Function ResolveEffective

configresolve/resolve.go:177–1241

ResolveEffective layers CLI inputs on top of env vars on top of YAML on top of built-in defaults to produce the runtime config every duckgres binary boots from. getenv and warn are pluggable so unit tests can run without touching os.Getenv or stderr; nil maps to no-op equivalents.

(fileCfg *configloader.FileConfig, cli CLIInputs, getenv func(string) string, warn func(string))

// top of built-in defaults to produce the runtime config every duckgres
// binary boots from. getenv and warn are pluggable so unit tests can run
// without touching os.Getenv or stderr; nil maps to no-op equivalents.
func ResolveEffective(fileCfg *configloader.FileConfig, cli CLIInputs, getenv func(string) string, warn func(string)) Resolved {
	if getenv == nil {
		getenv = func(string) string { return "" }
	}
	if warn == nil {
		warn = func(string) {}
	}
	if cli.Set == nil {
		cli.Set = map[string]bool{}
	}

	cfg := DefaultServerConfig()
	defaultQueryLog := cfg.QueryLog
	workerQueueTimeout := 60 * time.Second
	admissionReclaimerMaxReservations := controlplane.DefaultAdmissionReclaimerMaxReservations
	var workerIdleTimeout time.Duration
	var handoverDrainTimeout time.Duration
	var processMinWorkers, processMaxWorkers int
	var processRetireOnSessionEnd bool
	var workerBackend string
	// Connection-string worker-sizing config (all default to off/empty).
	var k8sAllowClientWorkerProfile bool
	var k8sWorkerProfileMinCPU, k8sWorkerProfileMaxCPU, k8sWorkerProfileMinMemory, k8sWorkerProfileMaxMemory string
	var k8sWorkerMaxTTL, k8sWorkerDefaultTTL time.Duration
	var k8sWorkerPriorityClassName string
	var k8sPlaceholderImage, k8sPlaceholderPriorityClassName string
	var k8sWorkerImage, k8sWorkerNamespace, k8sControlPlaneID string
	var k8sWorkerPort int
	var k8sWorkerSecret, k8sWorkerConfigMap, k8sWorkerImagePullPolicy string
	k8sWorkerServiceAccount := controlplane.DefaultK8sWorkerServiceAccount
	var k8sWorkerCPURequest, k8sWorkerMemoryRequest string
	var k8sWorkerNodeSelector, k8sWorkerTolerationKey, k8sWorkerTolerationValue string
	var k8sReshardPodCPU, k8sReshardPodMemory string
	var k8sExploratoryTierEnabled bool
	var k8sExploratoryWorkerCPU, k8sExploratoryWorkerMemory string
	var k8sExploratoryWorkerTTL time.Duration
	var awsRegion string
	var configStoreConn string
	var configPollInterval time.Duration
	var internalSecret string
	var internalSecretFallbacks []string
	var readOnlySecret string
	var readOnlySecretFallbacks []string
	var userSecretKey string
	var sniRoutingMode string
	var managedHostnameSuffixes []string
	var metadataHostnameSuffixes []string
	metadataProxyMaxConnections := 20
	var ducklingBucketSuffix string

	if fileCfg != nil {
		if fileCfg.Host != "" {
			cfg.Host = fileCfg.Host
		}
		if fileCfg.Port != 0 {
			cfg.Port = fileCfg.Port
		}