shared-infrastructure/com.vertyll.veds.sharedinfrastructure.saga.service

Package-level declarations

Types

fun interface CompensationCommandDeserializer<TCommand : Any>

Service-provided deserializer for compensation events consumed from the internal saga-compensation-<participant> topic.

CompensationCommandHandler

fun interface CompensationCommandHandler<TCommand : Any>

Domain-specific compensation dispatcher used by SagaCompensationEngine.

CompensationEventSerializer

fun interface CompensationEventSerializer<TCommand : Any>

Service-provided serializer for compensation events that flow on each microservice's internal saga-compensation-<participant> topic.

DecodedCompensationEvent

data class DecodedCompensationEvent<TCommand : Any>(val sagaId: String, val stepId: Long?, val command: TCommand)

Strongly-typed envelope produced by CompensationCommandDeserializer.

DefaultSagaCompensationContext

class DefaultSagaCompensationContext<TCommand : Any>(kafkaOutboxProcessor: KafkaOutboxProcessor, compensationEventSerializer: CompensationEventSerializer<TCommand>, compensationTopic: String, objectMapper: ObjectMapper) : SagaCompensationContext<TCommand>

Default SagaCompensationContext implementation shared by SagaEngine and SagaCompensationRunner.

SagaCompensationContext

interface SagaCompensationContext<TCommand : Any>

Callback surface that SagaCompensator uses to interact with the saga engine while staying decoupled from it. Hides Kafka outbox and JSON serialization details behind a small, intention-revealing API.

SagaCompensationEngine

open class SagaCompensationEngine<T : SagaStep<T>, TCommand : Any>(sagaStepRepository: SagaStepRepositoryPort<T>, commandDeserializer: CompensationCommandDeserializer<TCommand>, stepFactory: SagaCompensationStepFactory<T>, handler: CompensationCommandHandler<TCommand>)

Engine for the choreography saga compensation flow.

SagaCompensationRunner

open class SagaCompensationRunner<S : Saga<S>, T : SagaStep<T>, TCommand : Any>(sagaRepository: SagaRepositoryPort<S>, sagaStepRepository: SagaStepRepositoryPort<T>, compensator: SagaCompensator<S, T, TCommand>, compensationContext: SagaCompensationContext<TCommand>) : SagaCompensationTrigger

Transactional helper for SagaEngine that runs the compensation sequence in its own fresh transaction.

SagaCompensationStepFactory

interface SagaCompensationStepFactory<T : SagaStep<T>>

Factory hook used by SagaCompensationEngine to create a service-specific compensation step instance against the persistence-agnostic SagaStep contract.

SagaCompensationTrigger

fun interface SagaCompensationTrigger

Non-generic trigger used by SagaEngine to delegate compensation to a proxied bean that opens a fresh REQUIRES_NEW transaction.

SagaCompensator

interface SagaCompensator<S : Saga<S>, T : SagaStep<T>, TCommand : Any>

Domain-specific compensation hook used by SagaEngine.

SagaEngine

open class SagaEngine<S : Saga<S>, T : SagaStep<T>>(sagaRepository: SagaRepositoryPort<S>, sagaStepRepository: SagaStepRepositoryPort<T>, objectMapper: ObjectMapper, entityFactory: SagaEntityFactory<S, T>, compensationRunner: SagaCompensationTrigger)

Reusable saga participant engine for the choreography pattern.

SagaEntityFactory

interface SagaEntityFactory<S : Saga<S>, T : SagaStep<T>>

Hook used by SagaEngine to instantiate concrete saga/saga-step instances for the owning microservice.

SagaWatchdog

open class SagaWatchdog<S : Saga<S>, T : SagaStep<T>>(sagaRepository: SagaRepositoryPort<S>, sagaEngine: SagaEngine<S, T>, properties: SagaProperties)

Per-service watchdog that: