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.
|
ClusterShardingHealthCheck |
INTERNAL API (ctr)
|
ClusterShardingHealthCheck$ |
|
ClusterShardingHealthCheckSettings |
|
ClusterShardingHealthCheckSettings$ |
Internal API
|
ClusterShardingSettings |
param: role specifies that this entity type requires cluster nodes with a specific role.
|
ClusterShardingSettings.TuningParameters |
|
ClusterShardingSettings$ |
|
DDataShardCoordinator |
INTERNAL API
Singleton coordinator (with state based on ddata) that decides where to allocate shards.
|
DDataShardCoordinator$ |
INTERNAL API
|
JoinConfigCompatCheckSharding |
INTERNAL API
|
NoOpShardingFlightRecorder |
INTERNAL
|
NoOpShardingFlightRecorder$ |
INTERNAL
|
OldCoordinatorStateMigrationEventAdapter |
Used for migrating from persistent state store mode to the new event sourced remember entities.
|
PersistentShardCoordinator |
Deprecated.
|
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.Active |
|
Shard.Active$ |
|
Shard.CurrentShardState |
|
Shard.CurrentShardState$ |
|
Shard.Entities |
|
Shard.EntitiesMovedToOtherShard |
If the shard id extractor is changed, remembered entities will start in a different shard
and this message is sent to the shard to not leak entityId -> RememberedButNotStarted entries
|
Shard.EntitiesMovedToOtherShard$ |
|
Shard.GetCurrentShardState$ |
|
Shard.GetShardStats$ |
|
Shard.LeaseAcquireResult |
|
Shard.LeaseAcquireResult$ |
|
Shard.LeaseLost |
|
Shard.LeaseLost$ |
|
Shard.LeaseRetry$ |
|
Shard.NoState$ |
Empty state rather than using optionals,
is never really kept track of but used to verify state transitions
and as return value instead of null
|
Shard.PassivateIdleTick$ |
|
Shard.Passivating |
|
Shard.Passivating$ |
|
Shard.RememberedButNotCreated$ |
In this state we know the entity has been stored in the remember sore but
it hasn't been created yet.
|
Shard.RememberEntityTimeout |
|
Shard.RememberEntityTimeout$ |
|
Shard.RememberingStart |
|
Shard.RememberingStart$ |
|
Shard.RememberingStop$ |
When remember entities is enabled an entity is in this state while
its stop is being recorded in the remember entities store, or while the stop is queued up
to be stored in the next batch.
|
Shard.RestartTerminatedEntity |
When remembering entities and the entity stops without issuing a Passivate , we
restart it after a back off using this message.
|
Shard.RestartTerminatedEntity$ |
|
Shard.ShardStats |
|
Shard.ShardStats$ |
|
Shard.WaitingForRestart$ |
|
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 |
Use akka.cluster.sharding.ShardCoordinator.ShardAllocationStrategy.leastShardAllocationStrategy instead.
|
ShardCoordinator.RebalanceWorker |
INTERNAL API.
|
ShardCoordinator.RebalanceWorker$ |
|
ShardCoordinator.RebalanceWorker$.ShardRegionTerminated |
|
ShardCoordinator.RebalanceWorker$.ShardRegionTerminated$ |
|
ShardCoordinator.ShardAllocationStrategy$ |
|
ShardCoordinator$ |
|
ShardingFlightRecorder$ |
INTERNAL API
|
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 |
|
ShardRegion.ClusterShardingStats$ |
|
ShardRegion.CurrentRegions |
Reply to GetCurrentRegions
|
ShardRegion.CurrentRegions$ |
|
ShardRegion.CurrentShardRegionState |
|
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$ |
|
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.GetShardRegionStatus$ |
INTERNAL API
|
ShardRegion.GracefulShutdown$ |
|
ShardRegion.HandOffStopper |
INTERNAL API.
|
ShardRegion.HandOffStopper$ |
INTERNAL API
|
ShardRegion.HashCodeMessageExtractor |
|
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.ShardRegionStatus |
INTERNAL API
|
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$ |
|