utils

Documentation

Index

• Constants
• func EnsureSysctlValue(name, value string) error
• func IsVlanNad(nad *nadv1.NetworkAttachmentDefinition) bool
• func Name(prefix string, s ...string) string
• func NewSelector(selector map[string]string) (labels.Selector, error)
• type Connectivity
• type Layer3NetworkConf
  • func NewLayer3NetworkConf(conf string) (*Layer3NetworkConf, error)
  • func (c *Layer3NetworkConf) ToString() (string, error)
• type Mode
• type NadSelectedNetworks
  • func NewNADSelectedNetworks(conf string) (NadSelectedNetworks, error)
  • func (n NadSelectedNetworks) ToString() (string, error)
• type NetConf
• type NetworkType
• type VmiGetter
  • func (v *VmiGetter) WhoUseNad(nad *nadv1.NetworkAttachmentDefinition, nodesFilter mapset.Set[string]) ([]*kubevirtv1.VirtualMachineInstance, error)

Constants

const (
	KeyVlanLabel = network.GroupName + "/vlan-id"
	// KeyLastVlanLabel is used to record the last VLAN id to support changing the VLAN id of the VLAN networks
	KeyLastVlanLabel       = network.GroupName + "/last-vlan-id"
	KeyVlanConfigLabel     = network.GroupName + "/vlanconfig"
	KeyClusterNetworkLabel = network.GroupName + "/clusternetwork"
	// KeyLastClusterNetworkLabel is used to record the last cluster network to support changing the cluster network of NADs
	KeyLastClusterNetworkLabel = network.GroupName + "/last-clusternetwork"
	KeyNodeLabel               = network.GroupName + "/node"
	KeyNetworkType             = network.GroupName + "/type"
	KeyLastNetworkType         = network.GroupName + "/last-type"
	KeyNetworkReady            = network.GroupName + "/ready"
	KeyNetworkRoute            = network.GroupName + "/route"

	KeyMatchedNodes = network.GroupName + "/matched-nodes"

	ValueTrue  = "true"
	ValueFalse = "false"

	CloudweavWitnessNodeLabelKey = "node-role.cloudweavhci.io/witness"
)

const ManagementClusterNetworkName = "mgmt"

Functions

func EnsureSysctlValue

func EnsureSysctlValue(name, value string) error

func IsVlanNad

func IsVlanNad(nad *nadv1.NetworkAttachmentDefinition) bool

func Name

func Name(prefix string, s ...string) string

Name function joints prefix with all other strings and crc32 checksum

func NewSelector

func NewSelector(selector map[string]string) (labels.Selector, error)

Types

type Connectivity

type Connectivity string

const (
	Connectable   Connectivity = "true"
	Unconnectable Connectivity = "false"
	DHCPFailed    Connectivity = "DHCP failed"
	PingFailed    Connectivity = "ping failed"
)

type Layer3NetworkConf

type Layer3NetworkConf struct {
	Mode         Mode         `json:"mode,omitempty"`
	CIDR         string       `json:"cidr,omitempty"`
	Gateway      string       `json:"gateway,omitempty"`
	ServerIPAddr string       `json:"serverIPAddr,omitempty"`
	Connectivity Connectivity `json:"connectivity,omitempty"`
	Outdated     bool         `json:"outdated,omitempty"`
}

func NewLayer3NetworkConf

func NewLayer3NetworkConf(conf string) (*Layer3NetworkConf, error)

func (*Layer3NetworkConf) ToString

func (c *Layer3NetworkConf) ToString() (string, error)

type Mode

type Mode string

const (
	Auto   Mode = "auto"
	Manual Mode = "manual"
)

type NadSelectedNetworks

type NadSelectedNetworks []nadv1.NetworkSelectionElement

func NewNADSelectedNetworks

func NewNADSelectedNetworks(conf string) (NadSelectedNetworks, error)

func (NadSelectedNetworks) ToString

func (n NadSelectedNetworks) ToString() (string, error)

type NetConf

type NetConf struct {
	cniv1.NetConf
	BrName       string `json:"bridge"`
	IsGW         bool   `json:"isGateway"`
	IsDefaultGW  bool   `json:"isDefaultGateway"`
	ForceAddress bool   `json:"forceAddress"`
	IPMasq       bool   `json:"ipMasq"`
	MTU          int    `json:"mtu"`
	HairpinMode  bool   `json:"hairpinMode"`
	PromiscMode  bool   `json:"promiscMode"`
	Vlan         int    `json:"vlan"`
}

type NetworkType

type NetworkType string

const (
	L2VlanNetwork   NetworkType = "L2VlanNetwork"
	UntaggedNetwork NetworkType = "UntaggedNetwork"
)

type VmiGetter

type VmiGetter struct {
	VmiCache ctlkubevirtv1.VirtualMachineInstanceCache
}

func (*VmiGetter) WhoUseNad

func (v *VmiGetter) WhoUseNad(nad *nadv1.NetworkAttachmentDefinition, nodesFilter mapset.Set[string]) ([]*kubevirtv1.VirtualMachineInstance, error)

WhoUseNad requires adding network indexer to the vmi cache before invoking it