Package | Description |
---|---|
io.simplesource.saga.client.dsl | |
io.simplesource.saga.model.messages | |
io.simplesource.saga.model.saga | |
io.simplesource.saga.model.serdes |
Modifier and Type | Method and Description |
---|---|
io.simplesource.data.Result<SagaError,Saga<A>> |
SagaDSL.SagaBuilder.build()
builds the Saga from all the subsagas that were previously defined by creating single actions with
addAction and by defining the dependencies between these actions. |
Modifier and Type | Field and Description |
---|---|
Saga<A> |
SagaRequest.initialState
The initial state of the saga.
|
Saga<A> |
SagaStateTransition.SetInitialState.sagaState |
Modifier and Type | Method and Description |
---|---|
static <A> Saga<A> |
Saga.of(Map<ActionId,SagaAction<A>> actions) |
static <A> Saga<A> |
Saga.of(SagaId sagaId,
Map<ActionId,SagaAction<A>> actions,
SagaStatus status,
io.simplesource.data.Sequence sequence)
Static constructor for a Saga.
|
Saga<A> |
Saga.updated(Map<ActionId,SagaAction<A>> actions,
SagaStatus status)
Creates a new saga instances with an updated set of actions and saga status.
|
Saga<A> |
Saga.updated(Map<ActionId,SagaAction<A>> actions,
SagaStatus status,
List<SagaError> sagaError)
Creates a new saga instances with an updated set of actions, saga status and error list.
|
Saga<A> |
Saga.updated(SagaStatus status)
Creates a new saga instances with an updated saga status.
|
Saga<A> |
Saga.updated(SagaStatus status,
List<SagaError> sagaError)
Creates a new saga instances with an updated saga status and error list.
|
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<Saga<A>> |
SagaSerdes.state()
Serde for the saga state.
|
Copyright © 2019. All rights reserved.