alluxio.master.meta

Class MetaMasterMasterServiceHandler

java.lang.Object

alluxio.grpc.MetaMasterMasterServiceGrpc.MetaMasterMasterServiceImplBase

alluxio.master.meta.MetaMasterMasterServiceHandler

All Implemented Interfaces:

MetaMasterMasterServiceGrpc.AsyncService, io.grpc.BindableService

@NotThreadSafe
public final class MetaMasterMasterServiceHandler
extends MetaMasterMasterServiceGrpc.MetaMasterMasterServiceImplBase

This class is a gRPC handler for meta master RPCs invoked by an Alluxio standby master.

Constructor Summary

Constructors

Constructor and Description
MetaMasterMasterServiceHandler(MetaMaster metaMaster) Creates a new instance of MetaMasterMasterServiceHandler.

Method Summary

Modifier and Type	Method and Description
void	getMasterId(GetMasterIdPRequest request, io.grpc.stub.StreamObserver<GetMasterIdPResponse> responseObserver) Returns a master id for the given master address.
void	masterHeartbeat(MasterHeartbeatPRequest request, io.grpc.stub.StreamObserver<MasterHeartbeatPResponse> responseObserver) Heartbeats to indicate the master is lost or not.
void	registerMaster(RegisterMasterPRequest request, io.grpc.stub.StreamObserver<RegisterMasterPResponse> responseObserver) Registers a master.

Methods inherited from class alluxio.grpc.MetaMasterMasterServiceGrpc.MetaMasterMasterServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

MetaMasterMasterServiceHandler

public MetaMasterMasterServiceHandler(MetaMaster metaMaster)

Creates a new instance of MetaMasterMasterServiceHandler.

Parameters:

metaMaster - the Alluxio meta master

Method Detail

getMasterId

public void getMasterId(GetMasterIdPRequest request,
                        io.grpc.stub.StreamObserver<GetMasterIdPResponse> responseObserver)

Description copied from interface: MetaMasterMasterServiceGrpc.AsyncService

 Returns a master id for the given master address.
 

registerMaster

public void registerMaster(RegisterMasterPRequest request,
                           io.grpc.stub.StreamObserver<RegisterMasterPResponse> responseObserver)

Description copied from interface: MetaMasterMasterServiceGrpc.AsyncService

 Registers a master.
 

masterHeartbeat

public void masterHeartbeat(MasterHeartbeatPRequest request,
                            io.grpc.stub.StreamObserver<MasterHeartbeatPResponse> responseObserver)

Description copied from interface: MetaMasterMasterServiceGrpc.AsyncService

 Heartbeats to indicate the master is lost or not.