ShardedWorkRegistry

The registry of the shard indexes along with the identifiers of the nodes, which process the messages corresponding to each index.

Functions

public abstract PickUpOutcome pickUp(ShardIndex index, NodeId node)

Picks up the shard at a given index to process.

public abstract void release(ShardSessionRecord session)

Completes the given session and releases the picked up shard, making it available for picking up.

public abstract Iterable<ShardIndex> releaseExpiredSessions(Duration inactivityPeriod)

Clears up the recorded NodeIds from the session records if there was no activity for longer than passed inactivityPeriod.