Versions in this module Expand all Collapse all v0 v0.4.0 Sep 2, 2026 v0.3.0 Sep 1, 2026 Changes in this version + type ClaimOptions struct + LeaseDuration time.Duration + Now time.Time + Owner string + TargetDispatchID string + type Completion struct + Attempt uint64 + DispatchID string + Error string + Exhausted bool + LeaseToken string + NextAttemptAt time.Time + Now time.Time + Outcome invocation.OutcomeClass + Result json.RawMessage + type CreateSagaRequest struct + AllowUnstableIdentityForTest bool + ExecutionID string + Namespace string + PlanDigest string + PlanID string + SagaID string + Serial bool + type Dispatch struct + ArgumentHash string + Arguments json.RawMessage + Attempt uint64 + ContractHash string + CreatedAt time.Time + Direction invocation.Direction + EffectID string + Fencing []FencingRequirement + FencingGrants []invocation.FencingGrant + ID string + IdempotencyKey string + LastError string + LastOutcome invocation.OutcomeClass + LeaseDeadline time.Time + LeaseOwner string + LeaseToken string + NextAttemptAt time.Time + Result json.RawMessage + Revision uint64 + SagaID string + Sequence int + State DispatchState + UpdatedAt time.Time + Verb string + type DispatchAttempt struct + Attempt uint64 + CompletedAt time.Time + DispatchID string + Error string + FencingGrants []invocation.FencingGrant + LeaseDeadline time.Time + LeaseOwner string + LeaseToken string + Outcome invocation.OutcomeClass + StartedAt time.Time + type DispatchState string + const DispatchBlockedFence + const DispatchBlockedUnknown + const DispatchFailedPermanent + const DispatchInFlight + const DispatchQueued + const DispatchRetryWait + const DispatchSucceeded + type EnqueueStepRequest struct + Arguments map[string]any + CompensationArguments map[string]any + CompensationContract string + CompensationVerb string + ContractHash string + EffectID string + Fencing []FencingRequirement + SagaID string + Sequence int + Verb string + type FencingRequirement struct + Authority string + Resource string + type OutboxStore interface + ClaimDispatch func(context.Context, ClaimOptions) (*Dispatch, error) + CompleteDispatch func(context.Context, Completion) error + CompleteSaga func(context.Context, string) error + CreateSaga func(context.Context, CreateSagaRequest) (*SagaInstance, error) + EnqueueStep func(context.Context, EnqueueStepRequest) (*Dispatch, error) + GetDispatch func(context.Context, string) (*Dispatch, error) + GetSaga func(context.Context, string) (*SagaInstance, error) + ListAttempts func(context.Context, string) ([]DispatchAttempt, error) + ListDispatches func(context.Context, string) ([]*Dispatch, error) + SaveFencingGrants func(context.Context, string, uint64, string, []invocation.FencingGrant) error + type SagaInstance struct + CreatedAt time.Time + ExecutionID string + Namespace string + PlanDigest string + PlanID string + Revision uint64 + SagaID string + Serial bool + State SagaState + UpdatedAt time.Time + type SagaState string + const SagaBlockedCompensation + const SagaBlockedDependency + const SagaBlockedFence + const SagaBlockedUnknown + const SagaCompensated + const SagaCompensating + const SagaCompleted + const SagaFailed + const SagaRunning + type SagaStep struct + ArgumentHash string + Arguments json.RawMessage + CompensationArgumentHash string + CompensationArguments json.RawMessage + CompensationContract string + CompensationVerb string + ContractHash string + EffectID string + Fencing []FencingRequirement + Result json.RawMessage + SagaID string + Sequence int + State StepState + Verb string + type StepState string + const StepCompensated + const StepFailed + const StepPending + const StepSucceeded + type UnknownOutcomeRetryPolicy interface + RetryUnknownOutcome func(invocation.Request) bool
Go to main page