sec

type Orchestrator[T any] interface {
	Start(ctx context.Context, id string, data T) error
	ReplyTopic() string
	HandleReply(ctx context.Context, reply ddd.Reply) error
}

type Saga[T any] interface {
	AddStep() SagaStep[T]
	Name() string
	ReplyTopic() string
	// contains filtered or unexported methods
}

type SagaContext[T any] struct {
	ID           string
	Data         T
	Step         int
	Done         bool
	Compensating bool
}

type SagaRepository[T any] struct {
	// contains filtered or unexported fields
}

type SagaStep[T any] interface {
	Action(fn StepActionFunc[T]) SagaStep[T]
	Compensation(fn StepActionFunc[T]) SagaStep[T]
	OnActionReply(replyName string, fn StepReplyHandlerFunc[T]) SagaStep[T]
	OnCompensationReply(replyName string, fn StepReplyHandlerFunc[T]) SagaStep[T]
	// contains filtered or unexported methods
}

type SagaStore interface {
	Load(ctx context.Context, sagaName, sagaID string) (*SagaContext[[]byte], error)
	Save(ctx context.Context, sagaName string, sagaCtx *SagaContext[[]byte]) error
}

type StepActionFunc[T any] func(ctx context.Context, data T) (string, ddd.Command, error)

type StepOption[T any] func(step *sagaStep[T])

type StepReplyHandlerFunc[T any] func(ctx context.Context, data T, reply ddd.Reply) error