Package org.apache.pekko.cluster.sharding.typed
package org.apache.pekko.cluster.sharding.typed
-
ClassDescriptionTell the sharded daemon process to rescale to the given number of processes.Protocol for querying sharding state e.g.param: numberOfShards number of shards used by the default
HashCodeMessageExtractorparam: role Specifies that this entity type requires cluster nodes with a specific role.Query the statistics about the currently running sharded entities in the entire cluster.Query the sharded daemon process for the current scaleQuery the ShardRegion state for the given entity type key.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.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.The murmur2 message extractor uses the same algorithm as the default kafka partitioner allowing kafka partitions to be mapped to shards.Reply forGetNumberOfProcessesSettings for a specific replica id in replicated sharding Currently only Entity's with ShardingEnvelope are supported but this may change in the futureRepresents the sharding instances for the replicas of one Replicated Event Sourcing entity typeNot for user extension.Extension for running Replicated Event Sourcing in sharding by starting one separate instance of sharding per replica.Commands for interacting with the sharded daemon processContext with details about the Sharded Daemon Process instance to use when starting itNot for user constructions, use factory methods to instantiate.INTERNAL APINot for user extensionINTERNAL APIDefault envelope type that may be used with Cluster Sharding.Entirely customizable typed message extractor.