Struct OrgReservedPool

controlplane/org_reserved_pool.go:17–31

OrgReservedPool presents one org's reserved slice of a shared K8s pool. It preserves the existing WorkerPool contract for SessionManager while ensuring workers are reserved to a single org for their lifetime and retired after use.

// It preserves the existing WorkerPool contract for SessionManager while ensuring
// workers are reserved to a single org for their lifetime and retired after use.
type OrgReservedPool struct {
	shared                 *K8sWorkerPool
	orgID                  string
	maxWorkers             int
	image                  string
	stsBroker              *STSBroker
	activateReservedWorker func(context.Context, *ManagedWorker) error
	// gate serializes the slow path's short DECISION section (re-check idle
	// reuse → hot-idle claim → spawning-slot creation; see acquireDecision) in
	// FIFO arrival order, so the next worker to become available goes to the
	// earliest waiting connection and a later one cannot snatch it. The
	// multi-minute spawn+activate runs OUTSIDE the gate, 1:1 bound to the
	// waiter that owns the claim, so a cold burst ramps spawns in parallel.
	gate *orgAcquireGate
}

func NewOrgReservedPool(shared *K8sWorkerPool, orgID string, maxWorkers int, image string, stsBroker *STSBroker) *OrgReservedPool {
	pool := &OrgReservedPool{