Package akka.cluster.sharding.internal

Interface ClusterShardingInstrumentation

All Known Implementing Classes:

ClusterShardingTelemetryEnsemble, EmptyClusterShardingInstrumentation, EmptyClusterShardingInstrumentation$

public interface ClusterShardingInstrumentation

INTERNAL API: Instrumentation SPI for Akka Cluster.

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.Seq<java.lang.String>	dependencies()	Optional dependencies for this instrumentation.
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)

Method Detail

dependencies

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

Optional dependencies for this instrumentation.

Dependency instrumentations will always be ordered before this instrumentation.

Returns:

list of class names for optional instrumentation dependencies

messageDropped

void messageDropped(java.lang.String typeName)

receivedShardHome

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

regionRequestedShardHome

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

shardHandoffFinished

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

shardHandoffStarted

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

shardRegionBufferSize

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

shardRegionBufferSizeIncremented

void shardRegionBufferSizeIncremented(java.lang.String typeName)