apply

package

v0.6.0 Latest Latest Go to latest Published: Jul 29, 2026 License: MIT Imports: 3 Imported by: 0

Details

Package apply orchestrates the dotdrift pipeline with always-resume semantics.

This section is empty.

This section is empty.

This section is empty.

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

Pipeline runs a list of steps, resuming from the persisted state.

func NewPipeline(steps []Step, save func(*state.State) error) *Pipeline

NewPipeline constructs a pipeline with the given steps and a save callback.

func (p *Pipeline) Run(ctx context.Context) error

Run executes the pipeline from the first incomplete step.

func (p *Pipeline) SetState(s *state.State)

SetState sets the initial state. It should be reset for selection changes before calling.

func (p *Pipeline) State() *state.State

State returns the current pipeline state.

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

Step is a single stage in the apply pipeline.