alluxio.master.service.rpc

Class RpcServerStandbyGrpcService

java.lang.Object

alluxio.master.service.rpc.RpcServerService

alluxio.master.service.rpc.RpcServerStandbyGrpcService

All Implemented Interfaces:

SimpleService

public class RpcServerStandbyGrpcService
extends RpcServerService

Created by RpcServerService.Factory. Manages the behavior of the master's rpc service. The grpc server is always on. When the promotion/demotion happens, the rpc service will be stopped and restarted. The new started grpc service will serve gRPC endpoints based on the node state (PRIMARY/STANDBY). No rejecting server is deployed.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.master.service.rpc.RpcServerService

RpcServerService.Factory

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Fields inherited from class alluxio.master.service.rpc.RpcServerService

mBindAddress, mGrpcServer, mMasterProcess, mMasterRegistry, mRejectingGrpcServer, mRpcExecutor

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RpcServerStandbyGrpcService(InetSocketAddress bindAddress, MasterProcess masterProcess, MasterRegistry masterRegistry)

Method Summary

Modifier and Type	Method and Description
void	demote() Demotes the service back to NodeState.STANDBY state.
boolean	isServingLeader()
boolean	isServingStandby()
void	promote() Promotes the service to NodeState.PRIMARY state.
void	start() Starts the service.
void	stop() Stops the service altogether and cleans up any state left.

Methods inherited from class alluxio.master.service.rpc.RpcServerService

isGrpcServerServing, isServing, startGrpcServer, startRejectingServer, stopGrpcServer, stopRejectingServer, stopRpcExecutor, waitFor, waitForBound, waitForFree

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

RpcServerStandbyGrpcService

protected RpcServerStandbyGrpcService(InetSocketAddress bindAddress,
                                      MasterProcess masterProcess,
                                      MasterRegistry masterRegistry)

Method Detail

isServingLeader

public boolean isServingLeader()

Overrides:

isServingLeader in class RpcServerService

Returns:

whether the grpc server is serving in leader mode

isServingStandby

public boolean isServingStandby()

Overrides:

isServingStandby in class RpcServerService

Returns:

whether the grpc server is serving in standby mode

start

public void start()

Description copied from interface: SimpleService

Starts the service. Leaves the service in NodeState.STANDBY state. Leaves the service in the same state as SimpleService.demote(). Can only be called once.

Specified by:

start in interface SimpleService

Overrides:

start in class RpcServerService

stop

public void stop()

Description copied from interface: SimpleService

Stops the service altogether and cleans up any state left. If SimpleService.start() has not been called on this service this method should be a noop. Can only be called once.

Specified by:

stop in interface SimpleService

Overrides:

stop in class RpcServerService

promote

public void promote()

Description copied from interface: SimpleService

Promotes the service to NodeState.PRIMARY state. Can only be called on a started service (i.e. SimpleService.start() must precede this method). Can only be called in NodeState.STANDBY state. Can be called multiple times (e.g. a service is promoted, then demoted, then promoted again).

Specified by:

promote in interface SimpleService

Overrides:

promote in class RpcServerService

demote

public void demote()

Description copied from interface: SimpleService

Demotes the service back to NodeState.STANDBY state. Can only be called on a started service (i.e. SimpleService.start() must precede this method). Can only be called in NodeState.PRIMARY state (i.e. SimpleService.promote() must precede this method). Can be called multiple times (e.g. a service is promoted, then demoted, then promoted again, and demoted again).

Specified by:

demote in interface SimpleService

Overrides:

demote in class RpcServerService