Package akka.cluster.sharding

Interface Summary

Interface	Description
ClusterShardingSerializable	Marker trait for remote messages and persistent events/snapshots with special serializer.
EntityRecoveryStrategy
RememberingShard	INTERNAL API: Common things for PersistentShard and DDataShard
Shard.ShardCommand	A Shard command
Shard.ShardQuery	A query for information about the shard
Shard.StateChange	A case class which represents a state change for the Shard
ShardCoordinator.Internal$.CoordinatorCommand	Messages sent to the coordinator
ShardCoordinator.Internal$.CoordinatorMessage	Messages sent from the coordinator
ShardCoordinator.Internal$.DomainEvent
ShardCoordinator.ShardAllocationStrategy	Interface of the pluggable shard allocation and rebalancing logic used by the ShardCoordinator.
ShardCoordinator.StartableAllocationStrategy	Shard allocation strategy where start is called by the shard coordinator before any calls to rebalance or allocate shard.
ShardRegion.MessageExtractor	Java API: Interface of functions to extract entity id, shard id, and the message to send to the entity from an incoming message.
ShardRegion.ShardRegionCommand
ShardRegion.ShardRegionQuery

Class Summary

Class	Description
AllAtOnceEntityRecoveryStrategy
ClusterSharding
ClusterSharding$	This extension provides sharding functionality of actors in a cluster.
ClusterShardingGuardian	INTERNAL API.
ClusterShardingGuardian.Start
ClusterShardingGuardian.Start$
ClusterShardingGuardian.Started
ClusterShardingGuardian.Started$
ClusterShardingGuardian.StartProxy
ClusterShardingGuardian.StartProxy$
ClusterShardingGuardian$	INTERNAL API.
ClusterShardingSettings	param: role specifies that this entity type requires cluster nodes with a specific role.
ClusterShardingSettings.TuningParameters
ClusterShardingSettings$
ConstantRateEntityRecoveryStrategy
DDataShard	INTERNAL API
DDataShardCoordinator	Singleton coordinator (with state based on ddata) that decides where to allocate shards.
EntityRecoveryStrategy$
JoinConfigCompatCheckSharding	INTERNAL API
PersistentShard	INTERNAL API
PersistentShardCoordinator	Deprecated. Use `ddata` mode, persistence mode is deprecated.
RememberEntityStarter	INTERNAL API: Actor responsible for starting entities when rememberEntities is enabled
RememberEntityStarter$
RemoveInternalClusterShardingData
RemoveInternalClusterShardingData.RemoveOnePersistenceId	INTERNAL API: Remove all events and snapshots for one specific persistenceId.
RemoveInternalClusterShardingData.RemoveOnePersistenceId$	INTERNAL API
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Removals
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Removals$
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Result
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Result$
RemoveInternalClusterShardingData$	Utility program that removes the internal data stored with Akka Persistence by the Cluster ShardCoordinator.
Shard	INTERNAL API
Shard.CurrentShardState
Shard.CurrentShardState$
Shard.EntityStarted	State change for starting an entity in this Shard
Shard.EntityStarted$
Shard.EntityStopped	State change for an entity which has terminated.
Shard.EntityStopped$
Shard.GetCurrentShardState$
Shard.GetShardStats$
Shard.LeaseAcquireResult
Shard.LeaseAcquireResult$
Shard.LeaseLost
Shard.LeaseLost$
Shard.LeaseRetry$
Shard.PassivateIdleTick$
Shard.RestartEntities	When initialising a shard with remember entities enabled the following message is used to restart batches of entity actors at a time.
Shard.RestartEntities$
Shard.RestartEntity	When remembering entities and the entity stops without issuing a Passivate, we restart it after a back off using this message.
Shard.RestartEntity$
Shard.ShardStats
Shard.ShardStats$
Shard.State
Shard.State$
Shard$	INTERNAL API
ShardCoordinator	Singleton coordinator that decides where to allocate shards.
ShardCoordinator.AbstractShardAllocationStrategy	Java API: Java implementations of custom shard allocation and rebalancing logic used by the ShardCoordinator should extend this abstract class and implement the two methods.
ShardCoordinator.Internal$	INTERNAL API
ShardCoordinator.LeastShardAllocationStrategy	The default implementation of ShardCoordinator.LeastShardAllocationStrategy allocates new shards to the ShardRegion with least number of previously allocated shards.
ShardCoordinator.RebalanceWorker	INTERNAL API.
ShardCoordinator$
ShardingLogMarker	This is public with the purpose to document the used markers and properties of log events.
ShardingLogMarker.Properties$	INTERNAL API
ShardingLogMarker$	This is public with the purpose to document the used markers and properties of log events.
ShardingQueries	INTERNAL API
ShardingQueries.ShardsQueryResult<B>	INTERNAL API The result of a group query and metadata.
ShardingQueries.ShardsQueryResult$
ShardingQueries$	INTERNAL API
ShardRegion	INTERNAL API
ShardRegion.ClusterShardingStats	Reply to ShardRegion.GetClusterShardingStats, contains statistics about all the sharding regions in the cluster.
ShardRegion.ClusterShardingStats$
ShardRegion.CurrentRegions	Reply to GetCurrentRegions
ShardRegion.CurrentRegions$
ShardRegion.CurrentShardRegionState	Reply to ShardRegion.GetShardRegionState$
ShardRegion.CurrentShardRegionState$
ShardRegion.GetClusterShardingStats	Send this message to the ShardRegion actor to request for ShardRegion.ClusterShardingStats, which contains statistics about the currently running sharded entities in the entire cluster.
ShardRegion.GetClusterShardingStats$
ShardRegion.GetCurrentRegions$	Send this message to the ShardRegion actor to request for ShardRegion.CurrentRegions, which contains the addresses of all registered regions.
ShardRegion.GetShardRegionState$	Send this message to a ShardRegion actor instance to request a ShardRegion.CurrentShardRegionState which describes the current state of the region.
ShardRegion.GetShardRegionStats$	Send this message to the ShardRegion actor to request for ShardRegion.ShardRegionStats, which contains statistics about the currently running sharded entities in the entire region.
ShardRegion.GracefulShutdown$
ShardRegion.HandOffStopper	INTERNAL API.
ShardRegion.HashCodeMessageExtractor	Convenience implementation of ShardRegion.MessageExtractor that construct shardId based on the hashCode of the entityId.
ShardRegion.HashCodeMessageExtractor$
ShardRegion.Passivate	If the state of the entities are persistent you may stop entities that are not used to reduce memory consumption.
ShardRegion.Passivate$
ShardRegion.ShardInitialized	We must be sure that a shard is initialized before to start send messages to it.
ShardRegion.ShardInitialized$
ShardRegion.ShardRegionStats	param: stats the region stats mapping of ShardId to number of entities param: failed set of shards if any failed to respond within the timeout
ShardRegion.ShardRegionStats$
ShardRegion.ShardState
ShardRegion.ShardState$
ShardRegion.StartEntity	When remembering entities and a shard is started, each entity id that needs to be running will trigger this message being sent through sharding.
ShardRegion.StartEntity$
ShardRegion.StartEntityAck	Sent back when a ShardRegion.StartEntity message was received and triggered the entity to start (it does not guarantee the entity successfully started)
ShardRegion.StartEntityAck$
ShardRegion$