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

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface RecoveryPermitterInstrumentation

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 interface RecoveryPermitterInstrumentation

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.