Package akka.persistence.telemetry
Interface RecoveryPermitterInstrumentation
-
- All Known Implementing Classes:
EmptyRecoveryPermitterInstrumentation
,EmptyRecoveryPermitterInstrumentation$
,RecoveryPermitterEnsemble
public interface RecoveryPermitterInstrumentation
INTERNAL API: Instrumentation SPI for PersistentActor.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.collection.immutable.Seq<java.lang.String>
dependencies()
Optional dependencies for this instrumentation.void
recoveryPermitterStatus(ActorRef recoveryPermitter, int maxPermits, int usedPermits, int pendingActors)
Record recovery permitter status - invoked after an actor has requested a permit.
-
-
-
Method Detail
-
dependencies
scala.collection.immutable.Seq<java.lang.String> dependencies()
Optional dependencies for this instrumentation.Dependency instrumentations will always be ordered before this instrumentation.
- Returns:
- list of class names for optional instrumentation dependencies
-
recoveryPermitterStatus
void recoveryPermitterStatus(ActorRef recoveryPermitter, int maxPermits, int usedPermits, int pendingActors)
Record recovery permitter status - invoked after an actor has requested a permit.- Parameters:
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.
-
-