alluxio.worker.grpc

Class DelegationWriteHandler

java.lang.Object

alluxio.worker.grpc.DelegationWriteHandler

All Implemented Interfaces:

io.grpc.stub.StreamObserver<WriteRequest>

public class DelegationWriteHandler
extends Object
implements io.grpc.stub.StreamObserver<WriteRequest>

A write request handler that delegate worker write request of different types to corresponding write handlers.

Constructor Summary

Constructors

Constructor and Description
DelegationWriteHandler(DefaultBlockWorker blockWorker, UfsManager ufsManager, io.grpc.stub.StreamObserver<WriteResponse> responseObserver, AuthenticatedUserInfo userInfo, boolean domainSocketEnabled)

Method Summary

Modifier and Type	Method and Description
void	onCancel() Handles cancel event from the client.
void	onCompleted()
void	onError(Throwable t)
void	onNext(WriteRequest request)

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegationWriteHandler

public DelegationWriteHandler(DefaultBlockWorker blockWorker,
                              UfsManager ufsManager,
                              io.grpc.stub.StreamObserver<WriteResponse> responseObserver,
                              AuthenticatedUserInfo userInfo,
                              boolean domainSocketEnabled)

Parameters:

blockWorker - the block worker instance

ufsManager - the UFS manager

responseObserver - the response observer of the gRPC stream

userInfo - the authenticated user info

domainSocketEnabled - whether using a domain socket

Method Detail

onNext

public void onNext(WriteRequest request)

Specified by:

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

onError

public void onError(Throwable t)

Specified by:

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

onCompleted

public void onCompleted()

Specified by:

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

onCancel

public void onCancel()

Handles cancel event from the client.