alluxio.master.journal.raft

Class RaftJournalServiceHandler

java.lang.Object

alluxio.grpc.RaftJournalServiceGrpc.RaftJournalServiceImplBase

alluxio.master.journal.raft.RaftJournalServiceHandler

All Implemented Interfaces:

RaftJournalServiceGrpc.AsyncService, io.grpc.BindableService

public class RaftJournalServiceHandler
extends RaftJournalServiceGrpc.RaftJournalServiceImplBase

RPC handler for raft journal service.

Constructor Summary

Constructors

Constructor and Description
RaftJournalServiceHandler(org.apache.ratis.statemachine.StateMachineStorage storage)

Method Summary

Modifier and Type	Method and Description
void	requestLatestSnapshotData(SnapshotMetadata request, io.grpc.stub.StreamObserver<SnapshotData> responseObserver) Request to download the snapshot information from a particular machine.
void	requestLatestSnapshotInfo(LatestSnapshotInfoPRequest request, io.grpc.stub.StreamObserver<SnapshotMetadata> responseObserver) Requests information about snapshots on a particular machine.

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

Methods inherited from interface alluxio.grpc.RaftJournalServiceGrpc.AsyncService

downloadSnapshot, uploadSnapshot

Constructor Detail

RaftJournalServiceHandler

public RaftJournalServiceHandler(org.apache.ratis.statemachine.StateMachineStorage storage)

Parameters:

storage - the storage that the state machine uses for its snapshots

Method Detail

requestLatestSnapshotInfo

public void requestLatestSnapshotInfo(LatestSnapshotInfoPRequest request,
                                      io.grpc.stub.StreamObserver<SnapshotMetadata> responseObserver)

Description copied from interface: RaftJournalServiceGrpc.AsyncService

 Requests information about snapshots on a particular machine.
 

requestLatestSnapshotData

public void requestLatestSnapshotData(SnapshotMetadata request,
                                      io.grpc.stub.StreamObserver<SnapshotData> responseObserver)

Description copied from interface: RaftJournalServiceGrpc.AsyncService

 Request to download the snapshot information from a particular machine.