Package akka.persistence.telemetry

Class EmptyRecoveryPermitterInstrumentation

java.lang.Object

akka.persistence.telemetry.EmptyRecoveryPermitterInstrumentation

All Implemented Interfaces:

RecoveryPermitterInstrumentation

Direct Known Subclasses:

EmptyRecoveryPermitterInstrumentation$

public class EmptyRecoveryPermitterInstrumentation
extends java.lang.Object
implements RecoveryPermitterInstrumentation

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
EmptyRecoveryPermitterInstrumentation()
EmptyRecoveryPermitterInstrumentation(ActorSystem system)

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

EmptyRecoveryPermitterInstrumentation

public EmptyRecoveryPermitterInstrumentation()

EmptyRecoveryPermitterInstrumentation

public EmptyRecoveryPermitterInstrumentation(ActorSystem system)

Method Detail

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.

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