Package io.grpc.xds
Class FaultFilter.DelayInjectedCall<ReqT,RespT>
java.lang.Object
io.grpc.ClientCall<ReqT,RespT>
io.grpc.internal.DelayedClientCall<ReqT,RespT>
io.grpc.xds.FaultFilter.DelayInjectedCall<ReqT,RespT>
- Enclosing class:
FaultFilter
private final class FaultFilter.DelayInjectedCall<ReqT,RespT>
extends io.grpc.internal.DelayedClientCall<ReqT,RespT>
A
DelayedClientCall
with a fixed delay.-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.ClientCall
io.grpc.ClientCall.Listener<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) ScheduledFuture
<?> (package private) final Object
-
Constructor Summary
ConstructorsConstructorDescriptionDelayInjectedCall
(long delayNanos, Executor callExecutor, ScheduledExecutorService scheduler, io.grpc.Deadline deadline, com.google.common.base.Supplier<? extends io.grpc.ClientCall<ReqT, RespT>> callSupplier) -
Method Summary
Methods inherited from class io.grpc.internal.DelayedClientCall
cancel, getAttributes, halfClose, isReady, request, sendMessage, setCall, setMessageCompression, start, toString
-
Field Details
-
lock
-
delayTask
ScheduledFuture<?> delayTask -
cancelled
boolean cancelled
-
-
Constructor Details
-
DelayInjectedCall
DelayInjectedCall(long delayNanos, Executor callExecutor, ScheduledExecutorService scheduler, @Nullable io.grpc.Deadline deadline, com.google.common.base.Supplier<? extends io.grpc.ClientCall<ReqT, RespT>> callSupplier)
-
-
Method Details