Index

_

__init__() (minos.saga.context.SagaContext method) (minos.saga.definitions.operations.SagaOperation method) (minos.saga.definitions.saga.Saga method) (minos.saga.definitions.steps.abc.SagaStep method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) (minos.saga.definitions.steps.conditional.ElseThenAlternative method) (minos.saga.definitions.steps.conditional.IfThenAlternative method) (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method) (minos.saga.exceptions.AlreadyCommittedException method) (minos.saga.exceptions.AlreadyOnSagaException method) (minos.saga.exceptions.EmptySagaException method) (minos.saga.exceptions.EmptySagaStepException method) (minos.saga.exceptions.ExecutorException method) (minos.saga.exceptions.MultipleElseThenException method) (minos.saga.exceptions.MultipleOnErrorException method) (minos.saga.exceptions.MultipleOnExecuteException method) (minos.saga.exceptions.MultipleOnFailureException method) (minos.saga.exceptions.MultipleOnSuccessException method) (minos.saga.exceptions.SagaException method) (minos.saga.exceptions.SagaExecutionAlreadyExecutedException method) (minos.saga.exceptions.SagaExecutionException method) (minos.saga.exceptions.SagaExecutionNotFoundException method) (minos.saga.exceptions.SagaFailedCommitCallbackException method) (minos.saga.exceptions.SagaFailedExecutionException method) (minos.saga.exceptions.SagaFailedExecutionStepException method) (minos.saga.exceptions.SagaNotCommittedException method) (minos.saga.exceptions.SagaNotDefinedException method) (minos.saga.exceptions.SagaPausedExecutionStepException method) (minos.saga.exceptions.SagaResponseException method) (minos.saga.exceptions.SagaRollbackExecutionException method) (minos.saga.exceptions.SagaRollbackExecutionStepException method) (minos.saga.exceptions.SagaStepException method) (minos.saga.exceptions.SagaStepExecutionException method) (minos.saga.exceptions.UndefinedOnExecuteException method) (minos.saga.executions.commit.TransactionCommitter method) (minos.saga.executions.executors.abc.Executor method) (minos.saga.executions.executors.local.LocalExecutor method) (minos.saga.executions.executors.request.RequestExecutor method) (minos.saga.executions.executors.response.ResponseExecutor method) (minos.saga.executions.saga.SagaExecution method) (minos.saga.executions.steps.abc.SagaStepExecution method) (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution method) (minos.saga.executions.steps.local.LocalSagaStepExecution method) (minos.saga.executions.steps.remote.RemoteSagaStepExecution method) (minos.saga.executions.storage.SagaExecutionStorage method) (minos.saga.manager.SagaManager method) (minos.saga.messages.SagaRequest method) (minos.saga.messages.SagaResponse method) (minos.saga.services.SagaService method)

A

already_destroyed (minos.saga.manager.SagaManager property) already_setup (minos.saga.manager.SagaManager property) AlreadyCommittedException AlreadyOnSagaException args (minos.saga.exceptions.AlreadyCommittedException attribute) (minos.saga.exceptions.AlreadyOnSagaException attribute) (minos.saga.exceptions.EmptySagaException attribute) (minos.saga.exceptions.EmptySagaStepException attribute) (minos.saga.exceptions.ExecutorException attribute) (minos.saga.exceptions.MultipleElseThenException attribute) (minos.saga.exceptions.MultipleOnErrorException attribute) (minos.saga.exceptions.MultipleOnExecuteException attribute) (minos.saga.exceptions.MultipleOnFailureException attribute) (minos.saga.exceptions.MultipleOnSuccessException attribute) (minos.saga.exceptions.SagaException attribute) (minos.saga.exceptions.SagaExecutionAlreadyExecutedException attribute) (minos.saga.exceptions.SagaExecutionException attribute) (minos.saga.exceptions.SagaExecutionNotFoundException attribute) (minos.saga.exceptions.SagaFailedCommitCallbackException attribute) (minos.saga.exceptions.SagaFailedExecutionException attribute) (minos.saga.exceptions.SagaFailedExecutionStepException attribute) (minos.saga.exceptions.SagaNotCommittedException attribute) (minos.saga.exceptions.SagaNotDefinedException attribute) (minos.saga.exceptions.SagaPausedExecutionStepException attribute) (minos.saga.exceptions.SagaResponseException attribute) (minos.saga.exceptions.SagaRollbackExecutionException attribute) (minos.saga.exceptions.SagaRollbackExecutionStepException attribute) (minos.saga.exceptions.SagaStepException attribute) (minos.saga.exceptions.SagaStepExecutionException attribute) (minos.saga.exceptions.UndefinedOnExecuteException attribute)

avro_bytes (minos.saga.context.SagaContext property) avro_data (minos.saga.context.SagaContext property) avro_schema (minos.saga.context.SagaContext attribute) avro_str (minos.saga.context.SagaContext property)

C

classname (minos.saga.context.SagaContext attribute) clear() (minos.saga.context.SagaContext method) commit() (minos.saga.definitions.saga.Saga method) (minos.saga.definitions.steps.abc.SagaStep method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method) (minos.saga.executions.commit.TransactionCommitter method) (minos.saga.executions.saga.SagaExecution method) conditional_step() (minos.saga.definitions.saga.Saga method) (minos.saga.definitions.steps.abc.SagaStep method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method)

ConditionalSagaStep (class in minos.saga.definitions.steps.conditional) ConditionalSagaStepExecution (class in minos.saga.executions.steps.conditional) content() (minos.saga.messages.SagaRequest method) (minos.saga.messages.SagaResponse method) Created (minos.saga.executions.status.SagaStatus attribute) (minos.saga.executions.status.SagaStepStatus attribute)

D

definition (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution attribute) (minos.saga.executions.steps.local.LocalSagaStepExecution attribute) (minos.saga.executions.steps.remote.RemoteSagaStepExecution attribute)

delete() (minos.saga.executions.storage.SagaExecutionStorage method) destroy() (minos.saga.manager.SagaManager method)

E

else_then() (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) ElseThenAlternative (class in minos.saga.definitions.steps.conditional) empty() (minos.saga.context.SagaContext class method) EmptySagaException EmptySagaStepException ERROR (minos.saga.messages.SagaResponseStatus attribute) Errored (minos.saga.executions.status.SagaStatus attribute) ErroredByOnExecute (minos.saga.executions.status.SagaStepStatus attribute) ErroredOnError (minos.saga.executions.status.SagaStepStatus attribute) ErroredOnExecute (minos.saga.executions.status.SagaStepStatus attribute) ErroredOnFailure (minos.saga.executions.status.SagaStepStatus attribute) ErroredOnSuccess (minos.saga.executions.status.SagaStepStatus attribute) exec() (minos.saga.executions.executors.abc.Executor method) (minos.saga.executions.executors.local.LocalExecutor method) (minos.saga.executions.executors.request.RequestExecutor method) (minos.saga.executions.executors.response.ResponseExecutor method)

exec_function() (minos.saga.executions.executors.abc.Executor method) (minos.saga.executions.executors.local.LocalExecutor method) (minos.saga.executions.executors.request.RequestExecutor method) (minos.saga.executions.executors.response.ResponseExecutor method) execute() (minos.saga.executions.saga.SagaExecution method) (minos.saga.executions.steps.abc.SagaStepExecution method) (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution method) (minos.saga.executions.steps.local.LocalSagaStepExecution method) (minos.saga.executions.steps.remote.RemoteSagaStepExecution method) Executor (class in minos.saga.executions.executors.abc) ExecutorException

F

fields (minos.saga.context.SagaContext property) Finished (minos.saga.executions.status.SagaStatus attribute) (minos.saga.executions.status.SagaStepStatus attribute) FinishedOnExecute (minos.saga.executions.status.SagaStepStatus attribute) from_avro() (minos.saga.context.SagaContext class method) from_avro_bytes() (minos.saga.context.SagaContext class method) from_avro_str() (minos.saga.context.SagaContext class method) from_config() (minos.saga.executions.storage.SagaExecutionStorage class method) (minos.saga.manager.SagaManager class method) from_definition() (minos.saga.executions.saga.SagaExecution class method) (minos.saga.executions.steps.abc.SagaStepExecution static method) (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution static method) (minos.saga.executions.steps.local.LocalSagaStepExecution static method) (minos.saga.executions.steps.remote.RemoteSagaStepExecution static method) from_message() (minos.saga.messages.SagaResponse class method) from_model_type() (minos.saga.context.SagaContext class method) from_raw() (minos.saga.definitions.operations.SagaOperation class method) (minos.saga.definitions.saga.Saga class method) (minos.saga.definitions.steps.abc.SagaStep class method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep class method) (minos.saga.definitions.steps.conditional.ElseThenAlternative class method) (minos.saga.definitions.steps.conditional.IfThenAlternative class method) (minos.saga.definitions.steps.local.LocalSagaStep class method) (minos.saga.definitions.steps.remote.RemoteSagaStep class method) (minos.saga.executions.saga.SagaExecution class method) (minos.saga.executions.status.SagaStatus class method) (minos.saga.executions.status.SagaStepStatus class method) (minos.saga.executions.steps.abc.SagaStepExecution class method) (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution class method) (minos.saga.executions.steps.local.LocalSagaStepExecution class method) (minos.saga.executions.steps.remote.RemoteSagaStepExecution class method) (minos.saga.messages.SagaResponseStatus class method)

from_saga() (minos.saga.executions.saga.SagaExecution class method) from_typed_dict() (minos.saga.context.SagaContext class method)

G

get() (minos.saga.context.SagaContext method)

get_service_name() (in module minos.saga.utils)

I

if_then() (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) IfThenAlternative (class in minos.saga.definitions.steps.conditional)

inner (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution attribute) items() (minos.saga.context.SagaContext method)

K

keys() (minos.saga.context.SagaContext method)

L

load() (minos.saga.executions.storage.SagaExecutionStorage method) local_step() (minos.saga.definitions.saga.Saga method) (minos.saga.definitions.steps.abc.SagaStep method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method)

LocalExecutor (class in minos.saga.executions.executors.local) LocalSagaStep (class in minos.saga.definitions.steps.local) LocalSagaStepExecution (class in minos.saga.executions.steps.local)

M

minos module minos.saga module minos.saga.context module minos.saga.definitions module minos.saga.definitions.operations module minos.saga.definitions.saga module minos.saga.definitions.steps module minos.saga.definitions.steps.abc module minos.saga.definitions.steps.conditional module minos.saga.definitions.steps.local module minos.saga.definitions.steps.remote module minos.saga.definitions.types module minos.saga.exceptions module minos.saga.executions module minos.saga.executions.commit module minos.saga.executions.executors module minos.saga.executions.executors.abc module minos.saga.executions.executors.local module minos.saga.executions.executors.request module minos.saga.executions.executors.response module minos.saga.executions.saga module minos.saga.executions.status module minos.saga.executions.steps module minos.saga.executions.steps.abc module minos.saga.executions.steps.conditional module minos.saga.executions.steps.local module minos.saga.executions.steps.remote module

minos.saga.executions.storage module minos.saga.manager module minos.saga.messages module minos.saga.middleware module minos.saga.services module minos.saga.utils module model_type (minos.saga.context.SagaContext attribute) module minos minos.saga minos.saga.context minos.saga.definitions minos.saga.definitions.operations minos.saga.definitions.saga minos.saga.definitions.steps minos.saga.definitions.steps.abc minos.saga.definitions.steps.conditional minos.saga.definitions.steps.local minos.saga.definitions.steps.remote minos.saga.definitions.types minos.saga.exceptions minos.saga.executions minos.saga.executions.commit minos.saga.executions.executors minos.saga.executions.executors.abc minos.saga.executions.executors.local minos.saga.executions.executors.request minos.saga.executions.executors.response minos.saga.executions.saga minos.saga.executions.status minos.saga.executions.steps minos.saga.executions.steps.abc minos.saga.executions.steps.conditional minos.saga.executions.steps.local minos.saga.executions.steps.remote minos.saga.executions.storage minos.saga.manager minos.saga.messages minos.saga.middleware minos.saga.services minos.saga.utils MultipleElseThenException MultipleOnErrorException MultipleOnExecuteException MultipleOnFailureException MultipleOnSuccessException

O

ok (minos.saga.messages.SagaResponse property) on_error() (minos.saga.definitions.steps.remote.RemoteSagaStep method) on_execute() (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method)

on_failure() (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method) on_success() (minos.saga.definitions.steps.remote.RemoteSagaStep method)

P

parameterized (minos.saga.definitions.operations.SagaOperation property) Paused (minos.saga.executions.status.SagaStatus attribute) PausedByOnExecute (minos.saga.executions.status.SagaStepStatus attribute)

PausedOnFailure (minos.saga.executions.status.SagaStepStatus attribute) pop() (minos.saga.context.SagaContext method) popitem() (minos.saga.context.SagaContext method)

R

raw (minos.saga.definitions.operations.SagaOperation property) (minos.saga.definitions.saga.Saga property) (minos.saga.definitions.steps.abc.SagaStep property) (minos.saga.definitions.steps.conditional.ConditionalSagaStep property) (minos.saga.definitions.steps.conditional.ElseThenAlternative property) (minos.saga.definitions.steps.conditional.IfThenAlternative property) (minos.saga.definitions.steps.local.LocalSagaStep property) (minos.saga.definitions.steps.remote.RemoteSagaStep property) (minos.saga.executions.saga.SagaExecution property) (minos.saga.executions.status.SagaStatus property) (minos.saga.executions.status.SagaStepStatus property) (minos.saga.executions.steps.abc.SagaStepExecution property) (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution property) (minos.saga.executions.steps.local.LocalSagaStepExecution property) (minos.saga.executions.steps.remote.RemoteSagaStepExecution property) reject() (minos.saga.executions.commit.TransactionCommitter method) (minos.saga.executions.saga.SagaExecution method) related_services (minos.saga.messages.SagaResponse property) remote_step() (minos.saga.definitions.saga.Saga method) (minos.saga.definitions.steps.abc.SagaStep method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method)

RemoteSagaStep (class in minos.saga.definitions.steps.remote) RemoteSagaStepExecution (class in minos.saga.executions.steps.remote) RequestExecutor (class in minos.saga.executions.executors.request) ResponseExecutor (class in minos.saga.executions.executors.response) rollback() (minos.saga.executions.saga.SagaExecution method) (minos.saga.executions.steps.abc.SagaStepExecution method) (minos.saga.executions.steps.conditional.ConditionalSagaStepExecution method) (minos.saga.executions.steps.local.LocalSagaStepExecution method) (minos.saga.executions.steps.remote.RemoteSagaStepExecution method) run() (minos.saga.manager.SagaManager method) Running (minos.saga.executions.status.SagaStatus attribute) RunningOnError (minos.saga.executions.status.SagaStepStatus attribute) RunningOnExecute (minos.saga.executions.status.SagaStepStatus attribute) RunningOnFailure (minos.saga.executions.status.SagaStepStatus attribute) RunningOnSuccess (minos.saga.executions.status.SagaStepStatus attribute)

S

Saga (class in minos.saga.definitions.saga) SagaContext (class in minos.saga.context) SagaException SagaExecution (class in minos.saga.executions.saga) SagaExecutionAlreadyExecutedException SagaExecutionException SagaExecutionNotFoundException SagaExecutionStorage (class in minos.saga.executions.storage) SagaFailedCommitCallbackException SagaFailedExecutionException SagaFailedExecutionStepException SagaManager (class in minos.saga.manager) SagaNotCommittedException SagaNotDefinedException SagaOperation (class in minos.saga.definitions.operations) SagaPausedExecutionStepException SagaRequest (class in minos.saga.messages) SagaResponse (class in minos.saga.messages) SagaResponseException SagaResponseStatus (class in minos.saga.messages)

SagaRollbackExecutionException SagaRollbackExecutionStepException SagaService (class in minos.saga.services) SagaStatus (class in minos.saga.executions.status) SagaStep (class in minos.saga.definitions.steps.abc) SagaStepException SagaStepExecution (class in minos.saga.executions.steps.abc) SagaStepExecutionException SagaStepStatus (class in minos.saga.executions.status) setdefault() (minos.saga.context.SagaContext method) setup() (minos.saga.manager.SagaManager method) status (minos.saga.messages.SagaResponse property) step() (minos.saga.definitions.saga.Saga method) (minos.saga.definitions.steps.abc.SagaStep method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method) store() (minos.saga.executions.storage.SagaExecutionStorage method) SUCCESS (minos.saga.messages.SagaResponseStatus attribute) SYSTEM_ERROR (minos.saga.messages.SagaResponseStatus attribute)

T

target (minos.saga.messages.SagaRequest property) to_avro_bytes() (minos.saga.context.SagaContext class method) to_avro_str() (minos.saga.context.SagaContext class method) transactional_command() (in module minos.saga.middleware)

TransactionCommitter (class in minos.saga.executions.commit) transactions (minos.saga.executions.commit.TransactionCommitter attribute) type_hints (minos.saga.context.SagaContext attribute) type_hints_parameters (minos.saga.context.SagaContext attribute)

U

UndefinedOnExecuteException

update() (minos.saga.context.SagaContext method) uuid (minos.saga.messages.SagaResponse property)

V

validate() (minos.saga.definitions.saga.Saga method) (minos.saga.definitions.steps.abc.SagaStep method) (minos.saga.definitions.steps.conditional.ConditionalSagaStep method) (minos.saga.definitions.steps.conditional.ElseThenAlternative method) (minos.saga.definitions.steps.conditional.IfThenAlternative method) (minos.saga.definitions.steps.local.LocalSagaStep method) (minos.saga.definitions.steps.remote.RemoteSagaStep method)

values() (minos.saga.context.SagaContext method)

W

with_traceback() (minos.saga.exceptions.AlreadyCommittedException method) (minos.saga.exceptions.AlreadyOnSagaException method) (minos.saga.exceptions.EmptySagaException method) (minos.saga.exceptions.EmptySagaStepException method) (minos.saga.exceptions.ExecutorException method) (minos.saga.exceptions.MultipleElseThenException method) (minos.saga.exceptions.MultipleOnErrorException method) (minos.saga.exceptions.MultipleOnExecuteException method) (minos.saga.exceptions.MultipleOnFailureException method) (minos.saga.exceptions.MultipleOnSuccessException method) (minos.saga.exceptions.SagaException method) (minos.saga.exceptions.SagaExecutionAlreadyExecutedException method) (minos.saga.exceptions.SagaExecutionException method) (minos.saga.exceptions.SagaExecutionNotFoundException method) (minos.saga.exceptions.SagaFailedCommitCallbackException method) (minos.saga.exceptions.SagaFailedExecutionException method) (minos.saga.exceptions.SagaFailedExecutionStepException method) (minos.saga.exceptions.SagaNotCommittedException method) (minos.saga.exceptions.SagaNotDefinedException method) (minos.saga.exceptions.SagaPausedExecutionStepException method) (minos.saga.exceptions.SagaResponseException method) (minos.saga.exceptions.SagaRollbackExecutionException method) (minos.saga.exceptions.SagaRollbackExecutionStepException method) (minos.saga.exceptions.SagaStepException method) (minos.saga.exceptions.SagaStepExecutionException method) (minos.saga.exceptions.UndefinedOnExecuteException method)