ipampool

Documentation

Index

• Constants
• func CalculateMaxFreeIPs(scaler v1alpha.Scaler) int
• func CalculateMinFreeIPs(scaler v1alpha.Scaler) int
• type Monitor
  • func NewMonitor(httpService cns.HTTPService, nnccli nodeNetworkConfigSpecUpdater, ...) *Monitor
  • func (pm *Monitor) GetStateSnapshot() cns.IpamPoolMonitorStateSnapshot
  • func (pm *Monitor) Start(ctx context.Context) error
  • func (pm *Monitor) Update(nnc *v1alpha.NodeNetworkConfig)
• type Options

Constants

const (
	// DefaultRefreshDelay pool monitor poll delay default in seconds.
	DefaultRefreshDelay = 1 * time.Second
	// DefaultMaxIPs default maximum allocatable IPs
	DefaultMaxIPs = 250
)

Functions

func CalculateMaxFreeIPs

func CalculateMaxFreeIPs(scaler v1alpha.Scaler) int

CalculateMaxFreeIPs calculates the maximum free IP quantity based on the Scaler in the passed NodeNetworkConfig.

func CalculateMinFreeIPs

func CalculateMinFreeIPs(scaler v1alpha.Scaler) int

CalculateMinFreeIPs calculates the minimum free IP quantity based on the Scaler in the passed NodeNetworkConfig.

Types

type Monitor

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

func NewMonitor

func NewMonitor(httpService cns.HTTPService, nnccli nodeNetworkConfigSpecUpdater, opts *Options) *Monitor

func (*Monitor) GetStateSnapshot

func (pm *Monitor) GetStateSnapshot() cns.IpamPoolMonitorStateSnapshot

GetStateSnapshot gets a snapshot of the IPAMPoolMonitor struct.

func (*Monitor) Start

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

func (*Monitor) Update

func (pm *Monitor) Update(nnc *v1alpha.NodeNetworkConfig)

Update ingests a NodeNetworkConfig, clamping some values to ensure they are legal and then pushing it to the Monitor's source channel.

type Options

type Options struct {
	RefreshDelay time.Duration
	MaxIPs       int
}