engine

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

type Options struct {
	MaxParallel int
	// VolumeResolver materialises a Task's volumes onto host paths just
	// before the task runs. The CLI sets this; tests may leave it nil
	// (volumes are then unsupported in that test).
	VolumeResolver VolumeResolver
}

type PipelineInput struct {
	Bundle     *loader.Bundle
	Name       string                            // pipeline name
	Params     map[string]tektontypes.ParamValue // user-provided params
	Workspaces map[string]string                 // pipeline workspace name → host path
	RunID      string                            // optional; auto-generated if empty
}

type RunResult struct {
	Status string // succeeded | failed
	Tasks  map[string]TaskOutcome
	// Reason is the backend-supplied terminal reason. On the cluster
	// backend this is the Tekton condition reason verbatim
	// (PipelineRunTimeout, PipelineValidationFailed, Failed, …); on
	// the docker backend it's empty. Surfaced for diagnostic logging
	// only — the user-visible status enum lives in Status.
	Reason string
	// Message is the backend-supplied terminal message. Same purpose
	// as Reason — surfaced so failure logs can attribute a misclassified
	// run to a specific backend code path.
	Message string
}

type TaskOutcome struct {
	Status   string
	Message  string
	Results  map[string]string
	Attempt  int           // final attempt number (1-based); 0 = did not run
	Duration time.Duration // duration of the final attempt
}

type VolumeResolver func(taskName string, vs []tektontypes.Volume) (map[string]string, error)