portallocator

Jun 11, 2025

Changes in this version

+ const RELEASE_PORT_RETRY_INTERVAL

+ var RETRY_CONFIG = wait.Backoff

Jun 3, 2025

Changes in this version

+ type PortAllocator struct

+ BitmapCluster []uint64

+ BitmapPerNode map[string][]uint64

+ Client client.Client

+ IsLeader bool

+ PortRangeEndCluster int

+ PortRangeEndNode int

+ PortRangeStartCluster int

+ PortRangeStartNode int

+ func NewPortAllocator(ctx context.Context, client client.Client, nodeLevelPortRange string, ...) (*PortAllocator, error)

+ func (s *PortAllocator) AssignClusterLevelHostPort(podName string) (int, error)

+ func (s *PortAllocator) AssignHostPort(nodeName string) (int, error)

+ func (s *PortAllocator) GetLeaderIP() string

+ func (s *PortAllocator) ReleaseClusterLevelHostPort(podName string, port int) error

+ func (s *PortAllocator) ReleaseHostPort(nodeName string, port int) error

+ func (s *PortAllocator) SetupWithManager(ctx context.Context, mgr manager.Manager) <-chan struct{}