Interface ConfigStoreInterface

controlplane/control.go:221–251

ConfigStoreInterface abstracts the config store for the control plane. Defined here to avoid circular imports with the configstore package.

// PostgreSQL wire protocol, and SQL transpilation all happen here. Workers are
// thin DuckDB execution engines reachable via Arrow Flight SQL over Unix sockets.
type ControlPlane struct {
	cfg             ControlPlaneConfig
	pool            WorkerPool      // non-nil in single-tenant process mode
	sessions        *SessionManager // non-nil in single-tenant process mode
	rebalancer      *MemoryRebalancer
	srv             *server.Server // Minimal server for cancel request routing
	rateLimiter     *server.RateLimiter
	tlsConfig       *tls.Config
	pgListener      net.Listener
	upgrader        *tableflip.Upgrader
	parentPID       int // tableflip parent PID (0 if first generation)
	activeConns     int64
	closed          bool
	closeMu         sync.Mutex
	wg              sync.WaitGroup
	reloading       atomic.Bool            // guards against concurrent upgrade from double SIGUSR1
	upgradeDraining atomic.Bool            // true after upgrade succeeded; SIGTERM should exit immediately
	sessionDraining atomic.Bool            // true once any shutdown path closes session creation
	preReady        sessionLifecycle       // authenticated pgwire handshakes not yet handed to the message loop
	acmeManager     *server.ACMEManager    // ACME manager for Let's Encrypt HTTP-01 (nil when using static certs)
	acmeDNSManager  *server.ACMEDNSManager // ACME manager for DNS-01 (nil when not using DNS challenges)

	// isRemoteBackend is true when workers run as separate K8s pods (remote backend).
	isRemoteBackend bool

	// Multi-tenant fields (non-nil in remote multitenant mode)
	orgRouter      OrgRouterInterface
	configStore    ConfigStoreInterface
	apiServer      *http.Server // API server on :8080 (shut down on graceful exit)
	runtimeTracker *ControlPlaneRuntimeTracker
	janitorLeader  *JanitorLeaderManager

	// computeMeter accumulates per-org compute-usage and flushes it to the
	// durable buffer (remote/k8s backend with billing config only; nil