Package akka.persistence.telemetry
Class RecoveryPermitterEnsemble
- java.lang.Object
-
- akka.persistence.telemetry.RecoveryPermitterEnsemble
-
- All Implemented Interfaces:
RecoveryPermitterInstrumentation
public class RecoveryPermitterEnsemble extends java.lang.Object implements RecoveryPermitterInstrumentation
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description RecoveryPermitterEnsemble(scala.collection.immutable.Seq<RecoveryPermitterInstrumentation> instrumentations)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.collection.immutable.Seq<java.lang.String>
dependencies()
Optional dependencies for this instrumentation.scala.collection.immutable.Seq<RecoveryPermitterInstrumentation>
instrumentations()
void
recoveryPermitterStatus(ActorRef recoveryPermitter, int maxPermits, int usedPermits, int pendingActors)
Record recovery permitter status - invoked after an actor has requested a permit.
-
-
-
Constructor Detail
-
RecoveryPermitterEnsemble
public RecoveryPermitterEnsemble(scala.collection.immutable.Seq<RecoveryPermitterInstrumentation> instrumentations)
-
-
Method Detail
-
dependencies
public scala.collection.immutable.Seq<java.lang.String> dependencies()
Description copied from interface:RecoveryPermitterInstrumentation
Optional dependencies for this instrumentation.Dependency instrumentations will always be ordered before this instrumentation.
- Specified by:
dependencies
in interfaceRecoveryPermitterInstrumentation
- Returns:
- list of class names for optional instrumentation dependencies
-
instrumentations
public scala.collection.immutable.Seq<RecoveryPermitterInstrumentation> instrumentations()
-
recoveryPermitterStatus
public void recoveryPermitterStatus(ActorRef recoveryPermitter, int maxPermits, int usedPermits, int pendingActors)
Description copied from interface:RecoveryPermitterInstrumentation
Record recovery permitter status - invoked after an actor has requested a permit.- Specified by:
recoveryPermitterStatus
in interfaceRecoveryPermitterInstrumentation
- 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.
-
-