alluxio.master.journal

Class JournalMasterClientServiceHandler

java.lang.Object

alluxio.grpc.JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

alluxio.master.journal.JournalMasterClientServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public class JournalMasterClientServiceHandler
extends JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

This class is a gRPC handler for journal master RPCs invoked by an Alluxio client.

Constructor Summary

Constructors

Constructor and Description
JournalMasterClientServiceHandler(JournalMaster journalMaster) Creates gRPC service handler for JobMaster service.

Method Summary

Modifier and Type	Method and Description
void	getNodeState(GetNodeStatePRequest request, io.grpc.stub.StreamObserver<GetNodeStatePResponse> responseObserver) Gets the state of the current node and returns whether it is primary or standby.
void	getQuorumInfo(GetQuorumInfoPRequest request, io.grpc.stub.StreamObserver<GetQuorumInfoPResponse> responseObserver) Gets list of server states in an embedded journal quorum.
void	getTransferLeaderMessage(GetTransferLeaderMessagePRequest request, io.grpc.stub.StreamObserver<GetTransferLeaderMessagePResponse> responseObserver) Gets exception message throwing when transfer leader.
void	removeQuorumServer(RemoveQuorumServerPRequest request, io.grpc.stub.StreamObserver<RemoveQuorumServerPResponse> responseObserver) Removes a server from embedded journal quorum.
void	resetPriorities(ResetPrioritiesPRequest request, io.grpc.stub.StreamObserver<ResetPrioritiesPResponse> responseObserver) Reset all the RaftPeer priorities.
void	transferLeadership(TransferLeadershipPRequest request, io.grpc.stub.StreamObserver<TransferLeadershipPResponse> responseObserver) Transfers the leadership from the current leader to another designated leader.

Methods inherited from class alluxio.grpc.JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalMasterClientServiceHandler

public JournalMasterClientServiceHandler(JournalMaster journalMaster)

Creates gRPC service handler for JobMaster service.

Parameters:

journalMaster - the journal master

Method Detail

getQuorumInfo

public void getQuorumInfo(GetQuorumInfoPRequest request,
                          io.grpc.stub.StreamObserver<GetQuorumInfoPResponse> responseObserver)

Description copied from class: JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

 Gets list of server states in an embedded journal quorum.
 

Overrides:

getQuorumInfo in class JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

removeQuorumServer

public void removeQuorumServer(RemoveQuorumServerPRequest request,
                               io.grpc.stub.StreamObserver<RemoveQuorumServerPResponse> responseObserver)

Description copied from class: JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

 Removes a server from embedded journal quorum.
 

Overrides:

removeQuorumServer in class JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

transferLeadership

public void transferLeadership(TransferLeadershipPRequest request,
                               io.grpc.stub.StreamObserver<TransferLeadershipPResponse> responseObserver)

Description copied from class: JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

 Transfers the leadership from the current leader to another designated leader.
 

Overrides:

transferLeadership in class JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

resetPriorities

public void resetPriorities(ResetPrioritiesPRequest request,
                            io.grpc.stub.StreamObserver<ResetPrioritiesPResponse> responseObserver)

Description copied from class: JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

 Reset all the RaftPeer priorities.
 

Overrides:

resetPriorities in class JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

getTransferLeaderMessage

public void getTransferLeaderMessage(GetTransferLeaderMessagePRequest request,
                                     io.grpc.stub.StreamObserver<GetTransferLeaderMessagePResponse> responseObserver)

Description copied from class: JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

 Gets exception message throwing when transfer leader.
 

Overrides:

getTransferLeaderMessage in class JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

getNodeState

public void getNodeState(GetNodeStatePRequest request,
                         io.grpc.stub.StreamObserver<GetNodeStatePResponse> responseObserver)

Description copied from class: JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

 Gets the state of the current node and returns whether it is primary or standby.
 

Overrides:

getNodeState in class JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase