alluxio.master.journal.raft

Class RaftJournalServiceHandler

java.lang.Object

alluxio.grpc.RaftJournalServiceGrpc.RaftJournalServiceImplBase

alluxio.master.journal.raft.RaftJournalServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public class RaftJournalServiceHandler
extends RaftJournalServiceGrpc.RaftJournalServiceImplBase

RPC handler for raft journal service.

Constructor Summary

Constructors

Constructor and Description
RaftJournalServiceHandler(SnapshotReplicationManager manager, RaftJournalSystem raftJournalSystem)

Method Summary

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<DownloadSnapshotPRequest>	downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver) Downloads a snapshot from primary master.
io.grpc.stub.StreamObserver<UploadSnapshotPRequest>	uploadSnapshot(io.grpc.stub.StreamObserver<UploadSnapshotPResponse> responseObserver) Uploads a snapshot to primary master.

Methods inherited from class alluxio.grpc.RaftJournalServiceGrpc.RaftJournalServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

RaftJournalServiceHandler

public RaftJournalServiceHandler(SnapshotReplicationManager manager,
                                 RaftJournalSystem raftJournalSystem)

Parameters:

manager - the snapshot replication manager

raftJournalSystem - the raft journal system

Method Detail

uploadSnapshot

public io.grpc.stub.StreamObserver<UploadSnapshotPRequest> uploadSnapshot(io.grpc.stub.StreamObserver<UploadSnapshotPResponse> responseObserver)

Description copied from class: RaftJournalServiceGrpc.RaftJournalServiceImplBase

 Uploads a snapshot to primary master.
 

Overrides:

uploadSnapshot in class RaftJournalServiceGrpc.RaftJournalServiceImplBase

downloadSnapshot

public io.grpc.stub.StreamObserver<DownloadSnapshotPRequest> downloadSnapshot(io.grpc.stub.StreamObserver<DownloadSnapshotPResponse> responseObserver)

Description copied from class: RaftJournalServiceGrpc.RaftJournalServiceImplBase

 Downloads a snapshot from primary master.
 

Overrides:

downloadSnapshot in class RaftJournalServiceGrpc.RaftJournalServiceImplBase