Package akka.persistence.typed.telemetry

Class DurableStateBehaviorEnsemble

java.lang.Object

akka.persistence.typed.telemetry.DurableStateBehaviorEnsemble

All Implemented Interfaces:

DurableStateBehaviorInstrumentation

public class DurableStateBehaviorEnsemble
extends java.lang.Object
implements DurableStateBehaviorInstrumentation

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
DurableStateBehaviorEnsemble(scala.collection.immutable.Seq<DurableStateBehaviorInstrumentation> instrumentations)

Method Summary

Modifier and Type	Method	Description
void	actorInitialized(ActorRef<?> actorRef)	Initialize state for an EventSourcedBehavior actor.
void	afterRequestRecoveryPermit(ActorRef<?> actorRef, java.lang.Object context)	Record after a recovery permit is requested.
java.lang.Object	beforeRequestRecoveryPermit(ActorRef<?> actorRef)	Record before a recovery permit is requested.
java.lang.Object	deleteStateCalled(ActorRef<?> actorRef, java.lang.Object command)	Record delete state.
scala.collection.immutable.Seq<java.lang.String>	dependencies()	Optional dependencies for this instrumentation.
scala.collection.immutable.Seq<DurableStateBehaviorInstrumentation>	instrumentations()
void	persistFailed(ActorRef<?> actorRef, java.lang.Throwable throwable, java.lang.Object state, long revision, java.lang.Object context)	Record persistence persist failure.
java.lang.Object	persistStateCalled(ActorRef<?> actorRef, java.lang.Object state, java.lang.Object command)	Record persist state.
void	persistStateDone(ActorRef<?> actorRef, java.lang.Object context)	Record state is written and the registered callback is called.
java.lang.Object	persistStateWritten(ActorRef<?> actorRef, java.lang.Object state, java.lang.Object context)	Record state is written but the registered callback has not been called yet
void	recoveryDone(ActorRef<?> actorRef)	Record persistence recovery done.
void	recoveryFailed(ActorRef<?> actorRef, java.lang.Throwable throwable)	Record persistence recovery failure.
void	recoveryStarted(ActorRef<?> actorRef)	Record persistence recovery started.

Methods inherited from class java.lang.Object

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

Constructor Detail

DurableStateBehaviorEnsemble

public DurableStateBehaviorEnsemble(scala.collection.immutable.Seq<DurableStateBehaviorInstrumentation> instrumentations)

Method Detail

actorInitialized

public void actorInitialized(ActorRef<?> actorRef)

Description copied from interface: DurableStateBehaviorInstrumentation

Initialize state for an EventSourcedBehavior actor.

Specified by:

actorInitialized in interface DurableStateBehaviorInstrumentation

afterRequestRecoveryPermit

public void afterRequestRecoveryPermit(ActorRef<?> actorRef,
                                       java.lang.Object context)

Description copied from interface: DurableStateBehaviorInstrumentation

Record after a recovery permit is requested.

Specified by:

afterRequestRecoveryPermit in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery permit is requested

context - returned by beforeRequestRecoveryPermit

beforeRequestRecoveryPermit

public java.lang.Object beforeRequestRecoveryPermit(ActorRef<?> actorRef)

Description copied from interface: DurableStateBehaviorInstrumentation

Record before a recovery permit is requested.

Specified by:

beforeRequestRecoveryPermit in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery permit is about to be requested

Returns:

context that will be passed to afterRequestRecoveryPermit

deleteStateCalled

public java.lang.Object deleteStateCalled(ActorRef<?> actorRef,
                                          java.lang.Object command)

Description copied from interface: DurableStateBehaviorInstrumentation

Record delete state.

Specified by:

deleteStateCalled in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the delete state will be sent to the store.

command - actor message (command) for which the state update was emitted.

Returns:

context that will be passed to persistStateWritten

dependencies

public scala.collection.immutable.Seq<java.lang.String> dependencies()

Description copied from interface: DurableStateBehaviorInstrumentation

Optional dependencies for this instrumentation.

Dependency instrumentations will always be ordered before this instrumentation.

Specified by:

dependencies in interface DurableStateBehaviorInstrumentation

Returns:

list of class names for optional instrumentation dependencies

instrumentations

public scala.collection.immutable.Seq<DurableStateBehaviorInstrumentation> instrumentations()

persistFailed

public void persistFailed(ActorRef<?> actorRef,
                          java.lang.Throwable throwable,
                          java.lang.Object state,
                          long revision,
                          java.lang.Object context)

Description copied from interface: DurableStateBehaviorInstrumentation

Record persistence persist failure.

Specified by:

persistFailed in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery has failed.

throwable - the cause of the failure.

state - the state that was to be persisted.

revision - the sequence number associated with the failure

context - context returned by persistStateCalled

persistStateCalled

public java.lang.Object persistStateCalled(ActorRef<?> actorRef,
                                           java.lang.Object state,
                                           java.lang.Object command)

Description copied from interface: DurableStateBehaviorInstrumentation

Record persist state.

Specified by:

persistStateCalled in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the state will be sent to the store.

state - the state that was submitted for persistence.

command - actor message (command) for which the state update was emitted.

Returns:

context that will be passed to persistStateWritten

persistStateDone

public void persistStateDone(ActorRef<?> actorRef,
                             java.lang.Object context)

Description copied from interface: DurableStateBehaviorInstrumentation

Record state is written and the registered callback is called.

Specified by:

persistStateDone in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the state has been successfully persisted.

context - context returned by persistStateWritten

persistStateWritten

public java.lang.Object persistStateWritten(ActorRef<?> actorRef,
                                            java.lang.Object state,
                                            java.lang.Object context)

Description copied from interface: DurableStateBehaviorInstrumentation

Record state is written but the registered callback has not been called yet

Specified by:

persistStateWritten in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the state has been successfully persisted.

state - the state that was stored in the journal.

context - context returned by persistStateCalled

Returns:

context that will be passed to persistStateDone

recoveryDone

public void recoveryDone(ActorRef<?> actorRef)

Description copied from interface: DurableStateBehaviorInstrumentation

Record persistence recovery done.

Specified by:

recoveryDone in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery is finished.

recoveryFailed

public void recoveryFailed(ActorRef<?> actorRef,
                           java.lang.Throwable throwable)

Description copied from interface: DurableStateBehaviorInstrumentation

Record persistence recovery failure.

Specified by:

recoveryFailed in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery has failed.

throwable - the cause of the failure.

recoveryStarted

public void recoveryStarted(ActorRef<?> actorRef)

Description copied from interface: DurableStateBehaviorInstrumentation

Record persistence recovery started.

Specified by:

recoveryStarted in interface DurableStateBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery is started.