pipeline

type Hook interface {
	// OnStepStart is called before a step executes.
	OnStepStart(ctx context.Context, step Step, state *State)

	// OnStepError is called if a step returns an error.
	OnStepError(ctx context.Context, step Step, state *State, err error)

	// OnStepComplete is called after a step successfully executes.
	OnStepComplete(ctx context.Context, step Step, state *State)
}

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

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

type Step interface {
	// Name returns the name of the step for logging and debugging.
	Name() string

	// Execute performs the step's operation, reading from and writing to the State.
	Execute(ctx context.Context, state *State) error
}