InMemoryShardedWorkRegistry

An in-memory implementation of ShardedWorkRegistry.

Constructors

protected Iterator<ShardSessionRecord> allRecords()

Obtains all the session records associated with this registry.

protected synchronized void clearNode(ShardSessionRecord session)

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

protected WorkerId currentWorkerFor(NodeId node)

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

protected Optional<ShardSessionRecord> find(ShardIndex index)

Looks for the session record by the given shard index.

public synchronized PickUpOutcome pickUp(ShardIndex index, NodeId nodeId)

Picks up the shard at a given index to process.

public void release(ShardSessionRecord session)

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

public synchronized 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 void write(ShardSessionRecord session)

Stores the given session.