alluxio.master.block

Class RegisterStreamObserver

java.lang.Object

alluxio.master.block.RegisterStreamObserver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<RegisterWorkerPRequest>

public class RegisterStreamObserver
extends Object
implements io.grpc.stub.StreamObserver<RegisterWorkerPRequest>

This class handles the master side logic of the register stream. The stream lifecycle is internal to the master. In other words, there should be no external control on the request/response observers external to this class. The only exception to this is the DefaultBlockMaster.WorkerRegisterStreamGCExecutor.

Constructor Summary

Constructors

Constructor and Description
RegisterStreamObserver(BlockMaster blockMaster, io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Constructor.

Method Summary

Modifier and Type	Method and Description
void	onCompleted()
void	onError(Throwable t)
void	onNext(RegisterWorkerPRequest chunk)

Methods inherited from class java.lang.Object

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

Constructor Detail

RegisterStreamObserver

public RegisterStreamObserver(BlockMaster blockMaster,
                              io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver)

Constructor.

Parameters:

blockMaster - the block master

responseObserver - used to send response to the worker side

Method Detail

onNext

public void onNext(RegisterWorkerPRequest chunk)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<RegisterWorkerPRequest>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<RegisterWorkerPRequest>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<RegisterWorkerPRequest>