alluxio.master.file.contexts

Class GrpcCallTracker

java.lang.Object

alluxio.master.file.contexts.GrpcCallTracker

All Implemented Interfaces:

CallTracker

public class GrpcCallTracker
extends java.lang.Object
implements CallTracker

CallTracker implementation for gRPC calls.

Field Summary

Fields inherited from interface alluxio.master.file.contexts.CallTracker

DISABLED_TRACKER, NOOP_TRACKER

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
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