alluxio.hub.manager.rpc.service

Class ManagerAgentService

java.lang.Object

alluxio.hub.proto.ManagerAgentServiceGrpc.ManagerAgentServiceImplBase

alluxio.hub.manager.rpc.service.ManagerAgentService

All Implemented Interfaces:

io.grpc.BindableService

public class ManagerAgentService
extends ManagerAgentServiceGrpc.ManagerAgentServiceImplBase

The implementation for the service of the Hub Manager manager which handles RPCs from agents.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ManagerAgentService(ManagerProcessContext ctx) Creates an instance of the RPC handler for agent requests.

Method Summary

Modifier and Type	Method and Description
void	agentHeartbeat(AgentHeartbeatRequest request, io.grpc.stub.StreamObserver<AgentHeartbeatResponse> responseObserver) A running agent will send a heartbeat message to the manager on an interval timer
void	registerAgent(RegisterAgentRequest request, io.grpc.stub.StreamObserver<RegisterAgentResponse> responseObserver) A running agent will attempt to register with the manager on startup

Methods inherited from class alluxio.hub.proto.ManagerAgentServiceGrpc.ManagerAgentServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

ManagerAgentService

public ManagerAgentService(ManagerProcessContext ctx)

Creates an instance of the RPC handler for agent requests.

Parameters:

ctx - the process context

Method Detail

registerAgent

public void registerAgent(RegisterAgentRequest request,
                          io.grpc.stub.StreamObserver<RegisterAgentResponse> responseObserver)

Description copied from class: ManagerAgentServiceGrpc.ManagerAgentServiceImplBase

 A running agent will attempt to register with the manager on startup
 

Overrides:

registerAgent in class ManagerAgentServiceGrpc.ManagerAgentServiceImplBase

agentHeartbeat

public void agentHeartbeat(AgentHeartbeatRequest request,
                           io.grpc.stub.StreamObserver<AgentHeartbeatResponse> responseObserver)

Description copied from class: ManagerAgentServiceGrpc.ManagerAgentServiceImplBase

 A running agent will send a heartbeat message to the manager on an interval timer
 

Overrides:

agentHeartbeat in class ManagerAgentServiceGrpc.ManagerAgentServiceImplBase