com.alipay.sofa.jraft.storage.snapshot.remote

Class RemoteFileCopier

java.lang.Object

com.alipay.sofa.jraft.storage.snapshot.remote.RemoteFileCopier

public class RemoteFileCopier
extends Object

Remote file copier

Author:

boyan (boyan@alibaba-inc.com) 2018-Mar-23 2:03:14 PM

Constructor Summary

Constructors

Constructor and Description
RemoteFileCopier()

Method Summary

Modifier and Type	Method and Description
boolean	copy2IoBuffer(String source, ByteBufferCollector destBuf, CopyOptions opt) Copy `source` from remote to buffer.
boolean	copyToFile(String source, String destPath, CopyOptions opts) Copy `source` from remote to local dest.
boolean	init(String uri, SnapshotThrottle snapshotThrottle, SnapshotCopierOptions opts)
Session	startCopy2IoBuffer(String source, ByteBufferCollector destBuf, CopyOptions opts)
Session	startCopyToFile(String source, String destPath, CopyOptions opts)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RemoteFileCopier

public RemoteFileCopier()

Method Detail

init

public boolean init(String uri,
                    SnapshotThrottle snapshotThrottle,
                    SnapshotCopierOptions opts)

copyToFile

public boolean copyToFile(String source,
                          String destPath,
                          CopyOptions opts)
                   throws IOException,
                          InterruptedException

Copy `source` from remote to local dest.

Parameters:

source - source from remote

destPath - local path

opts - options of copy

Returns:

true if copy success

Throws:

IOException

InterruptedException

startCopyToFile

public Session startCopyToFile(String source,
                               String destPath,
                               CopyOptions opts)
                        throws IOException

Throws:

IOException

copy2IoBuffer

public boolean copy2IoBuffer(String source,
                             ByteBufferCollector destBuf,
                             CopyOptions opt)
                      throws InterruptedException

Copy `source` from remote to buffer.

Parameters:

source - source from remote

destBuf - buffer of dest

opt - options of copy

Returns:

true if copy success

Throws:

InterruptedException

startCopy2IoBuffer

public Session startCopy2IoBuffer(String source,
                                  ByteBufferCollector destBuf,
                                  CopyOptions opts)