org.apache.flink.util.concurrent

Interface RetryStrategy

All Known Implementing Classes:

ExponentialBackoffRetryStrategy, FixedRetryStrategy

public interface RetryStrategy

Interface that encapsulates retry logic. An instances should be immutable.

Method Summary

Modifier and Type	Method and Description
RetryStrategy	getNextRetryStrategy()
int	getNumRemainingRetries()
java.time.Duration	getRetryDelay()

Method Detail

getNumRemainingRetries

int getNumRemainingRetries()

Returns:

the number of remaining retries

getRetryDelay

java.time.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