alluxio.master.meta

Class MetaMasterMasterServiceHandler

java.lang.Object

alluxio.grpc.MetaMasterMasterServiceGrpc.MetaMasterMasterServiceImplBase

alluxio.master.meta.MetaMasterMasterServiceHandler

All Implemented Interfaces:

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)
void	masterHeartbeat(MasterHeartbeatPRequest request, io.grpc.stub.StreamObserver<MasterHeartbeatPResponse> responseObserver)
void	registerMaster(RegisterMasterPRequest request, io.grpc.stub.StreamObserver<RegisterMasterPResponse> responseObserver)

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)

Overrides:

getMasterId in class MetaMasterMasterServiceGrpc.MetaMasterMasterServiceImplBase

registerMaster

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

Overrides:

registerMaster in class MetaMasterMasterServiceGrpc.MetaMasterMasterServiceImplBase

masterHeartbeat

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

Overrides:

masterHeartbeat in class MetaMasterMasterServiceGrpc.MetaMasterMasterServiceImplBase