Package io.deephaven.util

Class RetryStrategy

java.lang.Object

io.deephaven.util.RetryStrategy

public class RetryStrategy
extends Object

Utility class to support execution of gRPC requests with a retry strategy.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RetryStrategy.DeadlineExceededException	Exception class to signal deadline was exceeded while attempting retries with a retry strategy.

Field Summary

Fields

Modifier and Type	Field	Description
final Predicate<io.deephaven.shadow.core.io.grpc.Status>	doRetryPred
final RetryBackoffContext.Exponential.Params	params

Constructor Summary

Constructors

Constructor	Description
RetryStrategy(Predicate<io.deephaven.shadow.core.io.grpc.Status> doRetryPred, RetryBackoffContext.Exponential.Params params)	Create a new retry strategy.

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

doRetryPred

public final Predicate<io.deephaven.shadow.core.io.grpc.Status> doRetryPred

params

public final RetryBackoffContext.Exponential.Params params

Constructor Details

RetryStrategy

public RetryStrategy(Predicate<io.deephaven.shadow.core.io.grpc.Status> doRetryPred,
 RetryBackoffContext.Exponential.Params params)

Create a new retry strategy.

Parameters:

doRetryPred - The predicate that, based on a gRPC Status object, will decide whether to retry or not. It is a common case to only retry for Status.UNAVAILABLE, but more general strategies are possible.

params - Parameters for the retry strategy