object Retry extends Logging
- Alphabetic
- By Inheritance
- Retry
- Logging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- case class Policy(retriesLeft: Int, initialDelay: Duration, backoffFactor: Int) extends Product with Serializable
Description of a retry policy.
Description of a retry policy.
- retriesLeft
Number of retries left.
- initialDelay
Initial delay to use upon the next restart.
- backoffFactor
Factor to increase the delay by after every restart.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isInterruptionException(e: Throwable): Boolean
Checks whether the given exception is caused by an interrupt.
- val log: Logger
- Attributes
- protected
- Definition Classes
- Logging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def retryOnFailure[R](retryPolicy: Policy)(code: => R): R
Executes the given
code
, retrying as many times as needed if it throws non-interrupt exceptions.Executes the given
code
, retrying as many times as needed if it throws non-interrupt exceptions. Returns the result of the last successful execution or throws an exception if either it gets interrupted or is out of retries.- Annotations
- @tailrec()
- def retryOnFailureIf(policy: Policy)(shouldRetry: => Boolean)(code: => Unit): Unit
Executes the given
code
, retrying as many times as needed if it throws non-interrupt exceptions and if the givenshouldRetry
predicate evaluates to true.Executes the given
code
, retrying as many times as needed if it throws non-interrupt exceptions and if the givenshouldRetry
predicate evaluates to true.- Annotations
- @tailrec()
- def retryUntil[R](policy: Policy)(check: (R) => Boolean)(code: => R): R
Executes the given
code
until the specifiedcheck
returns true.Executes the given
code
until the specifiedcheck
returns true. Returns the result of the last execution, even if we run out of retries.- Annotations
- @tailrec()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()