Help us shape the future of Go! Take the 2026 Go Developer Survey

v2

package
v1.7.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// DefaultMaxIPs default maximum allocatable IPs on a k8s Node.
	DefaultMaxIPs = 250
)

Variables

This section is empty.

Functions

func PodIPDemandListener

func PodIPDemandListener(ch chan<- int) func([]v1.Pod)

Types

type Monitor

type Monitor struct {
	// contains filtered or unexported fields
}

func NewMonitor

func NewMonitor(z *zap.Logger, store ipStateStore, nnccli nodeNetworkConfigSpecUpdater, demandSource <-chan int, nncSource <-chan v1alpha.NodeNetworkConfig, cssSource <-chan v1alpha1.ClusterSubnetState) *Monitor

func (*Monitor) AsV1

func (m *Monitor) AsV1(nncSink chan<- v1alpha.NodeNetworkConfig) cns.IPAMPoolMonitor

func (*Monitor) Start

func (pm *Monitor) Start(ctx context.Context) error

Start begins the Monitor's pool reconcile loop. On first run, it will block until a NodeNetworkConfig is received (through a call to Update()). Subsequently, it will run run when Events happen or at least once per ReconcileDelay and attempt to re-reconcile the pool.

func (*Monitor) WithLegacyMetricsObserver

func (pm *Monitor) WithLegacyMetricsObserver(observer func(context.Context) error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL