Interface | Description |
---|---|
ClusterShardingSerializable |
Marker trait for remote messages and persistent events/snapshots with special serializer.
|
Shard.ShardCommand |
A Shard command
|
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 |
Class | Description |
---|---|
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$ | |
DDataShardCoordinator |
Singleton coordinator (with state based on ddata) that decides where to allocate shards.
|
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.Removals | |
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals$ | |
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result | |
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result$ | |
RemoveInternalClusterShardingData.RemoveOnePersistenceId$ |
INTERNAL API
|
RemoveInternalClusterShardingData$ |
Utility program that removes the internal data stored with Akka Persistence
by the Cluster Sharding coordinator.
|
Shard |
INTERNAL API
|
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.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.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.CurrentRegions |
Reply to
GetCurrentRegions |
ShardRegion.CurrentRegions$ | |
ShardRegion.GetCurrentRegions$ | |
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$ |