Package | Description |
---|---|
io.simplesource.saga.client.dsl | |
io.simplesource.saga.model.action | |
io.simplesource.saga.model.messages | |
io.simplesource.saga.model.saga | |
io.simplesource.saga.model.serdes |
Modifier and Type | Method and Description |
---|---|
SagaDSL.SubSaga<A> |
SagaDSL.SagaBuilder.addAction(ActionId actionId,
String actionType,
A actionCommand)
Adds an action with no undo action command, creating a sub saga with a single action.
|
SagaDSL.SubSaga<A> |
SagaDSL.SagaBuilder.addAction(ActionId actionId,
String actionType,
A actionCommand,
A undoActionCommand)
Adds an action with an undo action command, creating a sub saga with a single action.
|
Modifier and Type | Field and Description |
---|---|
ActionId |
SagaAction.actionId
The Action id uniquely identifies the action within the Saga dependency graph.
|
Modifier and Type | Field and Description |
---|---|
Set<ActionId> |
SagaAction.dependencies
The set dependencies of an action (i.e.
|
Modifier and Type | Method and Description |
---|---|
static ActionId |
ActionId.fromString(String uuidString)
Converts an action id from its string representation as a UUID string.
|
static ActionId |
ActionId.random()
Returns an random
ActionId |
Modifier and Type | Field and Description |
---|---|
ActionId |
ActionResponse.actionId
The action id uniquely identifies an action in the saga dependency graph.
|
ActionId |
SagaStateTransition.SagaActionStateChanged.actionId |
ActionId |
ActionRequest.actionId
The action id uniquely identifies an action in the saga dependency graph.
|
Modifier and Type | Field and Description |
---|---|
Map<ActionId,SagaAction<A>> |
Saga.actions
Actions are stored in a map by
ActionId . |
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.
|
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<ActionId> |
ActionSerdes.actionId()
Serde for the action id.
|
Copyright © 2019. All rights reserved.