common

Documentation

Index

• Constants
• Variables
• func CheckPodAnnotationIPs(s string) ([]net.IP, error)
• func CheckPodAnnotationMACs(s string) ([]string, error)
• func CheckSubnetConflict(subnet *flv1.FlatNetworkSubnet, subnets []*flv1.FlatNetworkSubnet) error
• func CheckSubnetFlatMode(subnet *flv1.FlatNetworkSubnet, subnets []*flv1.FlatNetworkSubnet) error
• func GetWorkloadKind(w metav1.Object) string
• func GetWorkloadReservdIPKey(w metav1.Object) string
• func ValidateSubnet(subnet *flv1.FlatNetworkSubnet) error
• type EndpointReource
  • func GetEndpointResources(svc *corev1.Service, pods []*corev1.Pod) (*EndpointReource, error)
  • func (r *EndpointReource) GetEndpointSliceAddressType() (discoveryv1.AddressType, error)

Constants

const (
	KindDeployment  = "Deployment"
	KindDaemonSet   = "DaemonSet"
	KindStatefulSet = "StatefulSet"
	KindCronJob     = "CronJob"
	KindJob         = "Job"
)

Variables

var (
	ErrPodNetworkStatusNotUpdated = fmt.Errorf("pod network status not updated by multus")
)

Functions

func CheckPodAnnotationIPs

func CheckPodAnnotationIPs(s string) ([]net.IP, error)

func CheckPodAnnotationMACs

func CheckPodAnnotationMACs(s string) ([]string, error)

func CheckSubnetConflict

func CheckSubnetConflict(
	subnet *flv1.FlatNetworkSubnet, subnets []*flv1.FlatNetworkSubnet,
) error

func CheckSubnetFlatMode

func CheckSubnetFlatMode(
	subnet *flv1.FlatNetworkSubnet, subnets []*flv1.FlatNetworkSubnet,
) error

func GetWorkloadKind

func GetWorkloadKind(w metav1.Object) string

func GetWorkloadReservdIPKey

func GetWorkloadReservdIPKey(w metav1.Object) string

func ValidateSubnet

func ValidateSubnet(subnet *flv1.FlatNetworkSubnet) error

Types

type EndpointReource

type EndpointReource struct {
	Subsets       []corev1.EndpointSubset
	Endpoints     []discoveryv1.Endpoint
	EndpointPorts []discoveryv1.EndpointPort
}

func GetEndpointResources

func GetEndpointResources(
	svc *corev1.Service, pods []*corev1.Pod,
) (*EndpointReource, error)

GetEndpointResources gets CoreV1 Endpoint Subsets and DiscoveryV1 EndpointSlice resources by pods.

func (*EndpointReource) GetEndpointSliceAddressType

func (r *EndpointReource) GetEndpointSliceAddressType() (discoveryv1.AddressType, error)