k8s

func AddrInFamily ¶

func AddrInFamily(addrType string, addr string) bool

Check address belongs to desired family

func CreateClients ¶

func CreateClients(config componentbaseconfig.ClientConnectionConfiguration, kubeAPIServerOverride string) (
	clientset.Interface, aggregatorclientset.Interface, crdclientset.Interface, apiextensionclientset.Interface, sigsclientset.Interface, error)

CreateClients creates kube clients from the given config.

func GetMultusEndpoints ¶

func GetMultusEndpoints(kubeClient clientset.Interface, svc *corev1.Service, netList []string, addrType string) ([]string, error)

func GetMultusNetworkName ¶

func GetMultusNetworkName(ns, name string) string

func GetMultusNetworkStatus ¶

func GetMultusNetworkStatus(ns, name string) (networkStatus, error)

func GetNodeAddr ¶

func GetNodeAddr(node *v1.Node) (net.IP, error)

GetNodeAddr gets the available IP address of a Node. GetNodeAddr will first try to get the NodeInternalIP, then try to get the NodeExternalIP.

func GetNodeName ¶

func GetNodeName() (string, error)

func GetServiceEndPoints ¶ added in v0.9.0

func GetServiceEndPoints(kubeClient clientset.Interface, name string, ns string) ([]net.IP, error)

func GetServiceLocalEndpoints ¶

func GetServiceLocalEndpoints(kubeClient clientset.Interface, svc *corev1.Service, addrType string) ([]string, error)

GetServiceLocalEndpoints - Get HostIPs of pods belonging to the given service

func GetServicePortIntValue ¶

func GetServicePortIntValue(kubeClient clientset.Interface, svc *corev1.Service, port corev1.ServicePort) (int, error)

func UnmarshalNetworkList ¶ added in v0.9.2

func UnmarshalNetworkList(ns string) ([]networkList, error)

func UnmarshalNetworkStatus ¶

func UnmarshalNetworkStatus(ns string) ([]networkStatus, error)