Skip navigation links
A B C D E F G H I K N O P R S T U V W 

A

ACTION_OUTPUT - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.ActionTopic
 
ACTION_REQUEST - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.ActionTopic
 
ACTION_REQUEST_UNPROCESSED - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.ActionTopic
 
ACTION_RESPONSE - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.ActionTopic
 
ActionApp<A> - Class in io.simplesource.saga.action.app
An ActionApp is the main component in an KStream action processor application.
ActionAppContext<A> - Class in io.simplesource.saga.action.app
An ActionAppContext represents the context with all the details required to set up an action processor stream.
ActionAppContext() - Constructor for class io.simplesource.saga.action.app.ActionAppContext
 
ActionCommand<A> - Class in io.simplesource.saga.model.action
An ActionCommand is a data class with the information needed: to uniquely identify the execution of the action and know whether it has been processed or not. to determine which action processor to use to process an action. by the action processor to process the action.
ActionCommand() - Constructor for class io.simplesource.saga.model.action.ActionCommand
 
actionCommand - Variable in class io.simplesource.saga.model.messages.ActionRequest
The Action command specifies the details of the command required for processing by the action processor.
actionErrors - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 
ActionId - Class in io.simplesource.saga.model.action
An ActionId uniquely identifies an action in the saga dependency graph.
ActionId() - Constructor for class io.simplesource.saga.model.action.ActionId
 
actionId - Variable in class io.simplesource.saga.model.action.SagaAction
The Action id uniquely identifies the action within the Saga dependency graph.
actionId - Variable in class io.simplesource.saga.model.messages.ActionRequest
The action id uniquely identifies an action in the saga dependency graph.
actionId - Variable in class io.simplesource.saga.model.messages.ActionResponse
The action id uniquely identifies an action in the saga dependency graph.
actionId - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 
actionId() - Method in interface io.simplesource.saga.model.serdes.ActionSerdes
Serde for the action id.
ActionProcessorBuildStep<A> - Interface in io.simplesource.saga.action.app
Represents a step in the process of building an action processor app.
ActionRequest<A> - Class in io.simplesource.saga.model.messages
An action request, published by the saga coordinator in the action request topic.
ActionRequest() - Constructor for class io.simplesource.saga.model.messages.ActionRequest
 
ActionResponse<A> - Class in io.simplesource.saga.model.messages
An action response, published by the action processor that receive the corresponding ActionResponse in the action response topic.
ActionResponse() - Constructor for class io.simplesource.saga.model.messages.ActionResponse
 
actions - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.TransitionList
 
actions - Variable in class io.simplesource.saga.model.saga.Saga
Actions are stored in a map by ActionId.
ActionSerdes<A> - Interface in io.simplesource.saga.model.serdes
The serdes required to serialize and deserialize the action request and response topics.
actionSerdes(Serde<A>, String, boolean) - Static method in class io.simplesource.saga.serialization.avro.AvroSerdes
Create action serdes (serdes required for serializing to and from action request and response topics)
actionSerdes(String, boolean) - Static method in interface io.simplesource.saga.serialization.avro.AvroSerdes.Generic
Create action serdes (serdes required for serializing to and from action request and response topics)
actionSerdes(String) - Static method in interface io.simplesource.saga.serialization.avro.AvroSerdes.Specific
 
actionSerdes(String, boolean) - Static method in interface io.simplesource.saga.serialization.avro.AvroSerdes.Specific
Create action serdes (serdes required for serializing to and from action request and response topics)
actionSpec - Variable in class io.simplesource.saga.action.app.ActionAppContext
 
actionSpec - Variable in class io.simplesource.saga.action.async.AsyncContext
 
actionSpec - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 
ActionSpec<A> - Class in io.simplesource.saga.model.specs
Represents the details common to all action processors
ActionSpec() - Constructor for class io.simplesource.saga.model.specs.ActionSpec
 
ActionStatus - Enum in io.simplesource.saga.model.action
An enum representing the current state of an action within a saga
actionStatus - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 
ActionTopic() - Constructor for class io.simplesource.saga.shared.topics.TopicTypes.ActionTopic
 
actionTopicBaseName(String) - Static method in class io.simplesource.saga.shared.topics.TopicUtils
 
actionTopicNamer - Variable in class io.simplesource.saga.action.async.AsyncContext
 
actionTopicNamer - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 
actionType - Variable in class io.simplesource.saga.action.async.AsyncSpec
Each action processor must have a unique action type associated with it.
actionType - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Action type.
actionType - Variable in class io.simplesource.saga.action.http.HttpSpec
 
actionType - Variable in class io.simplesource.saga.model.action.ActionCommand
Every action processor has an associated action type.
actionType - Variable in class io.simplesource.saga.model.action.UndoCommand
The Action type for the undo command.
addAction(String, A) - Method in class io.simplesource.saga.client.dsl.SagaDSL.SagaBuilder
Adds an action with a random Id and no undo action command, creating a sub saga with a single action.
addAction(String, A, A) - Method in class io.simplesource.saga.client.dsl.SagaDSL.SagaBuilder
Adds an action with a random Id and an undo action command, creating a sub saga with a single action.
addAction(ActionId, String, A) - Method in class io.simplesource.saga.client.dsl.SagaDSL.SagaBuilder
Adds an action with no undo action command, creating a sub saga with a single action.
addAction(ActionId, String, A, A) - Method in class io.simplesource.saga.client.dsl.SagaDSL.SagaBuilder
Adds an action with an undo action command, creating a sub saga with a single action.
addShutdownHook(StreamAppUtils.ShutdownHandler) - Static method in class io.simplesource.saga.shared.app.StreamAppUtils
 
aggregateName - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Simple Sourcing aggregate name.
all - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.ActionTopic
 
all - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.CommandTopic
 
all - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
allTopics() - Method in class io.simplesource.saga.shared.topics.TopicConfig
Builds a list of topic creations, which contains both the topic namer and the topic spec
allTopics(TopicConfig) - Static method in class io.simplesource.saga.shared.topics.TopicCreation
Creates a list of topic creation items from a topic config, resolving topic names and topic specs
andThen(SagaDSL.SubSaga<A>) - Method in class io.simplesource.saga.client.dsl.SagaDSL.SubSaga
Defines a dependency between two saga actions (or two sub-sagas).
appInput - Variable in class io.simplesource.saga.shared.app.StreamBuildContext
 
apply(AsyncSpec<A, D, K, O, R>, TopicConfigBuilder.BuildSteps, ScheduledExecutorService) - Static method in class io.simplesource.saga.action.async.AsyncBuilder
 
apply(AsyncSpec<A, D, K, O, R>, TopicConfigBuilder.BuildSteps) - Static method in class io.simplesource.saga.action.async.AsyncBuilder
 
apply(AsyncSpec<A, D, K, O, R>) - Static method in class io.simplesource.saga.action.async.AsyncBuilder
 
apply(AsyncSpec<A, D, K, O, R>, ScheduledExecutorService) - Static method in class io.simplesource.saga.action.async.AsyncBuilder
 
apply(D, O) - Method in interface io.simplesource.saga.action.async.AsyncSpec.UndoFunction
 
apply(EventSourcingSpec<A, D, K, C>, TopicConfigBuilder.BuildSteps, TopicConfigBuilder.BuildSteps) - Static method in class io.simplesource.saga.action.eventsourcing.EventSourcingBuilder
A static function that returns an action processor build step that: 1.
apply(EventSourcingSpec<A, D, K, C>) - Static method in class io.simplesource.saga.action.eventsourcing.EventSourcingBuilder
 
apply(K, C) - Method in interface io.simplesource.saga.action.eventsourcing.EventSourcingSpec.UndoFunction
The UndoFunction is a mechanism to take the result of the async invocation and turning it into an undo action command.
apply(HttpSpec<A, K, B, O, R>, TopicConfigBuilder.BuildSteps, ScheduledExecutorService) - Static method in class io.simplesource.saga.action.http.HttpBuilder
A static function that delegates the AsyncBuilder to provide an implementation of an action processor that can process http web service calls asynchronously as part of a saga.
apply(HttpSpec<A, D, K, O, R>, TopicConfigBuilder.BuildSteps) - Static method in class io.simplesource.saga.action.http.HttpBuilder
 
apply(HttpSpec<A, D, K, O, R>) - Static method in class io.simplesource.saga.action.http.HttpBuilder
 
apply(HttpSpec<A, D, K, O, R>, ScheduledExecutorService) - Static method in class io.simplesource.saga.action.http.HttpBuilder
 
apply(HttpRequest<K, B>, O) - Method in interface io.simplesource.saga.action.http.HttpSpec.UndoFunction
The UndoFunction is a mechanism to take the result of the async http invocation and turning it into an undo action command.
apply(String) - Method in interface io.simplesource.saga.shared.topics.TopicNamer
Create a full topic name for a topic type
applyStep(ActionAppContext<A>) - Method in interface io.simplesource.saga.action.app.ActionProcessorBuildStep
 
applyStep(StreamBuildContext<I>) - Method in interface io.simplesource.saga.shared.app.StreamBuildStep
 
applyStep(PropertiesBuilder) - Method in interface io.simplesource.saga.shared.properties.PropertiesBuilder.BuildSteps
 
applyStep(TopicConfigBuilder) - Method in interface io.simplesource.saga.shared.topics.TopicConfigBuilder.BuildSteps
 
aSerdes() - Method in class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 
AsyncBuilder - Class in io.simplesource.saga.action.async
A class with a single static function that returns an action processor build step for an async action.
AsyncBuilder() - Constructor for class io.simplesource.saga.action.async.AsyncBuilder
 
AsyncContext<A,D,K,O,R> - Class in io.simplesource.saga.action.async
 
AsyncContext() - Constructor for class io.simplesource.saga.action.async.AsyncContext
 
asyncFunction - Variable in class io.simplesource.saga.action.async.AsyncSpec
This is a BiConsumer that takes the decoded input type and a Callback as input.
asyncHttpFunction - Variable in class io.simplesource.saga.action.http.HttpSpec
 
AsyncResult<D,K,O,R> - Class in io.simplesource.saga.action.async
Represents the information required to consume the output returned by an async action, convert it to the result type R, and save it to an output topic.
AsyncResult() - Constructor for class io.simplesource.saga.action.async.AsyncResult
 
asyncSpec - Variable in class io.simplesource.saga.action.async.AsyncContext
 
AsyncSpec<A,D,K,O,R> - Class in io.simplesource.saga.action.async
A value class with the information required to define an async action processor.
AsyncSpec() - Constructor for class io.simplesource.saga.action.async.AsyncSpec
 
AsyncSpec.UndoFunction<A,D,O> - Interface in io.simplesource.saga.action.async
The UndoFunction is a mechanism to take the result of the async invocation and turn it into an undo action command.
AvroSerdes - Class in io.simplesource.saga.serialization.avro
Factory methods for Avro Serdes.
AvroSerdes() - Constructor for class io.simplesource.saga.serialization.avro.AvroSerdes
 
AvroSerdes.Generic - Interface in io.simplesource.saga.serialization.avro
Factory methods which can be used where A is a subclass of GenericRecord.
AvroSerdes.Specific - Interface in io.simplesource.saga.serialization.avro
Factory methods which can be used where A is a subclass of SpecificRecord.

B

body - Variable in class io.simplesource.saga.action.http.HttpRequest
 
build(PropertiesBuilder.BuildSteps) - Method in class io.simplesource.saga.action.app.ActionApp
Builds the stream.
build() - Method in class io.simplesource.saga.client.api.SagaClientBuilder
Builds the saga API.
build() - Method in class io.simplesource.saga.client.dsl.SagaDSL.SagaBuilder
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.
build(PropertiesBuilder.BuildSteps) - Method in class io.simplesource.saga.shared.app.StreamApp
 
build(PropertiesBuilder.Target) - Method in interface io.simplesource.saga.shared.properties.PropertiesBuilder.BuildSteps
 
build(List<String>) - Method in interface io.simplesource.saga.shared.topics.TopicConfigBuilder.BuildSteps
 
build(List<String>, Map<String, String>, Map<String, Map<String, String>>) - Method in interface io.simplesource.saga.shared.topics.TopicConfigBuilder.BuildSteps
 

C

Callback<O> - Interface in io.simplesource.saga.action.async
A callback function that is called by the asynchronous function to indicate that processing is complete, and to pass the result back to the async action processor.
cata(Function<SagaStateTransition.SetInitialState<A>, B>, Function<SagaStateTransition.SagaActionStateChanged<A>, B>, Function<SagaStateTransition.SagaStatusChanged<A>, B>, Function<SagaStateTransition.TransitionList<A>, B>) - Method in interface io.simplesource.saga.model.messages.SagaStateTransition
Catamorphism over SagaStateTransition
cata(Function<SagaStateTransition.SetInitialState<A>, B>, Function<SagaStateTransition.SagaActionStateChanged<A>, B>, Function<SagaStateTransition.SagaStatusChanged<A>, B>, Function<SagaStateTransition.TransitionList<A>, B>) - Method in class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 
cata(Function<SagaStateTransition.SetInitialState<A>, B>, Function<SagaStateTransition.SagaActionStateChanged<A>, B>, Function<SagaStateTransition.SagaStatusChanged<A>, B>, Function<SagaStateTransition.TransitionList<A>, B>) - Method in class io.simplesource.saga.model.messages.SagaStateTransition.SagaStatusChanged
 
cata(Function<SagaStateTransition.SetInitialState<A>, B>, Function<SagaStateTransition.SagaActionStateChanged<A>, B>, Function<SagaStateTransition.SagaStatusChanged<A>, B>, Function<SagaStateTransition.TransitionList<A>, B>) - Method in class io.simplesource.saga.model.messages.SagaStateTransition.SetInitialState
 
cata(Function<SagaStateTransition.SetInitialState<A>, B>, Function<SagaStateTransition.SagaActionStateChanged<A>, B>, Function<SagaStateTransition.SagaStatusChanged<A>, B>, Function<SagaStateTransition.TransitionList<A>, B>) - Method in class io.simplesource.saga.model.messages.SagaStateTransition.TransitionList
 
client - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
command - Variable in class io.simplesource.saga.model.action.ActionCommand
An action command, expressed in a generic type A, that the action processor is able to decode.
command - Variable in class io.simplesource.saga.model.action.SagaAction
The action command for regular processing of the action.
command - Variable in class io.simplesource.saga.model.action.UndoCommand
An action command, expressed in a generic type A, that the action processor is able to decode.
COMMAND_REQUEST - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.CommandTopic
 
COMMAND_RESPONSE - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.CommandTopic
 
commandId - Variable in class io.simplesource.saga.model.action.ActionCommand
The command Id is the unique identifier for an action command.
commandId - Variable in class io.simplesource.saga.model.messages.ActionResponse
The command id is the unique identifier for an action command execution.
commandId() - Method in interface io.simplesource.saga.model.serdes.ActionSerdes
Serde for the command id.
commandMapper - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Command mapper maps the decoded input type to a Simple Sourcing command.
commandSerdes - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Command serdes are required for the command request and response topics.
CommandTopic() - Constructor for class io.simplesource.saga.shared.topics.TopicTypes.CommandTopic
 
commandTopicNamer - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 
complete(Result<Throwable, O>) - Method in interface io.simplesource.saga.action.async.Callback
A function that is called during the async invocation to pass the return value back to the action processor.
create() - Static method in class io.simplesource.saga.client.api.SagaClientBuilder
Create saga client builder.
create(PropertiesBuilder.BuildSteps) - Static method in class io.simplesource.saga.client.api.SagaClientBuilder
Create saga client builder with config properties.
createBuilder() - Static method in class io.simplesource.saga.client.dsl.SagaDSL
Creates a SagaBuilder
createMissingTopics(Properties, List<TopicCreation>) - Static method in class io.simplesource.saga.shared.app.StreamAppUtils
 
cSerdes() - Method in class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 

D

decode(O) - Method in interface io.simplesource.saga.action.http.HttpOutput.HttpResultDecoder
 
decode(A) - Method in interface io.simplesource.saga.action.http.HttpRequest.HttpRequestDecoder
 
decoder - Variable in class io.simplesource.saga.action.http.HttpOutput
 
decoder - Variable in class io.simplesource.saga.action.http.HttpSpec
 
dependencies - Variable in class io.simplesource.saga.model.action.SagaAction
The set dependencies of an action (i.e.

E

error - Variable in class io.simplesource.saga.model.action.SagaAction
A list of error may have occurred while processing an action.
EventSourcingBuilder - Class in io.simplesource.saga.action.eventsourcing
A class with a single static function that returns an action processor build step for a simple sourcing event sourcing action.
EventSourcingBuilder() - Constructor for class io.simplesource.saga.action.eventsourcing.EventSourcingBuilder
 
EventSourcingContext<A,D,K,C> - Class in io.simplesource.saga.action.eventsourcing
 
EventSourcingContext() - Constructor for class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 
eventSourcingSpec - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 
EventSourcingSpec<A,D,K,C> - Class in io.simplesource.saga.action.eventsourcing
A value class with the information required to define an event sourcing action processor.
EventSourcingSpec() - Constructor for class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
 
EventSourcingSpec.UndoFunction<A,K,C> - Interface in io.simplesource.saga.action.eventsourcing
The UndoFunction functional interface.
executor - Variable in class io.simplesource.saga.action.async.AsyncContext
 

F

failFast() - Static method in interface io.simplesource.saga.model.saga.RetryStrategy
This strategy indicates no retries should be processed.
forPrefix(String, String) - Static method in interface io.simplesource.saga.shared.topics.TopicNamer
Creates a topic namer using the prefix resource naming strategy.
forStrategy(ResourceNamingStrategy, String) - Static method in interface io.simplesource.saga.shared.topics.TopicNamer
Creates a topic namer using a resource naming strategy.
fromString(String) - Static method in class io.simplesource.saga.model.action.ActionId
Converts an action id from its string representation as a UUID string.
fromString(String) - Static method in class io.simplesource.saga.model.saga.SagaId
Converts a saga from its string representation (as a UUID string) to a saga id.

G

genericAvroSerde(String, Boolean) - Static method in class io.simplesource.saga.serialization.avro.GenericSerdeUtils
 
genericAvroSerde(String, Boolean, SchemaRegistryClient) - Static method in class io.simplesource.saga.serialization.avro.GenericSerdeUtils
 
GenericSerdeUtils - Class in io.simplesource.saga.serialization.avro
 
GenericSerdeUtils() - Constructor for class io.simplesource.saga.serialization.avro.GenericSerdeUtils
 
getActionContext() - Method in class io.simplesource.saga.action.async.AsyncContext
 
getActionContext() - Method in class io.simplesource.saga.action.eventsourcing.EventSourcingContext
 
getMessage() - Method in class io.simplesource.saga.model.saga.SagaError
The error message accessor
getReason() - Method in class io.simplesource.saga.model.saga.SagaError
The reason value accessor.
getSagaResponse(SagaId, Duration) - Method in class io.simplesource.saga.client.api.KafkaSagaAPI
 
getSagaResponse(SagaId, Duration) - Method in interface io.simplesource.saga.model.api.SagaAPI
Returns the result of the saga.
groupId - Variable in class io.simplesource.saga.action.async.AsyncSpec
This group Id is used to create a consumer group that consumes requests to invoke asynchronous actions.
groupId - Variable in class io.simplesource.saga.action.http.HttpSpec
 

H

headers - Variable in class io.simplesource.saga.action.http.HttpRequest
 
HttpBuilder - Class in io.simplesource.saga.action.http
The Http builder is a thin wrapper around the AsyncBuilder that makes it easier to wrap Http web service calls as async actions.
HttpBuilder() - Constructor for class io.simplesource.saga.action.http.HttpBuilder
 
HttpOutput<K,O,R> - Class in io.simplesource.saga.action.http
 
HttpOutput() - Constructor for class io.simplesource.saga.action.http.HttpOutput
 
HttpOutput.HttpResultDecoder<O,R> - Interface in io.simplesource.saga.action.http
 
HttpRequest<K,B> - Class in io.simplesource.saga.action.http
 
HttpRequest() - Constructor for class io.simplesource.saga.action.http.HttpRequest
 
HttpRequest.HttpRequestDecoder<A,K,B> - Interface in io.simplesource.saga.action.http
 
HttpRequest.HttpVerb - Enum in io.simplesource.saga.action.http
 
HttpSpec<A,K,B,O,R> - Class in io.simplesource.saga.action.http
 
HttpSpec() - Constructor for class io.simplesource.saga.action.http.HttpSpec
 
HttpSpec.UndoFunction<A,K,B,O> - Interface in io.simplesource.saga.action.http
The UndoFunction functional interface.

I

id - Variable in class io.simplesource.saga.model.action.ActionId
The id, represented internally as a UUID.
id - Variable in class io.simplesource.saga.model.saga.SagaId
The d is represented internally as a UUID.
iMap(Serde<S>, Function<V, S>, Function<S, V>) - Static method in class io.simplesource.saga.serialization.utils.SerdeUtils
 
iMap(Serde<S>, BiFunction<String, V, S>, BiFunction<String, S, V>) - Static method in class io.simplesource.saga.serialization.utils.SerdeUtils
 
initialState - Variable in class io.simplesource.saga.model.messages.SagaRequest
The initial state of the saga.
inParallel(SagaDSL.SubSaga<A>, SagaDSL.SubSaga<A>...) - Static method in class io.simplesource.saga.client.dsl.SagaDSL
Creates a subsagas consisting of one or more subsagas executing in parallel.
inParallel(Collection<SagaDSL.SubSaga<A>>) - Static method in class io.simplesource.saga.client.dsl.SagaDSL
Creates a subsagas consisting of a collection of subsagas executing in parallel.
inputDecoder - Variable in class io.simplesource.saga.action.async.AsyncSpec
The Input decoder converts the common action command representation to an intermediate decoded type.
inputDecoder - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Input decoder.
inSeries(SagaDSL.SubSaga<A>, SagaDSL.SubSaga<A>...) - Static method in class io.simplesource.saga.client.dsl.SagaDSL
Creates a subsagas consisting of one or more subsagas executing in series.
inSeries(Iterable<SagaDSL.SubSaga<A>>) - Static method in class io.simplesource.saga.client.dsl.SagaDSL
Creates a subsagas consisting of an ordered collection of subsagas executing in series.
io.simplesource.saga.action.app - package io.simplesource.saga.action.app
 
io.simplesource.saga.action.async - package io.simplesource.saga.action.async
 
io.simplesource.saga.action.eventsourcing - package io.simplesource.saga.action.eventsourcing
 
io.simplesource.saga.action.http - package io.simplesource.saga.action.http
 
io.simplesource.saga.client.api - package io.simplesource.saga.client.api
 
io.simplesource.saga.client.dsl - package io.simplesource.saga.client.dsl
 
io.simplesource.saga.model.action - package io.simplesource.saga.model.action
 
io.simplesource.saga.model.api - package io.simplesource.saga.model.api
 
io.simplesource.saga.model.messages - package io.simplesource.saga.model.messages
 
io.simplesource.saga.model.saga - package io.simplesource.saga.model.saga
 
io.simplesource.saga.model.serdes - package io.simplesource.saga.model.serdes
 
io.simplesource.saga.model.specs - package io.simplesource.saga.model.specs
 
io.simplesource.saga.saga.app - package io.simplesource.saga.saga.app
 
io.simplesource.saga.serialization.avro - package io.simplesource.saga.serialization.avro
 
io.simplesource.saga.serialization.utils - package io.simplesource.saga.serialization.utils
 
io.simplesource.saga.shared.app - package io.simplesource.saga.shared.app
 
io.simplesource.saga.shared.kafka - package io.simplesource.saga.shared.kafka
 
io.simplesource.saga.shared.properties - package io.simplesource.saga.shared.properties
 
io.simplesource.saga.shared.serdes - package io.simplesource.saga.shared.serdes
 
io.simplesource.saga.shared.topics - package io.simplesource.saga.shared.topics
 
isUndo - Variable in class io.simplesource.saga.model.messages.ActionRequest
Indicates whether or not this action is processing in undo (compensation) mode.
isUndo - Variable in class io.simplesource.saga.model.messages.ActionResponse
Indicates whether or not this action is processing in undo (compensation) mode.
isUndo - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 

K

KafkaPublisher<K,V> - Class in io.simplesource.saga.shared.kafka
 
KafkaPublisher(KafkaProducer<byte[], byte[]>, Serde<K>, Serde<V>) - Constructor for class io.simplesource.saga.shared.kafka.KafkaPublisher
 
KafkaSagaAPI<A> - Class in io.simplesource.saga.client.api
The KafkaSagaAPI is an implementation of the SagaAPI.
key - Variable in class io.simplesource.saga.action.http.HttpRequest
 
key - Variable in class io.simplesource.saga.model.serdes.TopicSerdes
Serde for the key
keyMapper - Variable in class io.simplesource.saga.action.async.AsyncResult
The Key mapper converts the decoded input type to a key for the output topic.
keyMapper - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Key mapper maps the decoded input type to the aggregate key.

N

namer - Variable in class io.simplesource.saga.shared.topics.TopicConfig
A functional interface that resolves the names of topics for a set of topics types.
nextRetry(int) - Method in interface io.simplesource.saga.model.saga.RetryStrategy
A wait period until the next retry.

O

of(ActionSerdes<A>) - Static method in class io.simplesource.saga.action.app.ActionApp
 
of(K, HttpRequest.HttpVerb, String) - Static method in class io.simplesource.saga.action.http.HttpRequest
 
of(K, HttpRequest.HttpVerb, String, String) - Static method in class io.simplesource.saga.action.http.HttpRequest
 
of(K, HttpRequest.HttpVerb, String, String, B) - Static method in class io.simplesource.saga.action.http.HttpRequest
 
of(A, String) - Static method in class io.simplesource.saga.model.action.ActionCommand
Static constructor for action commands
of(SagaId, Map<ActionId, SagaAction<A>>, SagaStatus, Sequence) - Static method in class io.simplesource.saga.model.saga.Saga
Static constructor for a Saga.
of(Map<ActionId, SagaAction<A>>) - Static method in class io.simplesource.saga.model.saga.Saga
 
of(SagaError.Reason, Throwable) - Static method in class io.simplesource.saga.model.saga.SagaError
Construct a SagaError from a Throwable.
of(SagaError.Reason, String) - Static method in class io.simplesource.saga.model.saga.SagaError
Construct a SagaError from a Throwable.
of(SagaSpec<A>, ActionSpec<A>, TopicConfigBuilder.BuildSteps, PropertiesBuilder.BuildSteps) - Static method in class io.simplesource.saga.saga.app.SagaApp
Static constructor for a SagaApp saga coordinator application.
of(SagaSpec<A>, ActionSpec<A>, TopicConfigBuilder.BuildSteps) - Static method in class io.simplesource.saga.saga.app.SagaApp
 
of(SagaSpec<A>, ActionSpec<A>) - Static method in class io.simplesource.saga.saga.app.SagaApp
 
outputMapper - Variable in class io.simplesource.saga.action.async.AsyncResult
A function that takes the output of the async invocation and decodes it / converts it to the required result type.
outputSerdes - Variable in class io.simplesource.saga.action.async.AsyncResult
The serdes for writing the result to the output topic.
outputSerdes - Variable in class io.simplesource.saga.action.http.HttpOutput
 
outputSpec - Variable in class io.simplesource.saga.action.http.HttpSpec
 

P

properties - Variable in class io.simplesource.saga.shared.app.StreamBuildContext
 
propertiesBuilder - Variable in class io.simplesource.saga.action.app.ActionAppContext
 
PropertiesBuilder - Class in io.simplesource.saga.shared.properties
PropertiesBuilder, as used with PropertiesBuilder.BuildSteps is a functional pattern for setting properties Whenever a PropertiesBuilder.BuildSteps is required, a user can provide a lambda function of this form for example:
PropertiesBuilder() - Constructor for class io.simplesource.saga.shared.properties.PropertiesBuilder
 
PropertiesBuilder.BuildSteps - Interface in io.simplesource.saga.shared.properties
A functional interface representing a configuration step that is applied to a properties builder
PropertiesBuilder.Target - Enum in io.simplesource.saga.shared.properties
Representing the Target application requiring the properties

R

random() - Static method in class io.simplesource.saga.model.action.ActionId
Returns an random ActionId
random() - Static method in class io.simplesource.saga.model.saga.SagaId
Generates a randon saga ID.
repeat(int, Duration) - Static method in interface io.simplesource.saga.model.saga.RetryStrategy
This strategy retries a certain number of times, with a fixed delay between attempts.
request() - Method in interface io.simplesource.saga.model.serdes.ActionSerdes
Serde for an action request.
request() - Method in interface io.simplesource.saga.model.serdes.SagaClientSerdes
Serde for the saga request.
response() - Method in interface io.simplesource.saga.model.serdes.ActionSerdes
Serde for an action response.
response() - Method in interface io.simplesource.saga.model.serdes.SagaClientSerdes
Serde for the saga response.
responseWindow - Variable in class io.simplesource.saga.model.specs.SagaSpec
Represents the response window for the Saga API.
result - Variable in class io.simplesource.saga.model.messages.ActionResponse
The result, consisting of a SagaError if processing fail and indicating success if processing succeeds.
result - Variable in class io.simplesource.saga.model.messages.SagaResponse
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.
resultSpec - Variable in class io.simplesource.saga.action.async.AsyncSpec
This is required for cases where the result is written to an output topic, or where an undo function is defined based on the return value.
retryCount - Variable in class io.simplesource.saga.model.action.SagaAction
Th number of times that processing of an action has been re-attempted.
RetryPublisher<A> - Interface in io.simplesource.saga.saga.app
A functional interface to support retrying action processing
RetryStrategy - Interface in io.simplesource.saga.model.saga
This interface specifies how the saga coordinator should attempt retries, both how many times and how long between them
run(PropertiesBuilder.BuildSteps) - Method in class io.simplesource.saga.action.app.ActionApp
Builds and runs the stream.
run() - Method in class io.simplesource.saga.saga.app.SagaApp
Run the SagaApp with the given stream app configuration.
run(PropertiesBuilder.BuildSteps) - Method in class io.simplesource.saga.shared.app.StreamApp
Run the SourcingApp with the given configuration steps
runStreamApp(Properties, Topology) - Static method in class io.simplesource.saga.shared.app.StreamAppUtils
 

S

Saga<A> - Class in io.simplesource.saga.model.saga
The internal representation of a saga.
Saga() - Constructor for class io.simplesource.saga.model.saga.Saga
 
SAGA_BASE_NAME - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
SAGA_REQUEST - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
SAGA_RESPONSE - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
SAGA_RESPONSE_TOPIC_MAP - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
SAGA_STATE - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
SAGA_STATE_TRANSITION - Static variable in class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
SagaAction<A> - Class in io.simplesource.saga.model.action
The representation of an action within a Saga
SagaAction() - Constructor for class io.simplesource.saga.model.action.SagaAction
 
SagaActionStateChanged() - Constructor for class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 
SagaAPI<A> - Interface in io.simplesource.saga.model.api
The Saga API, used for submitting saga requests and asynchronously waiting for the result of the saga execution/
SagaApp<A> - Class in io.simplesource.saga.saga.app
SagaApp (the "Saga Coordinator") accepts a dependency graph of saga actions.
SagaBuilder() - Constructor for class io.simplesource.saga.client.dsl.SagaDSL.SagaBuilder
 
SagaClientBuilder<A> - Class in io.simplesource.saga.client.api
The saga client builder is used to create a SagaAPI.
SagaClientBuilder() - Constructor for class io.simplesource.saga.client.api.SagaClientBuilder
 
SagaClientSerdes<A> - Interface in io.simplesource.saga.model.serdes
The serdes required to serialize and deserialize the saga request and response topics.
sagaClientSerdes(String, boolean) - Static method in interface io.simplesource.saga.serialization.avro.AvroSerdes.Generic
Saga client serdes (serdes required for the saga request and response topics)
sagaClientSerdes(Serde<A>, String, boolean) - Static method in class io.simplesource.saga.serialization.avro.AvroSerdes
Saga client serdes (serdes required for the saga request and response topics)
sagaClientSerdes(String, boolean) - Static method in interface io.simplesource.saga.serialization.avro.AvroSerdes.Specific
Saga client serdes (serdes required for the saga request and response topics)
SagaClientSpec<A> - Class in io.simplesource.saga.model.specs
Represents the details required to create a saga client instance
SagaClientSpec() - Constructor for class io.simplesource.saga.model.specs.SagaClientSpec
 
SagaDSL - Class in io.simplesource.saga.client.dsl
The saga DSL is used be the client to build a saga.
SagaDSL() - Constructor for class io.simplesource.saga.client.dsl.SagaDSL
 
SagaDSL.SagaBuilder<A> - Class in io.simplesource.saga.client.dsl
A SagaBuilder is used to add actions by creating a subsaga consisting of a single action, and to build the saga once the definition steps are complete.
SagaDSL.SubSaga<A> - Class in io.simplesource.saga.client.dsl
A Subsaga is a subset of a saga consisting of one or more action, with dependencies defined between them.
sagaError - Variable in class io.simplesource.saga.model.saga.Saga
If the saga fails, the cumulative list of errors that occurred in the processing for the saga.
SagaError - Class in io.simplesource.saga.model.saga
Represents an error in saga processing
SagaError.Reason - Enum in io.simplesource.saga.model.saga
Represents the reason for an action processor or saga failing.
sagaErrors - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaStatusChanged
 
sagaId - Variable in class io.simplesource.saga.model.messages.ActionRequest
The saga id uniquely identifies the saga, and is used as the key for the action request and responses.
sagaId - Variable in class io.simplesource.saga.model.messages.ActionResponse
The saga id uniquely identifies the saga, and is used as the key for the action request and responses.
sagaId - Variable in class io.simplesource.saga.model.messages.SagaRequest
The saga id uniquely identifies the saga, and is used as the key for the saga request and responses.
sagaId - Variable in class io.simplesource.saga.model.messages.SagaResponse
The saga id uniquely identifies the saga, and is used as the key for the saga request and responses.
sagaId - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 
sagaId - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaStatusChanged
 
sagaId - Variable in class io.simplesource.saga.model.saga.Saga
The Saga id uniquely identifies the saga.
SagaId - Class in io.simplesource.saga.model.saga
A saga id uniquely identifies the saga.
SagaId() - Constructor for class io.simplesource.saga.model.saga.SagaId
 
sagaId() - Method in interface io.simplesource.saga.model.serdes.ActionSerdes
Serde for the saga id.
sagaId() - Method in interface io.simplesource.saga.model.serdes.SagaClientSerdes
Serde for the saga id.
SagaRequest<A> - Class in io.simplesource.saga.model.messages
A request to execute a saga, published by client (either directly, or via the SagaAPI in the saga request topic, and consumed by the saga coordinator.
SagaRequest() - Constructor for class io.simplesource.saga.model.messages.SagaRequest
 
SagaResponse - Class in io.simplesource.saga.model.messages
A response from saga execution, published by the saga coordinator in the saga response topic after saga completes (successfully, or with error).
SagaResponse() - Constructor for class io.simplesource.saga.model.messages.SagaResponse
 
SagaSerdes<A> - Interface in io.simplesource.saga.model.serdes
The serdes required to serialize and deserialize the saga state and state transition topics, as well as the request and response topics.
sagaSerdes(String, boolean) - Static method in interface io.simplesource.saga.serialization.avro.AvroSerdes.Generic
Saga serdes (saga client topics, as well as the saga internal state and state transition topics)
sagaSerdes(Serde<A>, String, boolean) - Static method in class io.simplesource.saga.serialization.avro.AvroSerdes
Saga serdes (saga client topics, as well as the saga internal state and state transition topics)
sagaSerdes(String, boolean) - Static method in interface io.simplesource.saga.serialization.avro.AvroSerdes.Specific
Saga serdes (saga client topics, as well as the saga internal state and state transition topics)
SagaSpec<A> - Class in io.simplesource.saga.model.specs
Represents the details required to create a saga coordinator
SagaSpec() - Constructor for class io.simplesource.saga.model.specs.SagaSpec
 
sagaState - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SetInitialState
 
SagaStateTransition<A> - Interface in io.simplesource.saga.model.messages
SagaStateTransition interface.
SagaStateTransition.SagaActionStateChanged<A> - Class in io.simplesource.saga.model.messages
A transition representing state changes of a Saga caused by updates to state of an action
SagaStateTransition.SagaStatusChanged<A> - Class in io.simplesource.saga.model.messages
A transition representing state changes of a Saga caused by updating a sagas status
SagaStateTransition.SetInitialState<A> - Class in io.simplesource.saga.model.messages
A transition for setting the initial state of the Saga
SagaStateTransition.TransitionList<A> - Class in io.simplesource.saga.model.messages
A transition representing multiple state changes to a saga
sagaStatus - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaStatusChanged
 
SagaStatus - Enum in io.simplesource.saga.model.saga
Represents the overall status of the saga.
SagaStatusChanged() - Constructor for class io.simplesource.saga.model.messages.SagaStateTransition.SagaStatusChanged
 
SagaTopic() - Constructor for class io.simplesource.saga.shared.topics.TopicTypes.SagaTopic
 
send(String, SagaId, SagaStateTransition<A>) - Method in interface io.simplesource.saga.saga.app.RetryPublisher
 
send(String, K, V) - Method in class io.simplesource.saga.shared.kafka.KafkaPublisher
 
sequence - Variable in class io.simplesource.saga.model.saga.Saga
The sequence number of the saga, indicating the number of saga state transitions that have occurred.
sequenceMapper - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Sequence mapper maps the decoded input type to the last read aggregate sequence.
serdes - Variable in class io.simplesource.saga.model.specs.ActionSpec
The Serdes.
serdes - Variable in class io.simplesource.saga.model.specs.SagaClientSpec
The serdes required for all the saga request and response topics.
serdes - Variable in class io.simplesource.saga.model.specs.SagaSpec
The serdes required for all the saga coordinator topics (request and response as well as state and state transition topics).
SerdeUtils - Class in io.simplesource.saga.serialization.utils
A utility class with methods that enable the derivation of a serde from a serde from an another type.
SerdeUtils() - Constructor for class io.simplesource.saga.serialization.utils.SerdeUtils
 
SetInitialState() - Constructor for class io.simplesource.saga.model.messages.SagaStateTransition.SetInitialState
 
shutDown() - Method in interface io.simplesource.saga.shared.app.StreamAppUtils.ShutdownHandler
 
shutdownExecutorService(ExecutorService) - Static method in class io.simplesource.saga.shared.app.StreamAppUtils
 
shutdownHandlers - Variable in class io.simplesource.saga.shared.app.StreamBuildResult
 
specificAvroSerde(String, Boolean) - Static method in class io.simplesource.saga.serialization.avro.SpecificSerdeUtils
 
specificAvroSerde(String, Boolean, SchemaRegistryClient) - Static method in class io.simplesource.saga.serialization.avro.SpecificSerdeUtils
 
SpecificSerdeUtils - Class in io.simplesource.saga.serialization.avro
 
SpecificSerdeUtils() - Constructor for class io.simplesource.saga.serialization.avro.SpecificSerdeUtils
 
state() - Method in interface io.simplesource.saga.model.serdes.SagaSerdes
Serde for the saga state.
status - Variable in class io.simplesource.saga.model.action.SagaAction
The status of the action.
status - Variable in class io.simplesource.saga.model.saga.Saga
The status of the saga.
StreamApp<I> - Class in io.simplesource.saga.shared.app
StreamApp is a generic method for specifying the steps involved in building and running a KStream app that enables: Defining some initial configuration that is applicable to the entire build process Specifying the stream topology for the application in an arbitrary sequence of steps Specifying which topics are needed to define te topology Specifying topic configuration information in a flexible way Collating the list of required topics, and providing and overriding configuration information for their creation Providing a flexible configuration mechanism for setting Kafka properties Creating the missing topics prior to running the stream Running the stream application Handling and cleanup / freeing of resources post termination of the stream It is a functional abstraction on top of the Kafka Stream builder DSL that delays the execution of the stream build steps and allows for decorating the process with extra information.
StreamApp(I) - Constructor for class io.simplesource.saga.shared.app.StreamApp
 
StreamAppUtils - Class in io.simplesource.saga.shared.app
 
StreamAppUtils() - Constructor for class io.simplesource.saga.shared.app.StreamAppUtils
 
StreamAppUtils.ShutdownHandler - Interface in io.simplesource.saga.shared.app
 
StreamBuildContext<I> - Class in io.simplesource.saga.shared.app
 
StreamBuildContext() - Constructor for class io.simplesource.saga.shared.app.StreamBuildContext
 
StreamBuildResult - Class in io.simplesource.saga.shared.app
 
StreamBuildResult() - Constructor for class io.simplesource.saga.shared.app.StreamBuildResult
 
StreamBuildSpec - Class in io.simplesource.saga.shared.app
 
StreamBuildSpec() - Constructor for class io.simplesource.saga.shared.app.StreamBuildSpec
 
StreamBuildStep<I> - Interface in io.simplesource.saga.shared.app
 
submitSaga(SagaRequest<A>) - Method in class io.simplesource.saga.client.api.KafkaSagaAPI
 
submitSaga(SagaRequest<A>) - Method in interface io.simplesource.saga.model.api.SagaAPI
Initiates a saga.
SubSaga() - Constructor for class io.simplesource.saga.client.dsl.SagaDSL.SubSaga
 

T

timeout - Variable in class io.simplesource.saga.action.async.AsyncSpec
The timeout.
timeout - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Timeout.
timeout - Variable in class io.simplesource.saga.action.http.HttpSpec
 
TopicConfig - Class in io.simplesource.saga.shared.topics
TopicConfig represents configuration information for topic names and for topic properties for topic creation
TopicConfig() - Constructor for class io.simplesource.saga.shared.topics.TopicConfig
 
TopicConfigBuilder - Class in io.simplesource.saga.shared.topics
TopicConfigBuilder, as used with TopicConfigBuilder.BuildSteps is a functional pattern for setting topic configuration Whenever a TopicConfigBuilder.BuildSteps is required, a user can provide a lambda function of this form for example:
TopicConfigBuilder.BuildSteps - Interface in io.simplesource.saga.shared.topics
A functional interface representing a configuration step that is applied to a topic builder
TopicCreation - Class in io.simplesource.saga.shared.topics
A data class that encompasses both the topic name and the configuration for topic creation
TopicCreation() - Constructor for class io.simplesource.saga.shared.topics.TopicCreation
 
topicCreations - Variable in class io.simplesource.saga.shared.app.StreamBuildResult
 
topicName - Variable in class io.simplesource.saga.action.http.HttpRequest
 
topicName - Variable in class io.simplesource.saga.shared.topics.TopicCreation
The topic name.
TopicNamer - Interface in io.simplesource.saga.shared.topics
Several types of topics (eg.
topicNamerOverride(TopicNamer, Map<String, String>) - Static method in class io.simplesource.saga.shared.topics.TopicUtils
 
topics - Variable in class io.simplesource.saga.shared.app.StreamBuildSpec
 
TopicSerdes<K,V> - Class in io.simplesource.saga.model.serdes
A generic interface representing the serdes required to serialize and deserialize an arbitrary topic.
TopicSerdes() - Constructor for class io.simplesource.saga.model.serdes.TopicSerdes
 
topicSpec - Variable in class io.simplesource.saga.shared.topics.TopicCreation
The topic spec for topic creation.
topicSpecs - Variable in class io.simplesource.saga.shared.topics.TopicConfig
A map of topic specs per action type.
topicTypes - Variable in class io.simplesource.saga.shared.topics.TopicConfig
A list of topic types that this topic config applies to the family of topics
TopicTypes - Class in io.simplesource.saga.shared.topics
A collation of the different topic types for various families of topics.
TopicTypes() - Constructor for class io.simplesource.saga.shared.topics.TopicTypes
 
TopicTypes.ActionTopic - Class in io.simplesource.saga.shared.topics
Topic types for action processors
TopicTypes.CommandTopic - Class in io.simplesource.saga.shared.topics
Topic types for event sourcing commands
TopicTypes.SagaTopic - Class in io.simplesource.saga.shared.topics
Topic types for the saga coordinator
TopicUtils - Class in io.simplesource.saga.shared.topics
 
TopicUtils() - Constructor for class io.simplesource.saga.shared.topics.TopicUtils
 
topologyBuildStep - Variable in class io.simplesource.saga.shared.app.StreamBuildSpec
 
topologySupplier - Variable in class io.simplesource.saga.shared.app.StreamBuildResult
 
toString() - Method in class io.simplesource.saga.model.action.ActionId
 
toString() - Method in class io.simplesource.saga.model.saga.SagaId
 
transition() - Method in interface io.simplesource.saga.model.serdes.SagaSerdes
Serde for the saga state transitions.
TransitionList() - Constructor for class io.simplesource.saga.model.messages.SagaStateTransition.TransitionList
 
tuple2(Serde<A>, Serde<B>) - Static method in class io.simplesource.saga.shared.serdes.TupleSerdes
A utility method for creating a serde on-the-fly for a pair Tuple2<A, B> whenever a serde is available for A and B.
TupleSerdes - Class in io.simplesource.saga.shared.serdes
A generic utility class for creating composite serdes.
TupleSerdes() - Constructor for class io.simplesource.saga.shared.serdes.TupleSerdes
 

U

undoCommand - Variable in class io.simplesource.saga.action.eventsourcing.EventSourcingSpec
The Undo command.
undoCommand - Variable in class io.simplesource.saga.model.action.SagaAction
The command for processing of the action when in undo (compensation) mode.
UndoCommand<A> - Class in io.simplesource.saga.model.action
Represents an undo action returned in the action response to dynamically set the undo (compensation) command for the action for if the saga later fails.
UndoCommand() - Constructor for class io.simplesource.saga.model.action.UndoCommand
 
undoCommand - Variable in class io.simplesource.saga.model.messages.SagaStateTransition.SagaActionStateChanged
 
undoFunction - Variable in class io.simplesource.saga.action.async.AsyncSpec
An undo function.
undoFunction - Variable in class io.simplesource.saga.action.http.HttpSpec
 
updated(ActionStatus) - Method in class io.simplesource.saga.model.action.SagaAction
Returns an new SagaAction with just the status updated
updated(SagaStatus) - Method in class io.simplesource.saga.model.saga.Saga
Creates a new saga instances with an updated saga status.
updated(SagaStatus, List<SagaError>) - Method in class io.simplesource.saga.model.saga.Saga
Creates a new saga instances with an updated saga status and error list.
updated(Map<ActionId, SagaAction<A>>, SagaStatus, List<SagaError>) - Method in class io.simplesource.saga.model.saga.Saga
Creates a new saga instances with an updated set of actions, saga status and error list.
updated(Map<ActionId, SagaAction<A>>, SagaStatus) - Method in class io.simplesource.saga.model.saga.Saga
Creates a new saga instances with an updated set of actions and saga status.
url - Variable in class io.simplesource.saga.action.http.HttpRequest
 

V

value - Variable in class io.simplesource.saga.model.serdes.TopicSerdes
Serde for the value
valueOf(String) - Static method in enum io.simplesource.saga.action.http.HttpRequest.HttpVerb
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.simplesource.saga.model.action.ActionStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.simplesource.saga.model.saga.SagaError.Reason
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.simplesource.saga.model.saga.SagaStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.simplesource.saga.shared.properties.PropertiesBuilder.Target
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.simplesource.saga.action.http.HttpRequest.HttpVerb
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.simplesource.saga.model.action.ActionStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.simplesource.saga.model.saga.SagaError.Reason
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.simplesource.saga.model.saga.SagaStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.simplesource.saga.shared.properties.PropertiesBuilder.Target
Returns an array containing the constants of this enum type, in the order they are declared.
verb - Variable in class io.simplesource.saga.action.http.HttpRequest
 

W

withAction(String, TopicConfigBuilder.BuildSteps) - Method in class io.simplesource.saga.saga.app.SagaApp
Adds a single action, specifying the topic configuration for the request and response topics for that action type
withActionProcessor(ActionProcessorBuildStep<A>) - Method in class io.simplesource.saga.action.app.ActionApp
Adds an action processor build step to the application.
withActions(Collection<String>, TopicConfigBuilder.BuildSteps) - Method in class io.simplesource.saga.saga.app.SagaApp
Adds multiple actions, specifying the topic configuration for the request and response topics for all action types
withActions(String...) - Method in class io.simplesource.saga.saga.app.SagaApp
Adds multiple actions, using default topic configuration
withActions(TopicConfigBuilder.BuildSteps, String...) - Method in class io.simplesource.saga.saga.app.SagaApp
Adds a variable length argument list of action types, specifying the topic configuration for the request and response topics for all action types
withBootstrapServers(String) - Method in class io.simplesource.saga.shared.properties.PropertiesBuilder
 
withBuildStep(StreamBuildStep<I>) - Method in class io.simplesource.saga.shared.app.StreamApp
 
withClientId(String) - Method in class io.simplesource.saga.client.api.SagaClientBuilder
With client id saga client builder.
withDefaultTopicSpec(int, int, int) - Method in class io.simplesource.saga.shared.topics.TopicConfigBuilder
Sets the topic spec by default topic to be the topic spec with the specified partitions and replication factor, as well as the setting the topic retention
withExecutor(ScheduledExecutorService) - Method in class io.simplesource.saga.saga.app.SagaApp
Sets an executor for the Saga app.
withInitialStep(PropertiesBuilder.BuildSteps) - Method in interface io.simplesource.saga.shared.properties.PropertiesBuilder.BuildSteps
 
withInitialStep(TopicConfigBuilder.BuildSteps) - Method in interface io.simplesource.saga.shared.topics.TopicConfigBuilder.BuildSteps
 
withNamingStrategy(ResourceNamingStrategy) - Method in class io.simplesource.saga.shared.topics.TopicConfigBuilder
Sets the the resource naming strategy for topic creation
withNextStep(PropertiesBuilder.BuildSteps) - Method in interface io.simplesource.saga.shared.properties.PropertiesBuilder.BuildSteps
 
withNextStep(TopicConfigBuilder.BuildSteps) - Method in interface io.simplesource.saga.shared.topics.TopicConfigBuilder.BuildSteps
 
withProperties(PropertiesBuilder.BuildSteps) - Method in class io.simplesource.saga.client.api.SagaClientBuilder
Sets the config properties.
withProperties(Properties) - Method in class io.simplesource.saga.shared.properties.PropertiesBuilder
 
withProperties(Map<String, Object>) - Method in class io.simplesource.saga.shared.properties.PropertiesBuilder
 
withProperty(String, Object) - Method in class io.simplesource.saga.shared.properties.PropertiesBuilder
 
withRetryStrategy(RetryStrategy) - Method in class io.simplesource.saga.saga.app.SagaApp
Sets the retry strategy that applies to all action types, unless specifically overridden
withRetryStrategy(String, RetryStrategy) - Method in class io.simplesource.saga.saga.app.SagaApp
Sets the retry strategy for a specific action type
withScheduler(ScheduledExecutorService) - Method in class io.simplesource.saga.client.api.SagaClientBuilder
Sets the scheduler required to schedule timeouts.
withSerdes(SagaClientSerdes<A>) - Method in class io.simplesource.saga.client.api.SagaClientBuilder
Sets the Serdes required for the saga request and saga response topics.
withStreamAppConfig(String, String) - Method in class io.simplesource.saga.shared.properties.PropertiesBuilder
Sets the essential properties for Kafka Streams applications (app id and bootstrap servers)
withTopicBaseName(String) - Method in class io.simplesource.saga.shared.topics.TopicConfigBuilder
Sets the base name for topic creation when applying the prefix resource naming strategy
withTopicConfig(TopicConfigBuilder.BuildSteps) - Method in class io.simplesource.saga.client.api.SagaClientBuilder
Sets the topic configuration for naming and creating the saga request and response topics.
withTopicNameOverride(String, String) - Method in class io.simplesource.saga.shared.topics.TopicConfigBuilder
Overrides the topic name for a given topic type
withTopicNamer(TopicNamer) - Method in class io.simplesource.saga.shared.topics.TopicConfigBuilder
Explicitly sets the topic namer
withTopicPrefix(String) - Method in class io.simplesource.saga.shared.topics.TopicConfigBuilder
Sets the resource naming strategy to PrefixResourceNamingStrategy with the given prefix
withTopicSpecOverride(String, TopicSpec) - Method in class io.simplesource.saga.shared.topics.TopicConfigBuilder
Overrides the topic spec for a given topic type
A B C D E F G H I K N O P R S T U V W 
Skip navigation links

Copyright © 2019. All rights reserved.