final class RestartSettings extends AnyRef

Source
RestartSettings.scala
Linear Supertypes
AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RestartSettings
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val logSettings: LogSettings
  2. val maxBackoff: FiniteDuration
  3. val maxRestarts: Int
  4. val maxRestartsWithin: FiniteDuration
  5. val minBackoff: FiniteDuration
  6. val randomFactor: Double
  7. val restartOn: (Throwable) => Boolean
  8. def toString(): String
    Definition Classes
    RestartSettings → AnyRef → Any
  9. def withLogSettings(newLogSettings: LogSettings): RestartSettings
  10. def withMaxBackoff(value: Duration): RestartSettings

    Java API: the exponential back-off is capped to this duration

  11. def withMaxBackoff(value: FiniteDuration): RestartSettings

    Scala API: the exponential back-off is capped to this duration

  12. def withMaxRestarts(count: Int, within: Duration): RestartSettings

    Java API: The amount of restarts is capped to count within a timeframe of within

  13. def withMaxRestarts(count: Int, within: FiniteDuration): RestartSettings

    Scala API: The amount of restarts is capped to count within a timeframe of within

  14. def withMinBackoff(value: Duration): RestartSettings

    Java API: minimum (initial) duration until the child actor will started again, if it is terminated

  15. def withMinBackoff(value: FiniteDuration): RestartSettings

    Scala API: minimum (initial) duration until the child actor will started again, if it is terminated

  16. def withRandomFactor(value: Double): RestartSettings

    After calculation of the exponential back-off an additional random delay based on this factor is added e.g.

    After calculation of the exponential back-off an additional random delay based on this factor is added e.g. 0.2 adds up to 20% delay. In order to skip this additional delay pass in 0

  17. def withRestartOn(restartOn: Predicate[Throwable]): RestartSettings

    Decides whether the failure should restart the stream or make the surrounding stream fail