Package akka.cluster.sharding.internal

Class ClusterShardingTelemetryEnsemble

java.lang.Object

akka.cluster.sharding.internal.ClusterShardingTelemetryEnsemble

All Implemented Interfaces:

ClusterShardingInstrumentation

public class ClusterShardingTelemetryEnsemble
extends java.lang.Object
implements ClusterShardingInstrumentation

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
ClusterShardingTelemetryEnsemble(scala.collection.immutable.Seq<ClusterShardingInstrumentation> 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<ClusterShardingInstrumentation>	instrumentations()
void	messageDropped(java.lang.String typeName)
void	receivedShardHome(java.lang.String typeName, java.lang.String shardId)
void	regionRequestedShardHome(java.lang.String typeName, java.lang.String shardId)
void	shardHandoffFinished(java.lang.String typeName, java.lang.String shard, boolean ok)
void	shardHandoffStarted(java.lang.String typeName, java.lang.String shard)
void	shardRegionBufferSize(java.lang.String typeName, int size)
void	shardRegionBufferSizeIncremented(java.lang.String typeName)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterShardingTelemetryEnsemble

public ClusterShardingTelemetryEnsemble(scala.collection.immutable.Seq<ClusterShardingInstrumentation> instrumentations)

Method Detail

dependencies

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

Description copied from interface: ClusterShardingInstrumentation

Optional dependencies for this instrumentation.

Dependency instrumentations will always be ordered before this instrumentation.

Specified by:

dependencies in interface ClusterShardingInstrumentation

Returns:

list of class names for optional instrumentation dependencies

instrumentations

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

messageDropped

public void messageDropped(java.lang.String typeName)

Specified by:

messageDropped in interface ClusterShardingInstrumentation

receivedShardHome

public void receivedShardHome(java.lang.String typeName,
                              java.lang.String shardId)

Specified by:

receivedShardHome in interface ClusterShardingInstrumentation

regionRequestedShardHome

public void regionRequestedShardHome(java.lang.String typeName,
                                     java.lang.String shardId)

Specified by:

regionRequestedShardHome in interface ClusterShardingInstrumentation

shardHandoffFinished

public void shardHandoffFinished(java.lang.String typeName,
                                 java.lang.String shard,
                                 boolean ok)

Specified by:

shardHandoffFinished in interface ClusterShardingInstrumentation

shardHandoffStarted

public void shardHandoffStarted(java.lang.String typeName,
                                java.lang.String shard)

Specified by:

shardHandoffStarted in interface ClusterShardingInstrumentation

shardRegionBufferSize

public void shardRegionBufferSize(java.lang.String typeName,
                                  int size)

Specified by:

shardRegionBufferSize in interface ClusterShardingInstrumentation

shardRegionBufferSizeIncremented

public void shardRegionBufferSizeIncremented(java.lang.String typeName)

Specified by:

shardRegionBufferSizeIncremented in interface ClusterShardingInstrumentation