package
0.0.6
Repository: https://github.com/stackus/edat.git
Documentation: pkg.go.dev

# Functions

NewCommandDispatcher constructs a new CommandDispatcher.
NewLocalStep constructor for LocalStep.
NewOrchestrator constructs a new Orchestrator.
NewRemoteStep constructor for RemoteStep.
NewSagaInstance constructor for *SagaInstances.
WithCommandDispatcherLogger is an option to set the log.Logger of the CommandDispatcher.
WithOrchestratorLogger is an option to set the log.Logger of the Orchestrator.
WithRemoteStepPredicate sets a predicate function for the action.
WithSagaInfo is an option to set additional Saga specific headers.

# Constants

Saga message headers.
Saga message headers.
Saga message headers.
Saga message headers.
Saga message headers.
Definition lifecycle hooks.
Definition lifecycle hooks.
Definition lifecycle hooks.

# Structs

CommandDispatcher is a MessageReceiver for Commands.
Instance is the container for saga data.
LocalStep is used to execute local saga business logic.
Orchestrator orchestrates local and distributed processes.
RemoteStep is used to execute distributed saga business logic.

# Interfaces

Command is a core.Command with message header information.
Definition interface.
InstanceStore interface.
Step interface for local, remote, ...other saga steps.

# Type aliases

CommandDispatcherOption options for CommandConsumers.
CommandHandlerFunc function handlers for saga.Command.
LifecycleHook type for hooking in custom code at specific stages of a saga.
OrchestratorOption options for Orchestrator.
RemoteStepActionOption options for remoteStepAction.