Class InMemoryStores

java.lang.Object

com.iantapply.orchestra.adapter.memory.InMemoryStores

All Implemented Interfaces:

DefinitionRepository, DistributedLock, ExecutionRepository

public final class InMemoryStores
extends Object
implements DefinitionRepository, ExecutionRepository, DistributedLock

Thread-safe in-memory implementation of the core stores and lease provider. Intended for tests, development, and single-process installations.

Nested Class Summary

Nested classes/interfaces inherited from interface DistributedLock

DistributedLock.Lease

Constructor Summary

Constructors

Constructor	Description
InMemoryStores()	Creates empty in-memory definition, execution, and lease stores.

Method Summary

Modifier and Type	Method	Description
boolean	compareAndSet(long expectedVersion, EventExecution replacement)	Replaces an execution only if its current version equals the expected version.
void	create(EventExecution execution)	Persists a new execution.
Optional<EventDefinition>	find(String id)	Finds one definition.
Optional<EventExecution>	find(UUID id)	Finds one execution.
Collection<EventExecution>	findActive(int limit)	Finds execution state eligible for startup recovery.
Collection<EventDefinition>	findAll()	Lists known definitions.
Collection<EventExecution>	findDue(Instant now, int limit)	Finds runnable work due on or before a time.
void	save(EventDefinition definition)	Inserts or replaces a definition.
Optional<DistributedLock.Lease>	tryAcquire(String key, Duration duration)	Attempts to claim a key for a bounded duration without waiting.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InMemoryStores

public InMemoryStores()

Creates empty in-memory definition, execution, and lease stores.

Method Details

save

public void save(EventDefinition definition)

Description copied from interface: DefinitionRepository

Inserts or replaces a definition.

Specified by:

save in interface DefinitionRepository

Parameters:

definition - definition to insert or replace by identifier

find

public Optional<EventDefinition> find(String id)

Description copied from interface: DefinitionRepository

Finds one definition.

Specified by:

find in interface DefinitionRepository

Parameters:

id - event identifier

Returns:

matching definition, if present

findAll

public Collection<EventDefinition> findAll()

Description copied from interface: DefinitionRepository

Lists known definitions.

Specified by:

findAll in interface DefinitionRepository

Returns:

snapshot of all known definitions

create

public void create(EventExecution execution)

Description copied from interface: ExecutionRepository

Persists a new execution.

Specified by:

create in interface ExecutionRepository

Parameters:

execution - new execution to persist

find

public Optional<EventExecution> find(UUID id)

Description copied from interface: ExecutionRepository

Finds one execution.

Specified by:

find in interface ExecutionRepository

Parameters:

id - execution identifier

Returns:

matching execution, if present

findDue

public Collection<EventExecution> findDue(Instant now,
 int limit)

Description copied from interface: ExecutionRepository

Finds runnable work due on or before a time.

Specified by:

findDue in interface ExecutionRepository

Parameters:

now - inclusive due-time boundary

limit - maximum results

Returns:

runnable executions ordered by due time when supported

findActive

public Collection<EventExecution> findActive(int limit)

Description copied from interface: ExecutionRepository

Finds execution state eligible for startup recovery.

Specified by:

findActive in interface ExecutionRepository

Parameters:

limit - maximum results

Returns:

executions eligible for startup recovery

compareAndSet

public boolean compareAndSet(long expectedVersion,
 EventExecution replacement)

Description copied from interface: ExecutionRepository

Replaces an execution only if its current version equals the expected version.

Specified by:

compareAndSet in interface ExecutionRepository

Parameters:

expectedVersion - version observed by the caller

replacement - complete replacement value

Returns:

whether the replacement was persisted

tryAcquire

public Optional<DistributedLock.Lease> tryAcquire(String key,
 Duration duration)

Description copied from interface: DistributedLock

Attempts to claim a key for a bounded duration without waiting.

Specified by:

tryAcquire in interface DistributedLock

Parameters:

key - globally meaningful lock key

duration - lease lifetime

Returns:

owned lease, or empty when another node owns the key