sagas

type CompensationFixture struct {
	// contains filtered or unexported fields
}

type Saga interface {
	// Name returns the saga's unique identifier.
	Name() string

	// HandleEvent processes an event and returns commands to dispatch.
	HandleEvent(ctx context.Context, event mink.StoredEvent) ([]mink.Command, error)

	// IsComplete returns true if the saga has completed.
	IsComplete() bool

	// State returns the current saga state.
	State() interface{}
}

type SagaCompensator interface {
	GetCompensationCommands() []mink.Command
}

type SagaState string

type SagaStateMachineFixture struct {
	// contains filtered or unexported fields
}

type SagaTestFixture struct {
	// contains filtered or unexported fields
}

type SagaWithTimeout interface {
	Saga
	OnTimeout(ctx context.Context) ([]mink.Command, error)
}

type StateTransition struct {
	From    SagaState
	To      SagaState
	Event   string
	Command string
}

type TB = testing.TB

type TimeoutFixture struct {
	// contains filtered or unexported fields
}