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
Shard.ShardQuery
Shard.StateChange
ShardCoordinator.Internal$.CoordinatorCommand
ShardCoordinator.Internal$.CoordinatorMessage
ShardCoordinator.Internal$.DomainEvent
ShardCoordinator.ShardAllocationStrategy	Invoked when the location of a new shard is to be decided.
ShardRegion.MessageExtractor	Extract the entity id from an incoming message.
ShardRegion.ShardRegionCommand
ShardRegion.ShardRegionQuery

Class Summary

Class	Description
AllAtOnceEntityRecoveryStrategy
ClusterSharding	Scala API: Register a named entity type by defining the Props of the entity actor and functions to extract entity and shard identifier from messages.
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	If true, this node should run the shard region, otherwise just a shard proxy should started on this node.
ClusterShardingSettings.TuningParameters
ClusterShardingSettings$	Create settings from the default configuration akka.cluster.sharding.
ConstantRateEntityRecoveryStrategy
DDataShard	If the message is for the same entity as we are waiting for the update it will be added to its messageBuffer, which will be sent after the update has completed.
DDataShardCoordinator	Singleton coordinator (with state based on ddata) that decides where to allocate shards.
EntityRecoveryStrategy$	If the message is for the same entity as we are waiting for the update it will be added to its messageBuffer, which will be sent after the update has completed.
JoinConfigCompatCheckSharding	INTERNAL API
PersistentShard	INTERNAL API
PersistentShardCoordinator	Singleton coordinator that decides where to allocate shards.
RememberEntityStarter	INTERNAL API: Actor responsible for starting entities when rememberEntities is enabled
RememberEntityStarter$	Will call onLeaseAcquired when completed, also when lease isn't used
RemoveInternalClusterShardingData
RemoveInternalClusterShardingData.RemoveOnePersistenceId
RemoveInternalClusterShardingData.RemoveOnePersistenceId$	INTERNAL API
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Removals
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Removals$
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Result
RemoveInternalClusterShardingData.RemoveOnePersistenceId$.Result$
RemoveInternalClusterShardingData$
Shard	Will call onLeaseAcquired when completed, also when lease isn't used
Shard.CurrentShardState
Shard.CurrentShardState$
Shard.EntityStarted
Shard.EntityStarted$
Shard.EntityStopped
Shard.EntityStopped$
Shard.GetCurrentShardState$
Shard.GetShardStats$
Shard.LeaseAcquireResult
Shard.LeaseAcquireResult$
Shard.LeaseLost
Shard.LeaseLost$
Shard.LeaseRetry$
Shard.PassivateIdleTick$
Shard.RestartEntities
Shard.RestartEntities$
Shard.RestartEntity
Shard.RestartEntity$
Shard.ShardStats
Shard.ShardStats$
Shard.State
Shard.State$
Shard$	A Shard command
ShardCoordinator
ShardCoordinator.AbstractShardAllocationStrategy
ShardCoordinator.Internal$
ShardCoordinator.LeastShardAllocationStrategy	The default implementation of ShardCoordinator.LeastShardAllocationStrategy allocates new shards to the ShardRegion with least number of previously allocated shards.
ShardCoordinator.RebalanceWorker
ShardCoordinator$	INTERNAL API Factory method for the Props of the ShardCoordinator actor.
ShardRegion	When leaving the coordinator singleton is started rather quickly on next oldest node and therefore it is good to send the GracefulShutdownReq to the likely locations of the coordinator.
ShardRegion.ClusterShardingStats
ShardRegion.ClusterShardingStats$
ShardRegion.CurrentRegions	Java API
ShardRegion.CurrentRegions$
ShardRegion.CurrentShardRegionState	Java API:
ShardRegion.CurrentShardRegionState$
ShardRegion.GetClusterShardingStats
ShardRegion.GetClusterShardingStats$
ShardRegion.GetCurrentRegions$
ShardRegion.GetShardRegionState$
ShardRegion.GetShardRegionStats$
ShardRegion.GracefulShutdown$
ShardRegion.HandOffStopper
ShardRegion.HashCodeMessageExtractor
ShardRegion.HashCodeMessageExtractor$
ShardRegion.Passivate
ShardRegion.Passivate$
ShardRegion.ShardInitialized
ShardRegion.ShardInitialized$
ShardRegion.ShardRegionStats	Java API
ShardRegion.ShardRegionStats$
ShardRegion.ShardState
ShardRegion.ShardState$
ShardRegion.StartEntity
ShardRegion.StartEntity$
ShardRegion.StartEntityAck
ShardRegion.StartEntityAck$
ShardRegion$	INTERNAL API Factory method for the Props of the ShardRegion actor.