alluxio.hub.proto

Class AgentManagerServiceGrpc.AgentManagerServiceImplBase

java.lang.Object

alluxio.hub.proto.AgentManagerServiceGrpc.AgentManagerServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

AgentManagerService

Enclosing class:

AgentManagerServiceGrpc

public abstract static class AgentManagerServiceGrpc.AgentManagerServiceImplBase
extends Object
implements io.grpc.BindableService

Constructor Summary

Constructors

Constructor and Description
AgentManagerServiceImplBase()

Method Summary

Modifier and Type	Method and Description
io.grpc.ServerServiceDefinition	bindService()
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 java.lang.Object

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

Constructor Detail

AgentManagerServiceImplBase

public AgentManagerServiceImplBase()

Method Detail

processStatusChange

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

getConfigurationSet

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

writeConfigurationSet

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

uploadFile

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

listFile

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

removeFile

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

detectPresto

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

listCatalogs

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

setPrestoConfDir

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

validatePrestoConfDir

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

shutdown

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

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService