t

akka.persistence.telemetry

RecoveryPermitterInstrumentation

trait RecoveryPermitterInstrumentation extends AnyRef

INTERNAL API: Instrumentation SPI for PersistentActor.

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

Abstract Value Members

  1. abstract 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

  2. abstract 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.