alluxio.grpc

Class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub>

alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub

Enclosing class:

BlockMasterWorkerServiceGrpc

public static final class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub
extends io.grpc.stub.AbstractAsyncStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub>

 This interface contains block master service endpoints for Alluxio workers.
 

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	blockHeartbeat(BlockHeartbeatPRequest request, io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver) Periodic block worker heartbeat returns an optional command for the block worker to execute.
protected BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	commitBlock(CommitBlockPRequest request, io.grpc.stub.StreamObserver<CommitBlockPResponse> responseObserver) Marks the given block as committed.
void	commitBlockInUfs(CommitBlockInUfsPRequest request, io.grpc.stub.StreamObserver<CommitBlockInUfsPResponse> responseObserver) Marks the given block as committed which resides in UFS.
void	getWorkerId(GetWorkerIdPRequest request, io.grpc.stub.StreamObserver<GetWorkerIdPResponse> responseObserver) Returns a worker id for the given network address.
void	notifyWorkerId(NotifyWorkerIdPRequest request, io.grpc.stub.StreamObserver<NotifyWorkerIdPResponse> responseObserver) Notify all masters about the worker ID.
void	registerWorker(RegisterWorkerPRequest request, io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker.
io.grpc.stub.StreamObserver<RegisterWorkerPRequest>	registerWorkerStream(io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker in a streaming way
void	requestRegisterLease(GetRegisterLeasePRequest request, io.grpc.stub.StreamObserver<GetRegisterLeasePResponse> responseObserver) Requests a lease for registration

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 BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub build(io.grpc.Channel channel,
                                                                          io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub>

blockHeartbeat

public 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

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

 Marks the given block as committed.
 

commitBlockInUfs

public void commitBlockInUfs(CommitBlockInUfsPRequest request,
                             io.grpc.stub.StreamObserver<CommitBlockInUfsPResponse> responseObserver)

 Marks the given block as committed which resides in UFS.
 

getWorkerId

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

 Returns a worker id for the given network address.
 

notifyWorkerId

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

 Notify all masters about the worker ID.
 

registerWorker

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

 Registers a worker.
 

registerWorkerStream

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

 Registers a worker in a streaming way
 

requestRegisterLease

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

 Requests a lease for registration