SagaStepRepositoryPort

Persistence-agnostic repository port for saga step records.

Concrete adapters (JPA, MongoDB, …) implement this interface.

Functions

abstract fun findByCompensationStepId(compensationStepId: Long): T?

Returns the compensation step that reverted the original step with id compensationStepId; null if not yet compensated.

abstract fun findBySagaId(sagaId: String): List<T>

Returns every step recorded for the given saga, in insertion order.

Returns the steps for sagaId currently in the given status.

Returns the steps for sagaId whose SagaStep.stepName equals stepName (typically zero or one).

Returns steps with the given stepName in the given status across all sagas.

abstract fun findOneById(id: Long): T?

Looks up a step by its surrogate id; null if absent.

abstract fun save(step: T): T

Persists step (insert or update) and returns the stored instance.