Class PostgresExecutionRepository

java.lang.Object

com.iantapply.orchestra.adapter.postgres.PostgresExecutionRepository

All Implemented Interfaces:

ExecutionRepository

public final class PostgresExecutionRepository
extends Object
implements ExecutionRepository

PostgreSQL execution repository with atomic version-checked updates.

Constructor Summary

Constructors

Constructor	Description
PostgresExecutionRepository(DataSource dataSource)	Creates an execution repository.

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<EventExecution>	find(UUID id)	Finds one execution.
Collection<EventExecution>	findActive(int limit)	Finds execution state eligible for startup recovery.
Collection<EventExecution>	findDue(Instant now, int limit)	Finds runnable work due on or before a time.

Methods inherited from class Object

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

Constructor Details

PostgresExecutionRepository

public PostgresExecutionRepository(DataSource dataSource)

Creates an execution repository.

Parameters:

dataSource - database connection pool

Method Details

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