orchestrator

package

v0.0.0-...-d4b30b0 Latest Latest Go to latest Published: Apr 20, 2025 License: MIT Imports: 4 Imported by: 0

Documentation ¶

This section is empty.

View Source

var ErrWorkflowNotBuilt = errors.New("workflow not built")

This section is empty.

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

func NewOrchestrator(logger *slog.Logger, steps ...flow.AddStep[Step]) *Orchestrator

func (o *Orchestrator) Build()

func (o *Orchestrator) Run(ctx context.Context) error

type Step interface {
	Do(context.Context) error
	Name() string
}