io.simplesource.saga.model.specs

Class SagaSpec<A>

java.lang.Object

io.simplesource.saga.model.specs.SagaSpec<A>

Type Parameters:

A - a representation of an action command that is shared across all actions in the saga. This is typically a generic type, such as Json, or if using Avro serialization, SpecificRecord or GenericRecord

public class SagaSpec<A>
extends Object

Represents the details required to create a saga coordinator

Field Summary

Fields

Modifier and Type	Field and Description
io.simplesource.kafka.spec.WindowSpec	responseWindow Represents the response window for the Saga API.
SagaSerdes<A>	serdes The serdes required for all the saga coordinator topics (request and response as well as state and state transition topics).

Constructor Summary

Constructors

Constructor and Description
SagaSpec()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

serdes

public final SagaSerdes<A> serdes

The serdes required for all the saga coordinator topics (request and response as well as state and state transition topics).

responseWindow

public final io.simplesource.kafka.spec.WindowSpec responseWindow

Represents the response window for the Saga API. This defines how long the saga API should be able to access the results of any saga in execution or previously completed saga.

See Also:

SagaAPI

Constructor Detail

SagaSpec

public SagaSpec()