v2

Documentation

Index

• Constants
• func PodIPDemandListener(ch chan<- int) func([]v1.Pod)
• type Monitor
  • func NewMonitor(z *zap.Logger, store ipStateStore, nnccli nodeNetworkConfigSpecUpdater, ...) *Monitor
  • func (m *Monitor) AsV1(nncSink chan<- v1alpha.NodeNetworkConfig) cns.IPAMPoolMonitor
  • func (pm *Monitor) Start(ctx context.Context) error
  • func (pm *Monitor) WithLegacyMetricsObserver(observer func(context.Context) error)

Constants

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

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)