diff --git a/pkg/manager/lifecycle.go b/pkg/manager/lifecycle.go index 73cb073..cc147df 100644 --- a/pkg/manager/lifecycle.go +++ b/pkg/manager/lifecycle.go @@ -23,8 +23,8 @@ type lifecycleManager struct { shutdownOnce sync.Once } -// NewLifecycleManager creates a new lifecycle manager. -func NewLifecycleManager( +// newLifecycleManager creates a new lifecycle manager. +func newLifecycleManager( registry *instanceRegistry, manager InstanceManager, checkInterval time.Duration, diff --git a/pkg/manager/manager.go b/pkg/manager/manager.go index 551b1dd..e2c39de 100644 --- a/pkg/manager/manager.go +++ b/pkg/manager/manager.go @@ -52,23 +52,23 @@ func New(backendsConfig config.BackendConfig, instancesConfig config.InstancesCo } // Initialize components - registry := NewInstanceRegistry() + registry := newInstanceRegistry() // Initialize port allocator portRange := instancesConfig.PortRange - ports, err := NewPortAllocator(portRange[0], portRange[1]) + ports, err := newPortAllocator(portRange[0], portRange[1]) if err != nil { log.Fatalf("Failed to create port allocator: %v", err) } // Initialize persistence - persistence, err := NewInstancePersister(instancesConfig.InstancesDir) + persistence, err := newInstancePersister(instancesConfig.InstancesDir) if err != nil { log.Fatalf("Failed to create instance persister: %v", err) } // Initialize remote manager - remote := NewRemoteManager(nodesConfig, 30*time.Second) + remote := newRemoteManager(nodesConfig, 30*time.Second) // Create manager instance im := &instanceManager{ @@ -83,7 +83,7 @@ func New(backendsConfig config.BackendConfig, instancesConfig config.InstancesCo // Initialize lifecycle manager (needs reference to manager for Stop/Evict operations) checkInterval := time.Duration(instancesConfig.TimeoutCheckInterval) * time.Minute - im.lifecycle = NewLifecycleManager(registry, im, checkInterval, true) + im.lifecycle = newLifecycleManager(registry, im, checkInterval, true) // Load existing instances from disk if err := im.loadInstances(); err != nil { diff --git a/pkg/manager/persistence.go b/pkg/manager/persistence.go index 21f4588..e9f2238 100644 --- a/pkg/manager/persistence.go +++ b/pkg/manager/persistence.go @@ -18,9 +18,9 @@ type instancePersister struct { enabled bool } -// NewInstancePersister creates a new instance persister. +// newInstancePersister creates a new instance persister. // If instancesDir is empty, persistence is disabled. -func NewInstancePersister(instancesDir string) (*instancePersister, error) { +func newInstancePersister(instancesDir string) (*instancePersister, error) { if instancesDir == "" { return &instancePersister{ enabled: false, diff --git a/pkg/manager/ports.go b/pkg/manager/ports.go index c5aac3e..18a3787 100644 --- a/pkg/manager/ports.go +++ b/pkg/manager/ports.go @@ -23,9 +23,9 @@ type portAllocator struct { rangeSize int } -// NewPortAllocator creates a new port allocator for the given port range. +// newPortAllocator creates a new port allocator for the given port range. // Returns an error if the port range is invalid. -func NewPortAllocator(minPort, maxPort int) (*portAllocator, error) { +func newPortAllocator(minPort, maxPort int) (*portAllocator, error) { if minPort <= 0 || maxPort <= 0 { return nil, fmt.Errorf("invalid port range: min=%d, max=%d (must be > 0)", minPort, maxPort) } diff --git a/pkg/manager/registry.go b/pkg/manager/registry.go index c8758f9..f0fd797 100644 --- a/pkg/manager/registry.go +++ b/pkg/manager/registry.go @@ -14,8 +14,8 @@ type instanceRegistry struct { running sync.Map // map[string]struct{} - lock-free for status checks } -// NewInstanceRegistry creates a new instance registry. -func NewInstanceRegistry() *instanceRegistry { +// newInstanceRegistry creates a new instance registry. +func newInstanceRegistry() *instanceRegistry { return &instanceRegistry{ instances: make(map[string]*instance.Instance), } diff --git a/pkg/manager/remote.go b/pkg/manager/remote.go index 50d2463..f149fa9 100644 --- a/pkg/manager/remote.go +++ b/pkg/manager/remote.go @@ -23,8 +23,8 @@ type remoteManager struct { instanceToNode map[string]*config.NodeConfig // instance name -> node config } -// NewRemoteManager creates a new remote manager. -func NewRemoteManager(nodes map[string]config.NodeConfig, timeout time.Duration) *remoteManager { +// newRemoteManager creates a new remote manager. +func newRemoteManager(nodes map[string]config.NodeConfig, timeout time.Duration) *remoteManager { if timeout <= 0 { timeout = 30 * time.Second }