shared-infrastructure/com.vertyll.veds.sharedinfrastructure.saga.contract/SagaRepositoryPort

SagaRepositoryPort

interface SagaRepositoryPort<S : Saga<S>>(source)

Persistence-agnostic repository port for saga aggregates.

Concrete adapters (JPA, MongoDB, …) implement this interface; the saga engine has no awareness of the underlying storage technology.

Inheritors

BaseSagaRepository

Functions

findByStartedAtBefore

abstract fun findByStartedAtBefore(startedAt: Instant): List<S>

Returns sagas whose Saga.startedAt is strictly before startedAt.

findByStatus

abstract fun findByStatus(status: SagaStatus): List<S>

Returns all sagas currently in the given SagaStatus.

findByStatusInAndStartedAtBefore

abstract fun findByStatusInAndStartedAtBefore(statuses: List<SagaStatus>, startedAt: Instant): List<S>

Returns sagas in any of statuses whose Saga.startedAt is strictly before startedAt.

findByStatusInAndUpdatedAtBefore

abstract fun findByStatusInAndUpdatedAtBefore(statuses: List<SagaStatus>, updatedAt: Instant): List<S>

Finds sagas whose Saga.status is in statuses and whose Saga.updatedAt is strictly before updatedAt. Used by the saga watchdog to detect AWAITING_RESPONSE timeouts and to schedule compensation retries with a cooldown.

findByType

abstract fun findByType(type: String): List<S>

Returns all sagas of the given Saga.type.

findByTypeAndStatus

abstract fun findByTypeAndStatus(type: String, status: SagaStatus): List<S>

Returns sagas matching both type and status.

findOneById

abstract fun findOneById(id: String): S?

Looks up a saga by its Saga.id; null if absent.

save

abstract fun save(saga: S): S

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