com.alipay.sofa.jraft.storage.snapshot.local

Class LocalSnapshotCopier

java.lang.Object

com.alipay.sofa.jraft.Status

com.alipay.sofa.jraft.storage.snapshot.SnapshotCopier

com.alipay.sofa.jraft.storage.snapshot.local.LocalSnapshotCopier

All Implemented Interfaces:

Copiable<Status>, Closeable, AutoCloseable

public class LocalSnapshotCopier
extends SnapshotCopier

Copy another machine snapshot to local.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-07 11:32:30 AM

Constructor Summary

Constructors

Constructor and Description
LocalSnapshotCopier()

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancel the copy job.
void	close()
SnapshotReader	getReader() Get the the SnapshotReader which represents the copied Snapshot
SnapshotStorage	getStorage()
boolean	init(String uri, SnapshotCopierOptions opts)
boolean	isFilterBeforeCopyRemote()
void	join() Block the thread until this copy job finishes, or some error occurs.
void	setFilterBeforeCopyRemote(boolean filterBeforeCopyRemote)
void	setSnapshotThrottle(SnapshotThrottle snapshotThrottle)
void	setStorage(SnapshotStorage storage)
void	start() Start the copy job.

Methods inherited from class com.alipay.sofa.jraft.Status

copy, equals, getCode, getErrorMsg, getRaftError, hashCode, isOk, OK, reset, setCode, setError, setError, setErrorMsg, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

LocalSnapshotCopier

public LocalSnapshotCopier()

Method Detail

setSnapshotThrottle

public void setSnapshotThrottle(SnapshotThrottle snapshotThrottle)

init

public boolean init(String uri,
                    SnapshotCopierOptions opts)

getStorage

public SnapshotStorage getStorage()

setStorage

public void setStorage(SnapshotStorage storage)

isFilterBeforeCopyRemote

public boolean isFilterBeforeCopyRemote()

setFilterBeforeCopyRemote

public void setFilterBeforeCopyRemote(boolean filterBeforeCopyRemote)

close

public void close()
           throws IOException

Throws:

IOException

start

public void start()

Description copied from class: SnapshotCopier

Start the copy job.

Specified by:

start in class SnapshotCopier

cancel

public void cancel()

Description copied from class: SnapshotCopier

Cancel the copy job.

Specified by:

cancel in class SnapshotCopier

join

public void join()
          throws InterruptedException

Description copied from class: SnapshotCopier

Block the thread until this copy job finishes, or some error occurs.

Specified by:

join in class SnapshotCopier

Throws:

InterruptedException - if the current thread is interrupted while waiting

getReader

public SnapshotReader getReader()

Description copied from class: SnapshotCopier

Get the the SnapshotReader which represents the copied Snapshot

Specified by:

getReader in class SnapshotCopier