shared-infrastructure/com.vertyll.veds.sharedinfrastructure.saga.repository/BaseSagaRepository

BaseSagaRepository

@NoRepositoryBean

interface BaseSagaRepository<T : BaseSaga<T>> : JpaRepository<T, String> , SagaRepositoryPort<T> (source)

JPA flavor of SagaRepositoryPort. Concrete service repositories extend this interface, and Spring Data JPA generates implementations that simultaneously satisfy the persistence-agnostic port.

Adding a new persistence flavor (e.g. MongoDB) only requires implementing SagaRepositoryPort directly with the target technology — the saga engine is unchanged.

Functions

count

abstract fun count(): Long

abstract fun <S : T?> count(example: Example<S?>?): Long

delete

abstract fun delete(entity: T?)

deleteAll

abstract fun deleteAll()

abstract fun deleteAll(entities: Iterable<out T?>?)

deleteAllById

abstract fun deleteAllById(ids: Iterable<out String?>?)

deleteAllByIdInBatch

abstract fun deleteAllByIdInBatch(ids: Iterable<String?>?)

deleteAllInBatch

abstract fun deleteAllInBatch()

abstract fun deleteAllInBatch(entities: Iterable<T?>?)

deleteById

abstract fun deleteById(id: String?)

deleteInBatch

open fun ~~deleteInBatch~~(entities: Iterable<T?>?)

exists

abstract fun <S : T?> exists(example: Example<S?>?): Boolean

existsById

abstract fun existsById(id: String?): Boolean

findAll

abstract fun findAll(): List<T?>?

abstract fun findAll(pageable: Pageable?): Page<T?>?

abstract fun findAll(sort: Sort?): List<T?>?

abstract fun <S : T?> findAll(example: Example<S?>?): List<S?>?

abstract fun <S : T?> findAll(example: Example<S?>?, pageable: Pageable?): Page<S?>?

abstract fun <S : T?> findAll(example: Example<S?>?, sort: Sort?): List<S?>?

findAllById

abstract fun findAllById(ids: Iterable<String?>?): List<T?>?

findBy

abstract fun <S : T?, R> findBy(example: Example<S?>?, queryFunction: Function<FluentQuery.FetchableFluentQuery<S?>?, R?>?): R?

findById

abstract fun findById(id: String?): Optional<T?>?

findByStartedAtBefore

abstract override fun findByStartedAtBefore(startedAt: Instant): List<T>

Returns sagas whose Saga.startedAt is strictly before startedAt.

findByStatus

abstract override fun findByStatus(status: SagaStatus): List<T>

Returns all sagas currently in the given SagaStatus.

findByStatusInAndStartedAtBefore

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

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

findByStatusInAndUpdatedAtBefore

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

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.