workflow

package

v0.3.0 Latest Latest Go to latest Published: Jul 20, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewCompensationError(executionErr error, compensationErrs ...error) *CompensationError

func (e *CompensationError) CompensationErrors() []error

func (e *CompensationError) Error() string

func (e *CompensationError) ExecutionError() error

type Step interface {
	Execute(ctx context.Context) error
	Compensate(ctx context.Context) error
}

func StepFunc(execute func(ctx context.Context) error, compensate func(ctx context.Context) error) Step

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

func New(steps ...Step) *Workflow

func (w *Workflow) Execute(ctx context.Context) error