k8s

Documentation

Index

• Constants
• func AddrInFamily(addrType string, addr string) bool
• func CreateClients(config componentbaseconfig.ClientConnectionConfiguration, ...) (clientset.Interface, aggregatorclientset.Interface, bpgcrdclientset.Interface, ...)
• func GetLoxilbServiceEndPoints(kubeClient clientset.Interface, name string, ns string, nodeMatchList []string) ([]string, error)
• func GetMultusEndpoints(kubeClient clientset.Interface, svc *corev1.Service, netList []string, ...) ([]string, error)
• func GetMultusNetworkName(ns, name string) string
• func GetMultusNetworkStatus(ns, name string) (networkStatus, error)
• func GetNodeAddr(node *v1.Node) (net.IP, error)
• func GetNodeName() (string, error)
• func GetServiceEndPoints(kubeClient clientset.Interface, svc *corev1.Service, addrType string, ...) ([]string, error)
• func GetServiceEndPointsPorts(kubeClient clientset.Interface, svc *corev1.Service) ([]int, error)
• func GetServiceLocalEndpoints(kubeClient clientset.Interface, svc *corev1.Service, addrType string, ...) ([]string, error)
• func GetServicePodEndpoints(kubeClient clientset.Interface, svc *corev1.Service, addrType string, ...) ([]string, error)
• func GetServicePortIntValue(kubeClient clientset.Interface, svc *corev1.Service, port corev1.ServicePort) ([]int, error)
• func MatchNodeinNodeList(node string, nodeMatchList []string) bool
• func UnmarshalNetworkList(ns string) ([]networkList, error)
• func UnmarshalNetworkStatus(ns string) ([]networkStatus, error)

Constants

const (
	NodeNameEnvKey = "NODE_NAME"
)

This const are environment variable of k8s pod

Functions

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, bpgcrdclientset.Interface, klbcrdclientset.Interface, egresscrdclientset.Interface, apiextensionclientset.Interface, sigsclientset.Interface, error)

CreateClients creates kube clients from the given config.

func GetLoxilbServiceEndPoints

func GetLoxilbServiceEndPoints(kubeClient clientset.Interface, name string, ns string, nodeMatchList []string) ([]string, error)

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

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

func GetServiceEndPointsPorts

func GetServiceEndPointsPorts(kubeClient clientset.Interface, svc *corev1.Service) ([]int, error)

func GetServiceLocalEndpoints

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

GetServiceLocalEndpoints - Get HostIPs of pods belonging to the given service

func GetServicePodEndpoints

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

GetServicePodEndpoints - Get PodIPs of pods belonging to the given service

func GetServicePortIntValue

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

func MatchNodeinNodeList

func MatchNodeinNodeList(node string, nodeMatchList []string) bool

func UnmarshalNetworkList

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

func UnmarshalNetworkStatus

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