Package com.here.platform.data.client.utils

Class Retrier

java.lang.Object
com.here.platform.data.client.utils.Retrier
public class Retrier extends Object

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static final class 
    Retrier.NoMoreAttemptsException
     
    static class 
    Retrier.NoMoreAttemptsException$
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    Retrier()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static <A> scala.concurrent.Future<A>
    apply(RetryStrategy strategy, scala.Function1<Object,scala.concurrent.Future<A>> attempt, scala.concurrent.ExecutionContext executionContext, org.apache.pekko.actor.Scheduler scheduler, org.apache.pekko.event.LoggingAdapter log, RetryContext retryContext)
     
    static <A> scala.concurrent.Future<A>
    apply(RetryStrategy strategy, scala.Option<scala.concurrent.duration.FiniteDuration> maxWaitingTimeBetweenRetries, scala.Function1<Object,scala.concurrent.Future<A>> attempt, scala.concurrent.ExecutionContext executionContext, org.apache.pekko.actor.Scheduler scheduler, org.apache.pekko.event.LoggingAdapter log, RetryContext retryContext)
     
    static scala.PartialFunction<scala.util.Try<Object>,Object>
    failedWithRetriableHttpException()
     
    static <A> scala.concurrent.Future<A>
    withExplicitRetryCondition(RetryStrategy strategy, scala.Option<scala.concurrent.duration.FiniteDuration> maxWaitingTimeBetweenRetries, scala.Function1<Object,scala.concurrent.Future<A>> attempt, scala.PartialFunction<scala.util.Try<A>,Object> shouldRetry, scala.concurrent.ExecutionContext executionContext, org.apache.pekko.actor.Scheduler scheduler, org.apache.pekko.event.LoggingAdapter log, RetryContext retryContext)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • Retrier

      public Retrier()

  • Method Details

    • failedWithRetriableHttpException

      public static scala.PartialFunction<scala.util.Try<Object>,Object> failedWithRetriableHttpException()

    • apply

      public static <A> scala.concurrent.Future<A> apply(RetryStrategy strategy, scala.Function1<Object,scala.concurrent.Future<A>> attempt, scala.concurrent.ExecutionContext executionContext, org.apache.pekko.actor.Scheduler scheduler, org.apache.pekko.event.LoggingAdapter log, RetryContext retryContext)

    • apply

      public static <A> scala.concurrent.Future<A> apply(RetryStrategy strategy, scala.Option<scala.concurrent.duration.FiniteDuration> maxWaitingTimeBetweenRetries, scala.Function1<Object,scala.concurrent.Future<A>> attempt, scala.concurrent.ExecutionContext executionContext, org.apache.pekko.actor.Scheduler scheduler, org.apache.pekko.event.LoggingAdapter log, RetryContext retryContext)

    • withExplicitRetryCondition

      public static <A> scala.concurrent.Future<A> withExplicitRetryCondition(RetryStrategy strategy, scala.Option<scala.concurrent.duration.FiniteDuration> maxWaitingTimeBetweenRetries, scala.Function1<Object,scala.concurrent.Future<A>> attempt, scala.PartialFunction<scala.util.Try<A>,Object> shouldRetry, scala.concurrent.ExecutionContext executionContext, org.apache.pekko.actor.Scheduler scheduler, org.apache.pekko.event.LoggingAdapter log, RetryContext retryContext)