alluxio.hub.proto

Class HostedManagerServiceGrpc.HostedManagerServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<HostedManagerServiceGrpc.HostedManagerServiceStub>

alluxio.hub.proto.HostedManagerServiceGrpc.HostedManagerServiceStub

Enclosing class:

HostedManagerServiceGrpc

public static final class HostedManagerServiceGrpc.HostedManagerServiceStub
extends io.grpc.stub.AbstractAsyncStub<HostedManagerServiceGrpc.HostedManagerServiceStub>

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
void	alluxioClusterHeartbeat(AlluxioClusterHeartbeatRequest request, io.grpc.stub.StreamObserver<AlluxioClusterHeartbeatResponse> responseObserver) unary RPCs
io.grpc.stub.StreamObserver<ApplyMountPointResponse>	applyMountPoint(io.grpc.stub.StreamObserver<ApplyMountPointRequest> responseObserver) mount point methods
protected HostedManagerServiceGrpc.HostedManagerServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
io.grpc.stub.StreamObserver<DeleteMountPointResponse>	deleteMountPoint(io.grpc.stub.StreamObserver<DeleteMountPointRequest> responseObserver)
io.grpc.stub.StreamObserver<DetectPrestoResponse>	detectPresto(io.grpc.stub.StreamObserver<DetectPrestoRequest> responseObserver) presto methods
io.grpc.stub.StreamObserver<GetConfigurationSetResponse>	getConfigurationSet(io.grpc.stub.StreamObserver<GetConfigurationSetRequest> responseObserver) configuration methods
io.grpc.stub.StreamObserver<GetPrestoConfDirResponse>	getPrestoConfDir(io.grpc.stub.StreamObserver<GetPrestoConfDirRequest> responseObserver)
io.grpc.stub.StreamObserver<ListCatalogResponse>	listCatalog(io.grpc.stub.StreamObserver<ListCatalogRequest> responseObserver) catalog methods
io.grpc.stub.StreamObserver<ListFileResponse>	listFile(io.grpc.stub.StreamObserver<ListFileRequest> responseObserver) file methods
io.grpc.stub.StreamObserver<ListMountPointResponse>	listMountPoint(io.grpc.stub.StreamObserver<ListMountPointRequest> responseObserver)
io.grpc.stub.StreamObserver<PingManagerResponse>	pingManager(io.grpc.stub.StreamObserver<PingManagerRequest> responseObserver) bi-directional streaming RPCs - Hub Manager sends responses, Hosted Hub sends requests Manager methods
io.grpc.stub.StreamObserver<ProcessStatusChangeResponse>	processStatusChange(io.grpc.stub.StreamObserver<ProcessStatusChangeRequest> responseObserver) Alluxio process methods
void	registerManager(RegisterManagerRequest request, io.grpc.stub.StreamObserver<RegisterManagerResponse> responseObserver)
io.grpc.stub.StreamObserver<RemoveFileResponse>	removeFile(io.grpc.stub.StreamObserver<RemoveFileRequest> responseObserver)
io.grpc.stub.StreamObserver<SetPrestoConfDirResponse>	setPrestoConfDir(io.grpc.stub.StreamObserver<SetPrestoConfDirRequest> responseObserver)
io.grpc.stub.StreamObserver<SpeedTestResponse>	speedTest(io.grpc.stub.StreamObserver<SpeedTestRequest> responseObserver) speed test method
io.grpc.stub.StreamObserver<UploadFileResponse>	uploadFile(io.grpc.stub.StreamObserver<UploadFileRequest> responseObserver)
io.grpc.stub.StreamObserver<WriteConfigurationSetResponse>	writeConfigurationSet(io.grpc.stub.StreamObserver<WriteConfigurationSetRequest> responseObserver)

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected HostedManagerServiceGrpc.HostedManagerServiceStub build(io.grpc.Channel channel,
                                                                  io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<HostedManagerServiceGrpc.HostedManagerServiceStub>

alluxioClusterHeartbeat

public void alluxioClusterHeartbeat(AlluxioClusterHeartbeatRequest request,
                                    io.grpc.stub.StreamObserver<AlluxioClusterHeartbeatResponse> responseObserver)

 unary RPCs
 

registerManager

public void registerManager(RegisterManagerRequest request,
                            io.grpc.stub.StreamObserver<RegisterManagerResponse> responseObserver)

pingManager

public io.grpc.stub.StreamObserver<PingManagerResponse> pingManager(io.grpc.stub.StreamObserver<PingManagerRequest> responseObserver)

 bi-directional streaming RPCs - Hub Manager sends responses, Hosted Hub sends requests
 Manager methods
 

processStatusChange

public io.grpc.stub.StreamObserver<ProcessStatusChangeResponse> processStatusChange(io.grpc.stub.StreamObserver<ProcessStatusChangeRequest> responseObserver)

 Alluxio process methods
 

getConfigurationSet

public io.grpc.stub.StreamObserver<GetConfigurationSetResponse> getConfigurationSet(io.grpc.stub.StreamObserver<GetConfigurationSetRequest> responseObserver)

 configuration methods
 

writeConfigurationSet

public io.grpc.stub.StreamObserver<WriteConfigurationSetResponse> writeConfigurationSet(io.grpc.stub.StreamObserver<WriteConfigurationSetRequest> responseObserver)

listFile

public io.grpc.stub.StreamObserver<ListFileResponse> listFile(io.grpc.stub.StreamObserver<ListFileRequest> responseObserver)

 file methods
 

removeFile

public io.grpc.stub.StreamObserver<RemoveFileResponse> removeFile(io.grpc.stub.StreamObserver<RemoveFileRequest> responseObserver)

uploadFile

public io.grpc.stub.StreamObserver<UploadFileResponse> uploadFile(io.grpc.stub.StreamObserver<UploadFileRequest> responseObserver)

listCatalog

public io.grpc.stub.StreamObserver<ListCatalogResponse> listCatalog(io.grpc.stub.StreamObserver<ListCatalogRequest> responseObserver)

 catalog methods
 

applyMountPoint

public io.grpc.stub.StreamObserver<ApplyMountPointResponse> applyMountPoint(io.grpc.stub.StreamObserver<ApplyMountPointRequest> responseObserver)

 mount point methods
 

deleteMountPoint

public io.grpc.stub.StreamObserver<DeleteMountPointResponse> deleteMountPoint(io.grpc.stub.StreamObserver<DeleteMountPointRequest> responseObserver)

listMountPoint

public io.grpc.stub.StreamObserver<ListMountPointResponse> listMountPoint(io.grpc.stub.StreamObserver<ListMountPointRequest> responseObserver)

detectPresto

public io.grpc.stub.StreamObserver<DetectPrestoResponse> detectPresto(io.grpc.stub.StreamObserver<DetectPrestoRequest> responseObserver)

 presto methods
 

getPrestoConfDir

public io.grpc.stub.StreamObserver<GetPrestoConfDirResponse> getPrestoConfDir(io.grpc.stub.StreamObserver<GetPrestoConfDirRequest> responseObserver)

setPrestoConfDir

public io.grpc.stub.StreamObserver<SetPrestoConfDirResponse> setPrestoConfDir(io.grpc.stub.StreamObserver<SetPrestoConfDirRequest> responseObserver)

speedTest

public io.grpc.stub.StreamObserver<SpeedTestResponse> speedTest(io.grpc.stub.StreamObserver<SpeedTestRequest> responseObserver)

 speed test method