| Interface | Description |
|---|---|
| ClusterShardingSerializable |
Marker trait for remote messages and persistent events/snapshots with special serializer.
|
| EntityRecoveryStrategy | |
| 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. |
| 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 | 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 | |
| DDataShardCoordinator |
Singleton coordinator (with state based on ddata) that decides where to allocate shards.
|
| EntityRecoveryStrategy$ | |
| PersistentShard |
INTERNAL API
|
| PersistentShardCoordinator |
Singleton coordinator that decides where to allocate shards.
|
| 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 Sharding coordinator.
|
| 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.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 an 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$ | |
| ShardRegion |
This actor creates children entity actors on demand for the shards that it is told to be
responsible for.
|
| 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.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 | |
| ShardRegion.ShardRegionStats$ | |
| ShardRegion.ShardState | |
| ShardRegion.ShardState$ | |
| ShardRegion$ |