alluxio.grpc

Class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

java.lang.Object

alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

BlockMasterWorkerServiceHandler

Enclosing class:

BlockMasterWorkerServiceGrpc

public abstract static class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase
extends Object
implements io.grpc.BindableService

 This interface contains block master service endpoints for Alluxio workers.
 

Constructor Summary

Constructors

Constructor and Description
BlockMasterWorkerServiceImplBase()

Method Summary

Modifier and Type	Method and Description
io.grpc.ServerServiceDefinition	bindService()
void	blockHeartbeat(BlockHeartbeatPRequest request, io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver) Periodic block worker heartbeat returns an optional command for the block worker to execute.
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 java.lang.Object

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

Constructor Detail

BlockMasterWorkerServiceImplBase

public BlockMasterWorkerServiceImplBase()

Method Detail

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
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService