c

akka.persistence.telemetry

RecoveryPermitterEnsemble

class RecoveryPermitterEnsemble extends RecoveryPermitterInstrumentation

INTERNAL API

Annotations
@InternalStableApi()
Source
RecoveryPermitterInstrumentation.scala
Linear Supertypes
RecoveryPermitterInstrumentation, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RecoveryPermitterEnsemble
  2. RecoveryPermitterInstrumentation
  3. AnyRef
  4. 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

Instance Constructors

  1. new RecoveryPermitterEnsemble(instrumentations: Seq[RecoveryPermitterInstrumentation])

Value Members

  1. def dependencies: Seq[String]

    Optional dependencies for this instrumentation.

    Optional dependencies for this instrumentation.

    Dependency instrumentations will always be ordered before this instrumentation.

    returns

    list of class names for optional instrumentation dependencies

    Definition Classes
    → RecoveryPermitterInstrumentation
  2. val instrumentations: Seq[RecoveryPermitterInstrumentation]
  3. def recoveryPermitterStatus(recoveryPermitter: ActorRef, maxPermits: Int, usedPermits: Int, pendingActors: Int): Unit

    Record recovery permitter status - invoked after an actor has requested a permit.

    Record recovery permitter status - invoked after an actor has requested a permit.

    recoveryPermitter

    ActorRef handling the permits for this actor system.

    maxPermits

    the max permits set (via configuration).

    usedPermits

    the number of used (issued) permits.

    pendingActors

    number of pending actors waiting for a permit.

    Definition Classes
    → RecoveryPermitterInstrumentation