pipeline

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

type PipelineConfig struct {
	// Renderer is the render service for generating configuration.
	Renderer *renderer.RenderService

	// Validator is the validation service for checking configuration. Nil
	// makes the pipeline render-only: the reconcile instance leaves HAProxy's
	// verdict to the asynchronous render gate (ADR-0022), while the proposal
	// instance keeps the synchronous check admission answers with.
	Validator *validation.ValidationService

	// OutputValidator optionally validates rendered auxiliary formats.
	OutputValidator RenderedOutputValidator

	// CommitValidator gates accepting external content no previous render
	// used. The reconcile pipeline has no Validator, but a render that pulls in
	// new HTTP-store content is the moment that content becomes the store's
	// accepted version — so it takes the full synchronous check before the
	// commit, not the gate's later verdict. Renders that accept nothing new
	// never reach it, which is every render in a steady state.
	CommitValidator *validation.ValidationService

	// Logger is the structured logger for logging.
	Logger *slog.Logger
}

type PipelineError struct {
	// Phase identifies which pipeline phase failed.
	Phase PipelinePhase

	// ValidationPhase is set when Phase is PhaseValidation.
	// It contains the specific validation sub-phase (syntax, schema, semantic).
	ValidationPhase string

	// Cause is the underlying error.
	Cause error
}

type PipelinePhase string

type PipelineResult struct {
	// HTTPObservations can confirm only the accepted versions read by this execution.
	HTTPObservations []httpstore.ObservationToken

	// CycleSnapshot binds the output and every effect from this render.
	CycleSnapshot *rendercycle.Snapshot

	// OutputSnapshot binds the exact config, plan, and auxiliary artifacts.
	OutputSnapshot *renderoutput.Snapshot

	// HAProxyConfig is the rendered HAProxy configuration.
	HAProxyConfig string

	// AuxiliaryFiles contains all rendered auxiliary files.
	// Production results leave it nil and use AuxiliaryFileSnapshot.
	AuxiliaryFiles *dataplane.AuxiliaryFiles

	// AuxiliaryFileSnapshot is the authenticated immutable production representation.
	AuxiliaryFileSnapshot *renderartifact.Snapshot

	// Plan is the structure this render declared: its sections, backends, map
	// entries and file set. Nil when the renderer produced none.
	Plan *renderplan.Plan

	// PlanID is the digest identifying Plan.
	PlanID string

	// StatusPatches is the detached compatibility representation.
	// Production renders leave it nil and use StatusPatchSnapshot.
	StatusPatches []templating.StatusPatch

	// StatusPatchSnapshot is the authenticated immutable production representation.
	StatusPatchSnapshot *templating.StatusPatchSnapshot

	// Events contains Kubernetes Events templates asked to emit via recordEvent()
	// (e.g. a RouteConflict Warning on an Ingress). Forwarded to the EventEmitter.
	// Production renders leave it nil and use EventSnapshot.
	Events []templating.RenderedEvent

	// EventSnapshot is the authenticated immutable production representation.
	EventSnapshot *templating.RenderedEventSnapshot

	// RenderedResources contains full Kubernetes resources the templates declared
	// the controller should own and reconcile (e.g. an auxiliary Service or other
	// object a template emits alongside the HAProxy config).
	// Production renders leave it nil and use RenderedResourceSnapshot.
	RenderedResources []templating.RenderedResource

	// RenderedResourceSnapshot is the authenticated immutable production representation.
	RenderedResourceSnapshot *templating.RenderedResourceSnapshot

	// AuxFileCount is the total number of auxiliary files.
	AuxFileCount int

	// ContentChecksum is the pre-computed content checksum covering config + aux files.
	// Computed once in the pipeline and propagated through events to downstream consumers,
	// eliminating redundant hashing across validation, publishing, and deployment.
	ContentChecksum string

	// RenderDurationMs is the rendering duration in milliseconds.
	RenderDurationMs int64

	// CacheState is "warm" when the render had a graph to build on, "cold" when it
	// re-evaluated everything, and "replay" when it reused the previous output.
	CacheState string

	// CacheBuildMs is what the most recent completed cache build cost, 0 while none
	// has completed.
	CacheBuildMs int64

	// ValidateDurationMs is the validation duration in milliseconds.
	ValidateDurationMs int64

	// TotalDurationMs is the total pipeline duration in milliseconds.
	TotalDurationMs int64

	// ValidationPhase indicates which validation phase completed last.
	// Empty string means all phases passed.
	ValidationPhase string

	// ValidationWarnings contains non-fatal diagnostics produced after render.
	ValidationWarnings []string
}

type RenderedOutputValidator interface {
	ValidateRenderedOutput(ctx context.Context, result *PipelineResult) (warnings []string, err error)
}