operator

type CapiHook struct {
	Paths  *config.Paths
	Runner execx.Runner
	Stdout io.Writer
	Stderr io.Writer

	// TemplateDir is the CAPI template tree (bash: ${HOOK_DIR}/capi-templates;
	// Env.CapiTemplateDir in the CLI).
	TemplateDir string
	// contains filtered or unexported fields
}

type CapiStatusSyncHook struct {
	Paths  *config.Paths
	Runner execx.Runner
	Stdout io.Writer
	Stderr io.Writer

	// GitopsBootstrap is gitops::bootstrap (gitops.BootstrapHook in the
	// CLI). nil = the lib is not loaded: the bash `declare -f` probe then
	// skips BOTH the bootstrap and the gitops status patch.
	GitopsBootstrap func(ctx context.Context, domain, provider string) error
	// DeployApply is deploy::apply (deploy.Deployer.Apply in the CLI). nil =
	// not loaded → probed away, like the bash.
	DeployApply func(ctx context.Context, domain string) error
}

type Env struct {
	// HookDir is the hook tree (bash: RUNTIME_DIR / HOOK_DIR → PATH_LOK8S).
	HookDir string
	// StateDir is the reconcile state volume (bash: LOK8S_STATE_DIR →
	// PATH_BASE).
	StateDir string
	// KustomizePluginHome is KUSTOMIZE_PLUGIN_HOME (defaulted, never
	// overridden when set).
	KustomizePluginHome string
}

type Event struct {
	// Type is the event type: "Synchronization", "Schedule", "Event" — the
	// bash read `.type // "Event"`, so a missing type is an Event.
	Type string `json:"type"`
	// Binding is the binding name (schedule bindings carry it).
	Binding string `json:"binding"`
	// Object is the watched object (after the jqFilter, for kubernetes
	// bindings).
	Object json.RawMessage `json:"object"`
	// FilterResult is the jqFilter's output (capi-status-sync reads it).
	FilterResult json.RawMessage `json:"filterResult"`
}

type ExitError struct{ Code int }

type Hook interface {
	// Config is the `--config` output (hook::config).
	Config() string
	// Trigger handles one binding-context batch (hook::trigger).
	Trigger(ctx context.Context, events []Event) error
}

type LoHook struct {
	Paths  *config.Paths
	Runner execx.Runner
	Stdout io.Writer
	Stderr io.Writer

	// Drivers overrides the driver lookup (nil → driver.Get). The bash
	// sourced drivers/lo/main unconditionally — the hook is the Lo
	// reconciler, so the kind is fixed: "lo".
	Drivers func(name string) (driver.Factory, bool)

	// BootstrapApply is bootstrap::apply (bootstrap.ApplyHook in the CLI).
	// nil = the lib is not loaded: the bash `driver::provision &&
	// bootstrap::apply` then fails on "command not found" and the CR lands
	// in ProvisionFailed — same here.
	BootstrapApply func(ctx context.Context, domain, clusterYAML, kubeconfig string) error
	// contains filtered or unexported fields
}