util

Documentation

Index

• Constants
• func EnvGetBool(key string, defaultValue bool) bool
• func FileExists(filename string) bool
• func GetServiceCIDRFromNode(node *corev1.Node) (string, error)
• func IsIPAddrInList(ipAddr netip.Addr, ipAddrList []netip.Addr) bool
• func IsIPInBetweenOf(ip, ip1, ip2 string) bool
• func LoadAllocated(allocated map[string]string) (allocatedList, excludedList, reservedList []netip.Addr)
• func LoadCIDR(cidr string) (ipNet *net.IPNet, networkIPAddr netip.Addr, broadcastIPAddr netip.Addr, ...)
• func SafeAgentConcatName(name ...string) string
• type PoolInfo
  • func LoadPool(ipPool *networkv1.IPPool) (pi PoolInfo, err error)
• type VmnetcfgGetter
  • func (g *VmnetcfgGetter) WhoUseIPPool(ipPool *networkv1.IPPool) ([]*networkv1.VirtualMachineNetworkConfig, error)

Constants

const (
	ExcludedMark = "EXCLUDED"
	ReservedMark = "RESERVED"

	AgentSuffixName        = "agent"
	NodeArgsAnnotationKey  = "rke2.io/node-args"
	ServiceCIDRFlag        = "--service-cidr"
	ManagementNodeLabelKey = "node-role.kubernetes.io/control-plane"
)

Functions

func EnvGetBool

func EnvGetBool(key string, defaultValue bool) bool

func FileExists

func FileExists(filename string) bool

func GetServiceCIDRFromNode

func GetServiceCIDRFromNode(node *corev1.Node) (string, error)

func IsIPAddrInList

func IsIPAddrInList(ipAddr netip.Addr, ipAddrList []netip.Addr) bool

func IsIPInBetweenOf

func IsIPInBetweenOf(ip, ip1, ip2 string) bool

func LoadAllocated

func LoadAllocated(allocated map[string]string) (allocatedList, excludedList, reservedList []netip.Addr)

LoadAllocated returns the un-allocatable IP addresses in three types of IP address lists, allocatedList, excludedList, and reservedList.

func LoadCIDR

func LoadCIDR(cidr string) (ipNet *net.IPNet, networkIPAddr netip.Addr, broadcastIPAddr netip.Addr, err error)

func SafeAgentConcatName

func SafeAgentConcatName(name ...string) string

Types

type PoolInfo

type PoolInfo struct {
	IPNet           *net.IPNet
	NetworkIPAddr   netip.Addr
	BroadcastIPAddr netip.Addr
	StartIPAddr     netip.Addr
	EndIPAddr       netip.Addr
	ServerIPAddr    netip.Addr
	RouterIPAddr    netip.Addr
}

func LoadPool

func LoadPool(ipPool *networkv1.IPPool) (pi PoolInfo, err error)

type VmnetcfgGetter

type VmnetcfgGetter struct {
	VmnetcfgCache ctlnetworkv1.VirtualMachineNetworkConfigCache
}

func (*VmnetcfgGetter) WhoUseIPPool

func (g *VmnetcfgGetter) WhoUseIPPool(ipPool *networkv1.IPPool) ([]*networkv1.VirtualMachineNetworkConfig, error)

WhoUseIPPool requires adding network indexer to the vmnetcfg cache before invoking it