configloader

pkg/controller/configloader

Stage-1 event adapter that turns HAProxyTemplateConfig CRD changes into internal config. Subscribes to ConfigResourceChangedEvent, runs conversion.ParseCRD on the unstructured resource, and publishes a ConfigParsedEvent with the resulting *config.Config plus the typed CRD wrapper.

This is a thin event-loop on top of pkg/controller/resourceloader.BaseLoader — same scaffold used by credentialsloader. The actual parsing lives in pkg/controller/conversion; this package just wires the event flow.

Minimal Usage

import (
    "context"

    "gitlab.com/haproxy-haptic/haptic/pkg/controller/configloader"
    "gitlab.com/haproxy-haptic/haptic/pkg/events"
)

bus := events.NewEventBus(100)
loader := configloader.NewConfigLoaderComponent(bus, logger)

bus.Start()              // release buffered events to subscribers
go loader.Start(ctx)     // then run the event loop

// Upstream: a SingleWatcher for the HAProxyTemplateConfig CRD emits
// ConfigResourceChangedEvent{Resource: *unstructured.Unstructured}.
// Downstream: pkg/controller/configchange.ConfigChangeHandler consumes
// ConfigParsedEvent, runs the scatter-gather validation, and publishes
// ConfigValidatedEvent / ConfigInvalidEvent.

Subscription happens in NewConfigLoaderComponent, before bus.Start(), so any buffered ConfigResourceChangedEvent from the watcher's initial sync is delivered once the bus is released.

Event Contract

In

type ConfigResourceChangedEvent struct {
    Resource any  // *unstructured.Unstructured pointing at the HAProxyTemplateConfig CRD
}

The resourceVersion is read off the unstructured resource by the loader itself; there's no Version field on the event.

Out — on successful parse

type ConfigParsedEvent struct {
    Config         any    // *config.Config — internal struct (any to avoid circular deps)
    TemplateConfig any    // typed CRD (metadata + spec) — used by ConfigPublisher for k8s metadata
    Version        string // CRD resourceVersion
    SecretVersion  string // always empty; ConfigChangeHandler passes it through unchanged
}

Out — on failure: nothing is published. Errors are logged with the CRD's namespace/name. A stale config stays active; the controller doesn't start a failed reinitialisation.

What It Validates

ParseCRD rejects resources that aren't haproxy-haptic.org/v1alpha1.HAProxyTemplateConfig before conversion. Everything after that (port ranges, required fields, enum values) is done by the scatter-gather validators in pkg/controller/validator, not here. configloader is intentionally small — it converts, it doesn't judge.

See Also

• pkg/controller/conversion — ParseCRD and ConvertSpec implementation
• pkg/controller/resourceloader — shared event-loop scaffold
• pkg/controller/credentialsloader — sibling loader built on the same base
• pkg/controller/configchange — orchestrator that consumes ConfigParsedEvent and runs scatter-gather validation
• pkg/controller/validator — scatter-gather validation responders
• pkg/core/config — target struct for ParseCRD's conversion

License

Apache-2.0 — see root LICENSE.