Package org.apache.pekko.cluster.sharding

Interface ShardCoordinator.StartableAllocationStrategy

All Superinterfaces:
NoSerializationVerificationNeeded, ShardCoordinator.ShardAllocationStrategy
All Known Implementing Classes:
ExternalShardAllocationStrategy
Enclosing class:
ShardCoordinator
public static interface ShardCoordinator.StartableAllocationStrategy extends ShardCoordinator.ShardAllocationStrategy
Shard allocation strategy where start is called by the shard coordinator before any calls to rebalance or allocate shard. This can be used if there is any expensive initialization to be done that you do not want to to in the constructor as it will happen on every node rather than just the node that hosts the ShardCoordinator

  • Method Details

    • start

      void start()
      Called before any calls to allocate/rebalance. Do not block. If asynchronous actions are required they can be started here and delay the Futures returned by allocate/rebalance.