Package org.apache.pekko.cluster.sharding
package org.apache.pekko.cluster.sharding
-
ClassDescriptionThis extension provides sharding functionality of actors in a cluster.INTERNAL API.INTERNAL API (ctr)Internal APIMarker trait for remote messages and persistent events/snapshots with special serializer.param: role specifies that this entity type requires cluster nodes with a specific role.INTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL API Determine the passivation strategy to use from settings.Not for user extensionNot for user extensionNot for user extension
pekko.cluster.sharding.ShardCoordinator.ShardAllocationStrategythat is using consistent hashing.INTERNAL APIINTERNAL APIINTERNALINTERNALSingleton coordinator that decides where to allocate shards.INTERNAL APIUtility program that removes the internal data stored with Pekko Persistence by the ClusterShardCoordinator.INTERNAL APISingleton coordinator that decides where to allocate shards.Java API: Java implementations of custom shard allocation and rebalancing logic used by theShardCoordinatorshould extend this abstract class and implement the two methods.Shard allocation strategy where start is called by the shard coordinator before any calls to rebalance or allocate shard.INTERNAL APIMessages sent to the coordinatorMessages sent from the coordinatorUsepekko.cluster.sharding.ShardCoordinator.ShardAllocationStrategy.leastShardAllocationStrategyinstead.Interface of the pluggable shard allocation and rebalancing logic used by theShardCoordinator.Shard allocation strategy where start is called by the shard coordinator before any calls to rebalance or allocate shard.INTERNAL APIINTERNAL APIThis is public with the purpose to document the used markers and properties of log events.INTERNAL APIThis is public with the purpose to document the used markers and properties of log events.INTERNAL APIINTERNAL API The result of a group query and metadata.INTERNAL API