alluxio.hub.agent.rpc.service

Class AgentManagerService

java.lang.Object

alluxio.hub.proto.AgentManagerServiceGrpc.AgentManagerServiceImplBase

alluxio.hub.agent.rpc.service.AgentManagerService

All Implemented Interfaces:

io.grpc.BindableService

public class AgentManagerService
extends AgentManagerServiceGrpc.AgentManagerServiceImplBase

The implementation of the RPC service that should be utilized by the hub manager to issue commands to specific nodes.

Field Summary

Fields

Modifier and Type	Field and Description
AgentProcessContext	mCtx

Constructor Summary

Constructors

Constructor and Description
AgentManagerService(AgentProcessContext ctx) The implementation for the manager agent service.

Method Summary

Modifier and Type	Method and Description
void	detectPresto(AgentDetectPrestoRequest request, io.grpc.stub.StreamObserver<AgentDetectPrestoResponse> responseObserver)
void	getConfigurationSet(AgentGetConfigurationSetRequest request, io.grpc.stub.StreamObserver<AgentGetConfigurationSetResponse> responseObserver)
void	listCatalogs(AgentListCatalogRequest request, io.grpc.stub.StreamObserver<AgentListCatalogResponse> responseObserver)
void	listFile(AgentListFileRequest request, io.grpc.stub.StreamObserver<AgentListFileResponse> responseObserver)
void	processStatusChange(AgentProcessStatusChangeRequest request, io.grpc.stub.StreamObserver<AgentProcessStatusChangeResponse> responseObserver)
void	removeFile(AgentRemoveFileRequest request, io.grpc.stub.StreamObserver<AgentRemoveFileResponse> responseObserver)
void	setPrestoConfDir(AgentSetPrestoConfRequest request, io.grpc.stub.StreamObserver<AgentSetPrestoConfResponse> responseObserver)
void	shutdown(AgentShutdownRequest request, io.grpc.stub.StreamObserver<AgentShutdownResponse> responseObserver)
void	uploadFile(AgentFileUploadRequest request, io.grpc.stub.StreamObserver<AgentFileUploadResponse> responseObserver)
void	validatePrestoConfDir(AgentValidatePrestoConfRequest request, io.grpc.stub.StreamObserver<AgentValidatePrestoConfResponse> responseObserver)
void	writeConfigurationSet(AgentWriteConfigurationSetRequest request, io.grpc.stub.StreamObserver<AgentWriteConfigurationSetResponse> responseObserver)

Methods inherited from class alluxio.hub.proto.AgentManagerServiceGrpc.AgentManagerServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Field Detail

mCtx

public AgentProcessContext mCtx

Constructor Detail

AgentManagerService

public AgentManagerService(AgentProcessContext ctx)

The implementation for the manager agent service.

Parameters:

ctx - the agent process context used to execute RPCs

Method Detail

processStatusChange

public void processStatusChange(AgentProcessStatusChangeRequest request,
                                io.grpc.stub.StreamObserver<AgentProcessStatusChangeResponse> responseObserver)

Overrides:

processStatusChange in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

getConfigurationSet

public void getConfigurationSet(AgentGetConfigurationSetRequest request,
                                io.grpc.stub.StreamObserver<AgentGetConfigurationSetResponse> responseObserver)

Overrides:

getConfigurationSet in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

writeConfigurationSet

public void writeConfigurationSet(AgentWriteConfigurationSetRequest request,
                                  io.grpc.stub.StreamObserver<AgentWriteConfigurationSetResponse> responseObserver)

Overrides:

writeConfigurationSet in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

uploadFile

public void uploadFile(AgentFileUploadRequest request,
                       io.grpc.stub.StreamObserver<AgentFileUploadResponse> responseObserver)

Overrides:

uploadFile in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

removeFile

public void removeFile(AgentRemoveFileRequest request,
                       io.grpc.stub.StreamObserver<AgentRemoveFileResponse> responseObserver)

Overrides:

removeFile in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

listFile

public void listFile(AgentListFileRequest request,
                     io.grpc.stub.StreamObserver<AgentListFileResponse> responseObserver)

Overrides:

listFile in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

detectPresto

public void detectPresto(AgentDetectPrestoRequest request,
                         io.grpc.stub.StreamObserver<AgentDetectPrestoResponse> responseObserver)

Overrides:

detectPresto in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

listCatalogs

public void listCatalogs(AgentListCatalogRequest request,
                         io.grpc.stub.StreamObserver<AgentListCatalogResponse> responseObserver)

Overrides:

listCatalogs in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

setPrestoConfDir

public void setPrestoConfDir(AgentSetPrestoConfRequest request,
                             io.grpc.stub.StreamObserver<AgentSetPrestoConfResponse> responseObserver)

Overrides:

setPrestoConfDir in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

validatePrestoConfDir

public void validatePrestoConfDir(AgentValidatePrestoConfRequest request,
                                  io.grpc.stub.StreamObserver<AgentValidatePrestoConfResponse> responseObserver)

Overrides:

validatePrestoConfDir in class AgentManagerServiceGrpc.AgentManagerServiceImplBase

shutdown

public void shutdown(AgentShutdownRequest request,
                     io.grpc.stub.StreamObserver<AgentShutdownResponse> responseObserver)

Overrides:

shutdown in class AgentManagerServiceGrpc.AgentManagerServiceImplBase