platform

type AnalyticsImageSet struct {
	Ingest        string
	PlatformAPI   string
	RuntimeAPI    string
	AnalyticsAPI  string
	Processor     string
	UI            string
	DoctorSmoke   string
	Traefik       string
	ClickHouse    string
	Kafka         string
	Prometheus    string
	OTelCollector string
	Tempo         string
	Loki          string
	Promtail      string
	Grafana       string
}

type ClusterManagerAPI interface {
	InitCluster(kubeconfig, context string) error
	ConfigureCluster(opts cluster.IngressOptions) error
}

type RegistryManagerAPI interface {
	ShowRegistryInfo() error
	PushInCluster(source, target, helperNS string) error
}

type SetupContext struct {
	Plan                  setupplan.Plan
	ExternalRegistry      *config.ExternalRegistryConfig
	UsingExternalRegistry bool
	RegistryAuthStaged    bool
	RegistrySecretName    string
	OperatorImage         string
	GatewayProxyImage     string
	AnalyticsImages       AnalyticsImageSet
}

type SetupDeps struct {
	ResolveExternalRegistryConfig   func(*config.ExternalRegistryConfig) (*config.ExternalRegistryConfig, error)
	ClusterManager                  ClusterManagerAPI
	RegistryManager                 RegistryManagerAPI
	LoginRegistry                   func(logger *zap.Logger, registryURL, username, password string) error
	DeployRegistry                  func(logger *zap.Logger, namespace string, port int, registryType, registryStorageSize, manifestPath string) error
	WaitForDeploymentAvailable      func(logger *zap.Logger, name, namespace, selector string, timeout time.Duration) error
	WaitForDeploymentRolledOut      func(logger *zap.Logger, name, namespace, selector string, timeout time.Duration) error
	PrintDeploymentDiagnostics      func(deploy, namespace, selector string)
	SetupTLS                        func(logger *zap.Logger, plan setupplan.Plan) error
	BuildOperatorImage              func(image string) error
	PushOperatorImage               func(image string) error
	BuildGatewayProxyImage          func(image string) error
	PushGatewayProxyImage           func(image string) error
	BuildAnalyticsImage             func(image, dockerfilePath, buildContext string) error
	PushAnalyticsImage              func(image string) error
	EnsureNamespace                 func(namespace string) error
	EnsureCatalogNamespace          func(namespace string, labels map[string]string) error
	ResolvePlatformRegistryURL      func(logger *zap.Logger) string
	PushOperatorImageToInternal     func(logger *zap.Logger, sourceImage, targetImage, helperNamespace string) error
	PushGatewayProxyImageToInternal func(logger *zap.Logger, sourceImage, targetImage, helperNamespace string) error
	PushAnalyticsImageToInternal    func(logger *zap.Logger, sourceImage, targetImage, helperNamespace string) error
	DeployOperatorManifests         func(logger *zap.Logger, operatorImage, gatewayProxyImage string, operatorArgs []string, imagePullSecretName string) error
	DeployAnalyticsManifests        func(logger *zap.Logger, images AnalyticsImageSet, storageMode, platformMode string) error
	EnsureImagePullSecret           func(namespace, name, registry, username, password string) error
	DisableRegistryIngressAuth      func() error
	EnableRegistryIngressAuth       func() error
	ConfigureProvisionedRegistryEnv func(ext *config.ExternalRegistryConfig, secretName string) error
	RestartDeployment               func(name, namespace string) error
	CheckCRDInstalled               func(name string) error
	GetDeploymentTimeout            func() time.Duration
	GetRegistryPort                 func() int
	OperatorImageFor                func(ext *config.ExternalRegistryConfig) string
	GatewayProxyImageFor            func(ext *config.ExternalRegistryConfig) string
	// StampPlatformVersion records the installed platform version on platform
	// Deployment metadata after a successful setup. Nil skips stamping (tests).
	StampPlatformVersion func(version string) error
	// RunPostSetupSmoke runs a short operational gate after registry/operator/CRD
	// checks. Nil skips the smoke (tests); production defaults fail setup when
	// nodes, Postgres, platform-api, Sentinel rollouts, or auth probes are bad.
	RunPostSetupSmoke func() error
}

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

type SetupStep interface {
	Name() string
	Run(logger *zap.Logger, deps SetupDeps, ctx *SetupContext) error
}