Package io.servicetalk.concurrent.api

Class RetryStrategies

java.lang.Object
io.servicetalk.concurrent.api.RetryStrategies
public final class RetryStrategies extends Object
A set of strategies to use for retrying with Publisher.retryWhen(BiIntFunction), Single.retryWhen(BiIntFunction), and Completable.retryWhen(BiIntFunction) or in general.

  • Method Details

    • retryWithConstantBackoffFullJitter

      public static BiIntFunction<Throwable,Completable> retryWithConstantBackoffFullJitter(int maxRetries, Predicate<Throwable> causeFilter, Duration delay, Executor timerExecutor)
      Creates a new retry function that adds the passed constant Duration as a delay between retries. This additionally adds a "Full Jitter" for the backoff as described here.
      Parameters:
      maxRetries - Maximum number of allowed retries, after which the returned BiIntFunction will return a failed Completable with the passed Throwable as the cause
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      delay - Constant Duration of delay between retries
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable

    • retryWithConstantBackoffFullJitter

      public static BiIntFunction<Throwable,Completable> retryWithConstantBackoffFullJitter(Predicate<Throwable> causeFilter, Duration delay, Executor timerExecutor)
      Creates a new retry function that adds the passed constant Duration as a delay between retries. This additionally adds a "Full Jitter" for the backoff as described here. a failed Completable with the passed Throwable as the cause
      Parameters:
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      delay - Constant Duration of delay between retries
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable

    • retryWithConstantBackoffDeltaJitter

      public static BiIntFunction<Throwable,Completable> retryWithConstantBackoffDeltaJitter(Predicate<Throwable> causeFilter, Duration delay, Duration jitter, Executor timerExecutor)
      Creates a new retry function that adds the passed constant Duration as a delay between retries.
      Parameters:
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      delay - Constant Duration of delay between retries
      jitter - The jitter to apply to delay on each retry.
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable

    • retryWithConstantBackoffDeltaJitter

      public static BiIntFunction<Throwable,Completable> retryWithConstantBackoffDeltaJitter(int maxRetries, Predicate<Throwable> causeFilter, Duration delay, Duration jitter, Executor timerExecutor)
      Creates a new retry function that adds the passed constant Duration as a delay between retries.
      Parameters:
      maxRetries - Maximum number of allowed retries, after which the returned BiIntFunction will return a failed Completable with the passed Throwable as the cause
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      delay - Constant Duration of delay between retries
      jitter - The jitter to apply to delay on each retry.
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable

    • retryWithExponentialBackoffFullJitter

      public static BiIntFunction<Throwable,Completable> retryWithExponentialBackoffFullJitter(Predicate<Throwable> causeFilter, Duration initialDelay, Duration maxDelay, Executor timerExecutor)
      Creates a new retry function that adds a delay between retries. For first retry, the delay is initialDelay which is increased exponentially for subsequent retries. This additionally adds a "Full Jitter" for the backoff as described here.
      Parameters:
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      initialDelay - Delay Duration for the first retry and increased exponentially with each retry
      maxDelay - The maximum amount of delay that will be introduced.
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable

    • retryWithExponentialBackoffFullJitter

      public static BiIntFunction<Throwable,Completable> retryWithExponentialBackoffFullJitter(int maxRetries, Predicate<Throwable> causeFilter, Duration initialDelay, Duration maxDelay, Executor timerExecutor)
      Creates a new retry function that adds a delay between retries. For first retry, the delay is initialDelay which is increased exponentially for subsequent retries. This additionally adds a "Full Jitter" for the backoff as described here.
      Parameters:
      maxRetries - Maximum number of allowed retries, after which the returned BiIntFunction will return a failed Completable with the passed Throwable as the cause
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      initialDelay - Delay Duration for the first retry and increased exponentially with each retry
      maxDelay - The maximum amount of delay that will be introduced.
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable

    • retryWithExponentialBackoffDeltaJitter

      public static BiIntFunction<Throwable,Completable> retryWithExponentialBackoffDeltaJitter(Predicate<Throwable> causeFilter, Duration initialDelay, Duration jitter, Duration maxDelay, Executor timerExecutor)
      Creates a new retry function that adds a delay between retries. For first retry, the delay is initialDelay which is increased exponentially for subsequent retries.
      Parameters:
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      initialDelay - Delay Duration for the first retry and increased exponentially with each retry
      jitter - The jitter to apply to delay on each retry.
      maxDelay - The maximum amount of delay that will be introduced.
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable

    • retryWithExponentialBackoffDeltaJitter

      public static BiIntFunction<Throwable,Completable> retryWithExponentialBackoffDeltaJitter(int maxRetries, Predicate<Throwable> causeFilter, Duration initialDelay, Duration jitter, Duration maxDelay, Executor timerExecutor)
      Creates a new retry function that adds a delay between retries. For first retry, the delay is initialDelay which is increased exponentially for subsequent retries.
      Parameters:
      maxRetries - Maximum number of allowed retries, after which the returned BiIntFunction will return a failed Completable with the passed Throwable as the cause
      causeFilter - A Predicate that selects whether a Throwable cause should be retried
      initialDelay - Delay Duration for the first retry and increased exponentially with each retry
      jitter - The jitter to apply to delay on each retry.
      maxDelay - The maximum amount of delay that will be introduced.
      timerExecutor - Executor to be used to schedule timers for backoff
      Returns:
      A BiIntFunction to be used for retries which given a retry count and a Throwable returns a Completable that terminates successfully when the source has to be retried or terminates with error if the source should not be retried for the passed Throwable