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.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.INTERNAL APIINTERNAL APIINTERNALINTERNALSingleton coordinator that decides where to allocate shards.INTERNAL APIUtility program that removes the internal data stored with Pekko Persistence by the Cluster
ShardCoordinator.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