Modifier and Type | Method and Description |
---|---|
io.simplesource.data.FutureResult<SagaError,SagaResponse> |
KafkaSagaAPI.getSagaResponse(SagaId sagaId,
java.time.Duration timeout) |
io.simplesource.data.FutureResult<SagaError,SagaId> |
KafkaSagaAPI.submitSaga(SagaRequest<A> request) |
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 |
---|---|
List<SagaError> |
SagaAction.error
A list of error may have occurred while processing an action.
|
Modifier and Type | Method and Description |
---|---|
io.simplesource.data.FutureResult<SagaError,SagaResponse> |
SagaAPI.getSagaResponse(SagaId sagaId,
java.time.Duration timeout)
Returns the result of the saga.
|
io.simplesource.data.FutureResult<SagaError,SagaId> |
SagaAPI.submitSaga(SagaRequest<A> request)
Initiates a saga.
|
Modifier and Type | Field and Description |
---|---|
List<SagaError> |
SagaStateTransition.SagaActionStateChanged.actionErrors |
io.simplesource.data.Result<SagaError,io.simplesource.data.Sequence> |
SagaResponse.result
Either and error if the saga failed to execute successfully, or the sequence number, which indicates the number of steps executed in the completed saga.
|
io.simplesource.data.Result<SagaError,Optional<UndoCommand<A>>> |
ActionResponse.result
The result, consisting of a
SagaError if processing fail and indicating success if processing succeeds. |
List<SagaError> |
SagaStateTransition.SagaStatusChanged.sagaErrors |
Modifier and Type | Field and Description |
---|---|
List<SagaError> |
Saga.sagaError
If the saga fails, the cumulative list of errors that occurred in the processing for the saga.
|
Modifier and Type | Method and Description |
---|---|
static SagaError |
SagaError.of(SagaError.Reason reason,
String msg)
|
static SagaError |
SagaError.of(SagaError.Reason reason,
Throwable throwable)
|
Modifier and Type | Method and Description |
---|---|
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,
List<SagaError> sagaError)
Creates a new saga instances with an updated saga status and error list.
|
Copyright © 2019. All rights reserved.