alluxio.master.journal.raft

Class SnapshotUploader<S,R>

java.lang.Object

alluxio.master.journal.raft.SnapshotUploader<S,R>

Type Parameters:

S - the message type to send

R - the message type to receive

All Implemented Interfaces:

io.grpc.stub.ClientResponseObserver<S,R>, io.grpc.stub.StreamObserver<R>

public class SnapshotUploader<S,R>
extends Object
implements io.grpc.stub.StreamObserver<R>, io.grpc.stub.ClientResponseObserver<S,R>

A stream observer for uploading a snapshot.

Method Summary

Modifier and Type	Method and Description
void	beforeStart(io.grpc.stub.ClientCallStreamObserver<S> requestStream)
static SnapshotUploader<UploadSnapshotPRequest,UploadSnapshotPResponse>	forFollower(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage, org.apache.ratis.statemachine.SnapshotInfo snapshot) Builds a stream for follower to upload a snapshot.
static SnapshotUploader<DownloadSnapshotPResponse,DownloadSnapshotPRequest>	forLeader(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage, org.apache.ratis.statemachine.SnapshotInfo snapshot, io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> stream) Builds a stream for leader to upload a snapshot.
CompletableFuture<org.apache.ratis.statemachine.SnapshotInfo>	getCompletionFuture()
void	onCompleted()
void	onError(Throwable t)
void	onNext(R value)

Methods inherited from class java.lang.Object

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

Method Detail

forLeader

public static SnapshotUploader<DownloadSnapshotPResponse,DownloadSnapshotPRequest> forLeader(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage,
                                                                                             org.apache.ratis.statemachine.SnapshotInfo snapshot,
                                                                                             io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> stream)

Builds a stream for leader to upload a snapshot.

Parameters:

storage - the snapshot storage

snapshot - the snapshot to upload

stream - the download stream

Returns:

the upload stream for leader

forFollower

public static SnapshotUploader<UploadSnapshotPRequest,UploadSnapshotPResponse> forFollower(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage,
                                                                                           org.apache.ratis.statemachine.SnapshotInfo snapshot)

Builds a stream for follower to upload a snapshot.

Parameters:

storage - the snapshot storage

snapshot - the snapshot to upload

Returns:

the upload stream for follower

onNext

public void onNext(R value)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<R>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<R>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<R>

getCompletionFuture

public CompletableFuture<org.apache.ratis.statemachine.SnapshotInfo> getCompletionFuture()

Returns:

a future used to propagate completion status to SnapshotReplicationManager

beforeStart

public void beforeStart(io.grpc.stub.ClientCallStreamObserver<S> requestStream)

Specified by:

beforeStart in interface io.grpc.stub.ClientResponseObserver<S,R>