util

Documentation

Index

• Constants
• func AddressCount(network *net.IPNet) float64
• func BigInt2Ip(ipInt *big.Int) string
• func CIDRConflict(a, b string) bool
• func CIDRContainIP(cidrStr, ipStr string) bool
• func CheckProtocol(address string) string
• func ContainsString(slice []string, s string) bool
• func DiffStringSlice(slice1, slice2 []string) []string
• func FirstSubnetIP(subnet string) (string, error)
• func GenerateMac() string
• func GenerateRandomV4IP(cidr string) string
• func Ip2BigInt(ipStr string) *big.Int
• func IsNetworkVlan(networkType string, vlanID string, vlanRange string) bool
• func IsProviderVlan(networkType, provider string) bool
• func IsStringIn(str string, slice []string) bool
• func IsStringsOverlap(a, b []string) bool
• func LastIP(subnet string) (string, error)
• func ParsePodNetworkAnnotation(podNetworks, defaultNamespace string) ([]*types.NetworkSelectionElement, error)
• func RemoveString(slice []string, s string) (result []string)
• func SubnetBroadCast(subnet string) string
• func SubnetNumber(subnet string) string
• func UniqString(a []string) []string
• func ValidatePodNetwork(annotations map[string]string) error
• func ValidateSubnet(subnet kubeovnv1.Subnet) error
• func ValidateVlan(vlan int, vlanRange string) error
• type IPTableRule

Constants

const (
	ControllerName = "kube-ovn-controller"

	AllocatedAnnotation  = "ovn.kubernetes.io/allocated"
	RoutedAnnotation     = "ovn.kubernetes.io/routed"
	MacAddressAnnotation = "ovn.kubernetes.io/mac_address"
	IpAddressAnnotation  = "ovn.kubernetes.io/ip_address"
	CidrAnnotation       = "ovn.kubernetes.io/cidr"
	GatewayAnnotation    = "ovn.kubernetes.io/gateway"
	IpPoolAnnotation     = "ovn.kubernetes.io/ip_pool"
	BgpAnnotation        = "ovn.kubernetes.io/bgp"
	SnatAnnotation       = "ovn.kubernetes.io/snat"
	EipAnnotation        = "ovn.kubernetes.io/eip"

	PortSecurityAnnotation = "ovn.kubernetes.io/port_security"
	NorthGatewayAnnotation = "ovn.kubernetes.io/north_gateway"

	AllocatedAnnotationTemplate     = "%s.kubernetes.io/allocated"
	MacAddressAnnotationTemplate    = "%s.kubernetes.io/mac_address"
	IpAddressAnnotationTemplate     = "%s.kubernetes.io/ip_address"
	CidrAnnotationTemplate          = "%s.kubernetes.io/cidr"
	GatewayAnnotationTemplate       = "%s.kubernetes.io/gateway"
	IpPoolAnnotationTemplate        = "%s.kubernetes.io/ip_pool"
	LogicalSwitchAnnotationTemplate = "%s.kubernetes.io/logical_switch"

	ExcludeIpsAnnotation = "ovn.kubernetes.io/exclude_ips"

	IngressRateAnnotation = "ovn.kubernetes.io/ingress_rate"
	EgressRateAnnotation  = "ovn.kubernetes.io/egress_rate"

	PortNameAnnotation      = "ovn.kubernetes.io/port_name"
	LogicalSwitchAnnotation = "ovn.kubernetes.io/logical_switch"

	SubnetNameLabel = "ovn.kubernetes.io/subnet"
	ICGatewayLabel  = "ovn.kubernetes.io/ic-gw"
	ExGatewayLabel  = "ovn.kubernetes.io/external-gw"

	ProtocolTCP = "tcp"
	ProtocolUDP = "udp"

	VlanIdAnnotation      = "ovn.kubernetes.io/vlan_id"
	VlanRangeAnnotation   = "ovn.kubernetes.io/vlan_range"
	NetworkType           = "ovn.kubernetes.io/network_types"
	NetworkTypeVlan       = "vlan"
	ProviderInterfaceName = "ovn.kubernetes.io/provider_interface_name"
	HostInterfaceName     = "ovn.kubernetes.io/host_interface_name"

	NodeNic           = "ovn0"
	NodeAllowPriority = "3000"

	IngressExceptDropPriority = "2002"
	IngressAllowPriority      = "2001"
	IngressDefaultDrop        = "2000"

	EgressExceptDropPriority = "2002"
	EgressAllowPriority      = "2001"
	EgressDefaultDrop        = "2000"

	SubnetAllowPriority = "1001"
	DefaultDropPriority = "1000"

	GeneveHeaderLength = 100
	TcpIpHeaderLength  = 40

	OvnProvider                 = "ovn"
	AttachmentNetworkAnnotation = "k8s.v1.cni.cncf.io/networks"

	SRIOVResourceName = "mellanox.com/cx5_sriov_switchdev"

	InterconnectionConfig = "ovn-ic-config"
	ExternalGatewayConfig = "ovn-external-gw-config"
	InterconnectionSwitch = "ts"
	ExternalGatewaySwitch = "ovn-external"
)

Functions

func AddressCount

func AddressCount(network *net.IPNet) float64

func BigInt2Ip

func BigInt2Ip(ipInt *big.Int) string

func CIDRConflict

func CIDRConflict(a, b string) bool

func CIDRContainIP

func CIDRContainIP(cidrStr, ipStr string) bool

func CheckProtocol

func CheckProtocol(address string) string

func ContainsString

func ContainsString(slice []string, s string) bool

Helper functions to check and remove string from a slice of strings.

func DiffStringSlice

func DiffStringSlice(slice1, slice2 []string) []string

func FirstSubnetIP

func FirstSubnetIP(subnet string) (string, error)

func GenerateMac

func GenerateMac() string

GenerateMac generates mac address.

func GenerateRandomV4IP

func GenerateRandomV4IP(cidr string) string

func Ip2BigInt

func Ip2BigInt(ipStr string) *big.Int

func IsNetworkVlan

func IsNetworkVlan(networkType string, vlanID string, vlanRange string) bool

func IsProviderVlan

func IsProviderVlan(networkType, provider string) bool

func IsStringIn

func IsStringIn(str string, slice []string) bool

func IsStringsOverlap

func IsStringsOverlap(a, b []string) bool

IsStringsOverlap check if two string slices are overlapped

func LastIP

func LastIP(subnet string) (string, error)

func ParsePodNetworkAnnotation

func ParsePodNetworkAnnotation(podNetworks, defaultNamespace string) ([]*types.NetworkSelectionElement, error)

func RemoveString

func RemoveString(slice []string, s string) (result []string)

func SubnetBroadCast

func SubnetBroadCast(subnet string) string

func SubnetNumber

func SubnetNumber(subnet string) string

func UniqString

func UniqString(a []string) []string

UniqString creates an array of string with unique values.

func ValidatePodNetwork

func ValidatePodNetwork(annotations map[string]string) error

func ValidateSubnet

func ValidateSubnet(subnet kubeovnv1.Subnet) error

func ValidateVlan

func ValidateVlan(vlan int, vlanRange string) error

Types

type IPTableRule

type IPTableRule struct {
	Table string
	Chain string
	Rule  []string
}

IPTableRule wraps iptables rule