alluxio.master.file.contexts

Class GrpcCallTracker

java.lang.Object

alluxio.master.file.contexts.GrpcCallTracker

All Implemented Interfaces:

CallTracker

public class GrpcCallTracker
extends Object
implements CallTracker

CallTracker implementation for gRPC calls.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.file.contexts.CallTracker

CallTracker.Type

Constructor Summary

Constructors

Constructor and Description
GrpcCallTracker(io.grpc.stub.StreamObserver<?> streamObserver) Creates a call tracker for gRPC.

Method Summary

Modifier and Type	Method and Description
CallTracker.Type	getType()
boolean	isCancelled()

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcCallTracker

public GrpcCallTracker(io.grpc.stub.StreamObserver<?> streamObserver)

Creates a call tracker for gRPC.

Parameters:

streamObserver - server stream observer

Method Detail

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface CallTracker

Returns:

true if call is cancelled by the client

getType

public CallTracker.Type getType()

Specified by:

getType in interface CallTracker

Returns:

the type of call tracker