case class Budget(retryBudget: RetryBudget, requeueBackoffs: Backoff = Budget.emptyBackoffSchedule) extends Product with Serializable
Determines how many failed requests are eligible for being retried.
- retryBudget
maintains a budget of remaining retries for an individual request.
- requeueBackoffs
schedule of delays applied between each automatic retry.
- Note
requeueBackoffs only apply to automatic retries and not to requests using a RetryPolicy
- Alphabetic
- By Inheritance
- Budget
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Budget(retryBudget: RetryBudget)
- new Budget(retryBudget: RetryBudget, requeueBackoffs: Backoff = Budget.emptyBackoffSchedule)
- retryBudget
maintains a budget of remaining retries for an individual request.
- requeueBackoffs
schedule of delays applied between each automatic retry.
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 canEqual(other: Any): Boolean
- Definition Classes
- Budget → Equals
- 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(other: Any): Boolean
The equals method only compares the retryBudget field of this instance, since the requeueBackoffs Stream[Duration] is possibly infinite, resulting in an infinite computation to compare for equality.
The equals method only compares the retryBudget field of this instance, since the requeueBackoffs Stream[Duration] is possibly infinite, resulting in an infinite computation to compare for equality.
- Definition Classes
- Budget → Equals → AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
For the hashCode of this class we only take into account the hashCode of the RetryBudget field.
For the hashCode of this class we only take into account the hashCode of the RetryBudget field. The requeueBackoffs Stream[Duration] is possibly infinite, resulting in an infinite computation to get to the hashCode.
- Definition Classes
- Budget → AnyRef → Any
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def mk(): (Budget, Param[Budget])
- 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 productElementNames: Iterator[String]
- Definition Classes
- Product
- val requeueBackoffs: Backoff
- val retryBudget: RetryBudget
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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()