Modifier and Type | Method and Description |
---|---|
io.simplesource.data.FutureResult<SagaError,SagaId> |
KafkaSagaAPI.submitSaga(SagaRequest<A> request) |
Modifier and Type | Method and Description |
---|---|
io.simplesource.data.FutureResult<SagaError,SagaResponse> |
KafkaSagaAPI.getSagaResponse(SagaId sagaId,
java.time.Duration timeout) |
Modifier and Type | Method and Description |
---|---|
io.simplesource.data.FutureResult<SagaError,SagaId> |
SagaAPI.submitSaga(SagaRequest<A> request)
Initiates a saga.
|
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.
|
Modifier and Type | Field and Description |
---|---|
SagaId |
SagaResponse.sagaId
The saga id uniquely identifies the saga, and is used as the key for the saga request and responses.
|
SagaId |
ActionResponse.sagaId
The saga id uniquely identifies the saga, and is used as the key for the action request and responses.
|
SagaId |
SagaStateTransition.SagaActionStateChanged.sagaId |
SagaId |
SagaStateTransition.SagaStatusChanged.sagaId |
SagaId |
ActionRequest.sagaId
The saga id uniquely identifies the saga, and is used as the key for the action request and responses.
|
SagaId |
SagaRequest.sagaId
The saga id uniquely identifies the saga, and is used as the key for the saga request and responses.
|
Modifier and Type | Field and Description |
---|---|
SagaId |
Saga.sagaId
The Saga id uniquely identifies the saga.
|
Modifier and Type | Method and Description |
---|---|
static SagaId |
SagaId.fromString(String uuidString)
Converts a saga from its string representation (as a UUID string) to a saga id.
|
static SagaId |
SagaId.random()
Generates a randon saga ID.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<SagaId> |
ActionSerdes.sagaId()
Serde for the saga id.
|
org.apache.kafka.common.serialization.Serde<SagaId> |
SagaClientSerdes.sagaId()
Serde for the saga id.
|
Modifier and Type | Method and Description |
---|---|
void |
RetryPublisher.send(String topic,
SagaId key,
SagaStateTransition<A> value) |
Copyright © 2019. All rights reserved.