Package akka.cluster.sharding.typed

Interface Summary

Interface	Description
ClusterShardingQuery	Protocol for querying sharding state e.g.
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.FilterSettings
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.OptimizerSettings
ClusterShardingSettings.PassivationStrategySettings$.PolicySettings
ClusterShardingSettings.RememberEntitiesStoreMode
ClusterShardingSettings.StateStoreMode
NumberOfProcesses	Reply for GetNumberOfProcesses
ReplicatedSharding<M>	Represents the sharding instances for the replicas of one Replicated Event Sourcing entity type
ReplicatedShardingExtension	Not for user extension.
ShardedDaemonProcessCommand	Commands for interacting with the sharded daemon process
ShardedDaemonProcessContext	Context with details about the Sharded Daemon Process instance to use when starting it
ShardingDirectReplication.Command	Not for user extension

Class Summary

Class	Description
ChangeNumberOfProcesses	Tell the sharded daemon process to rescale to the given number of processes.
ChangeNumberOfProcesses$
ClusterShardingSettings	param: numberOfShards number of shards used by the default HashCodeMessageExtractor param: role Specifies that this entity type requires cluster nodes with a specific role.
ClusterShardingSettings.PassivationStrategySettings	API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.
ClusterShardingSettings.PassivationStrategySettings$	API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.FilterSettings$
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.FrequencySketchSettings
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.FrequencySketchSettings$
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.HillClimbingSettings
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.HillClimbingSettings$
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.OptimizerSettings$
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.WindowSettings
ClusterShardingSettings.PassivationStrategySettings$.AdmissionSettings$.WindowSettings$
ClusterShardingSettings.PassivationStrategySettings$.IdleSettings
ClusterShardingSettings.PassivationStrategySettings$.IdleSettings$
ClusterShardingSettings.PassivationStrategySettings$.LeastFrequentlyUsedSettings
ClusterShardingSettings.PassivationStrategySettings$.LeastFrequentlyUsedSettings$
ClusterShardingSettings.PassivationStrategySettings$.LeastRecentlyUsedSettings
ClusterShardingSettings.PassivationStrategySettings$.LeastRecentlyUsedSettings$
ClusterShardingSettings.PassivationStrategySettings$.LeastRecentlyUsedSettings$.SegmentedSettings
ClusterShardingSettings.PassivationStrategySettings$.LeastRecentlyUsedSettings$.SegmentedSettings$
ClusterShardingSettings.PassivationStrategySettings$.MostRecentlyUsedSettings
ClusterShardingSettings.PassivationStrategySettings$.MostRecentlyUsedSettings$
ClusterShardingSettings.PassivationStrategySettings$.PolicySettings$
ClusterShardingSettings.RememberEntitiesStoreMode$
ClusterShardingSettings.RememberEntitiesStoreModeDData$
ClusterShardingSettings.RememberEntitiesStoreModeEventSourced$
ClusterShardingSettings.StateStoreMode$
ClusterShardingSettings.StateStoreModeDData$
ClusterShardingSettings.StateStoreModePersistence$
ClusterShardingSettings.TuningParameters
ClusterShardingSettings$
GetClusterShardingStats	Query the statistics about the currently running sharded entities in the entire cluster.
GetClusterShardingStats$
GetNumberOfProcesses	Query the sharded daemon process for the current scale
GetNumberOfProcesses$
GetShardRegionState	Query the ShardRegion state for the given entity type key.
GetShardRegionState$
HashCodeMessageExtractor<M>	Default message extractor type, using envelopes to identify what entity a message is for and the hashcode of the entityId to decide which shard an entity belongs to.
HashCodeNoEnvelopeMessageExtractor<M>	Default message extractor type, using a property of the message to identify what entity a message is for and the hashcode of the entityId to decide which shard an entity belongs to.
Murmur2MessageExtractor<M>	The murmur2 message extractor uses the same algorithm as the default kafka partitioner allowing kafka partitions to be mapped to shards.
Murmur2NoEnvelopeMessageExtractor<M>
ReplicatedEntity<M>	Settings for a specific replica id in replicated sharding Currently only Entity's with ShardingEnvelope are supported but this may change in the future
ReplicatedEntity$
ReplicatedEntityProvider<M>
ReplicatedEntityProvider$
ReplicatedShardingExtension$	Extension for running Replicated Event Sourcing in sharding by starting one separate instance of sharding per replica.
ShardedDaemonProcessSettings	Not for user constructions, use factory methods to instantiate.
ShardedDaemonProcessSettings$
ShardingDirectReplication	INTERNAL API
ShardingDirectReplication.VerifyStarted$
ShardingDirectReplication$	INTERNAL API
ShardingEnvelope<M>	Default envelope type that may be used with Cluster Sharding.
ShardingEnvelope$
ShardingMessageExtractor<E,M>	Entirely customizable typed message extractor.
ShardingMessageExtractor$
SliceRangeShardAllocationStrategy	Intended to be used with database sharding, https://doc.akka.io/docs/akka-persistence-r2dbc/current/data-partition.html, with a cluster of many Akka nodes.
SliceRangeShardAllocationStrategy.ShardBySliceMessageExtractor<M>	To be used together with SliceRangeShardAllocationStrategy.
SliceRangeShardAllocationStrategy$