AbstractWorkRegistry

An implementation base for ShardedWorkRegistries based on a specific persistence mechanism.

Constructors

protected abstract Iterator<ShardSessionRecord> allRecords()

Obtains all the session records associated with this registry.

protected void clearNode(ShardSessionRecord session)

Clears the value of ShardSessionRecord.worker and stores the session.

protected abstract WorkerId currentWorkerFor(NodeId node)

Returns an identifier of the current worker that is now going to process the shard.

protected abstract Optional<ShardSessionRecord> find(ShardIndex index)

Looks for the session record by the given shard index.

public PickUpOutcome pickUp(ShardIndex index, NodeId node)

Picks up the shard at a given index to process.

public Iterable<ShardIndex> releaseExpiredSessions(Duration inactivityPeriod)

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

protected abstract void write(ShardSessionRecord session)

Stores the given session.

public abstract void release(ShardSessionRecord session)

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