Package org.apache.flink.util.concurrent
Interface RetryStrategy
-
- All Known Implementing Classes:
ExponentialBackoffRetryStrategy
,FixedRetryStrategy
,IncrementalDelayRetryStrategy
public interface RetryStrategy
Interface that encapsulates retry logic. An instances should be immutable.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RetryStrategy
getNextRetryStrategy()
int
getNumRemainingRetries()
Duration
getRetryDelay()
-
-
-
Method Detail
-
getNumRemainingRetries
int getNumRemainingRetries()
- Returns:
- the number of remaining retries
-
getRetryDelay
Duration getRetryDelay()
- Returns:
- the current delay if we need to retry
-
getNextRetryStrategy
RetryStrategy getNextRetryStrategy()
- Returns:
- the next retry strategy to current delay if we need to retry
-
-