Package org.apache.pekko.cluster.sharding.typed
package org.apache.pekko.cluster.sharding.typed
-
ClassDescriptionProtocol 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.API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.Query the statistics about the currently running sharded entities in the entire cluster.Query 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.Settings 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.Not 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.