alluxio.grpc

Interface BlockMasterWorkerServiceGrpc.AsyncService

All Known Implementing Classes:

BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase, BlockMasterWorkerServiceHandler

Enclosing class:

BlockMasterWorkerServiceGrpc

public static interface BlockMasterWorkerServiceGrpc.AsyncService

 This interface contains block master service endpoints for Alluxio workers.
 

Method Summary

Modifier and Type	Method and Description
default void	blockHeartbeat(BlockHeartbeatPRequest request, io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver) Periodic block worker heartbeat returns an optional command for the block worker to execute.
default void	commitBlock(CommitBlockPRequest request, io.grpc.stub.StreamObserver<CommitBlockPResponse> responseObserver) Marks the given block as committed.
default void	getWorkerId(GetWorkerIdPRequest request, io.grpc.stub.StreamObserver<GetWorkerIdPResponse> responseObserver) Returns a worker id for the given network address.
default void	notifyWorkerId(NotifyWorkerIdPRequest request, io.grpc.stub.StreamObserver<NotifyWorkerIdPResponse> responseObserver) Notify all masters about the worker ID.
default void	registerWorker(RegisterWorkerPRequest request, io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker.
default io.grpc.stub.StreamObserver<RegisterWorkerPRequest>	registerWorkerStream(io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker in a streaming way
default void	requestRegisterLease(GetRegisterLeasePRequest request, io.grpc.stub.StreamObserver<GetRegisterLeasePResponse> responseObserver) Requests a lease for registration

Method Detail

blockHeartbeat

default void blockHeartbeat(BlockHeartbeatPRequest request,
                            io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver)

 Periodic block worker heartbeat returns an optional command for the block worker to execute.
 

commitBlock

default void commitBlock(CommitBlockPRequest request,
                         io.grpc.stub.StreamObserver<CommitBlockPResponse> responseObserver)

 Marks the given block as committed.
 

getWorkerId

default void getWorkerId(GetWorkerIdPRequest request,
                         io.grpc.stub.StreamObserver<GetWorkerIdPResponse> responseObserver)

 Returns a worker id for the given network address.
 

notifyWorkerId

default void notifyWorkerId(NotifyWorkerIdPRequest request,
                            io.grpc.stub.StreamObserver<NotifyWorkerIdPResponse> responseObserver)

 Notify all masters about the worker ID.
 

registerWorker

default void registerWorker(RegisterWorkerPRequest request,
                            io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver)

 Registers a worker.
 

registerWorkerStream

default io.grpc.stub.StreamObserver<RegisterWorkerPRequest> registerWorkerStream(io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver)

 Registers a worker in a streaming way
 

requestRegisterLease

default void requestRegisterLease(GetRegisterLeasePRequest request,
                                  io.grpc.stub.StreamObserver<GetRegisterLeasePResponse> responseObserver)

 Requests a lease for registration