alluxio.grpc

Class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub>

alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub

Enclosing class:

BlockMasterWorkerServiceGrpc

public static final class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub>

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

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

Specified by:

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

blockHeartbeat

public BlockHeartbeatPResponse blockHeartbeat(BlockHeartbeatPRequest request)

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

commitBlock

public CommitBlockPResponse commitBlock(CommitBlockPRequest request)

 Marks the given block as committed.
 

commitBlockInUfs

public CommitBlockInUfsPResponse commitBlockInUfs(CommitBlockInUfsPRequest request)

 Marks the given block as committed which resides in UFS.
 

getWorkerId

public GetWorkerIdPResponse getWorkerId(GetWorkerIdPRequest request)

 Returns a worker id for the given network address.
 

notifyWorkerId

public NotifyWorkerIdPResponse notifyWorkerId(NotifyWorkerIdPRequest request)

 Notify all masters about the worker ID.
 

registerWorker

public RegisterWorkerPResponse registerWorker(RegisterWorkerPRequest request)

 Registers a worker.
 

requestRegisterLease

public GetRegisterLeasePResponse requestRegisterLease(GetRegisterLeasePRequest request)

 Requests a lease for registration