Documentation ¶
Index ¶
- Constants
- func AddrInFamily(addrType string, addr string) bool
- func CreateClients(config componentbaseconfig.ClientConnectionConfiguration, ...) (clientset.Interface, aggregatorclientset.Interface, bpgcrdclientset.Interface, ...)
- 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, name string, ns string, nodeMatchList []string) ([]net.IP, 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 ¶
View Source
const (
NodeNameEnvKey = "NODE_NAME"
)
This const are environment variable of k8s pod
Variables ¶
This section is empty.
Functions ¶
func AddrInFamily ¶
Check address belongs to desired family
func CreateClients ¶
func CreateClients(config componentbaseconfig.ClientConnectionConfiguration, kubeAPIServerOverride string) ( clientset.Interface, aggregatorclientset.Interface, bpgcrdclientset.Interface, klbcrdclientset.Interface, apiextensionclientset.Interface, sigsclientset.Interface, error)
CreateClients creates kube clients from the given config.
func GetMultusEndpoints ¶
func GetMultusNetworkName ¶
func GetMultusNetworkStatus ¶
func GetNodeAddr ¶
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 GetServiceEndPoints ¶ added in v0.9.0
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 ¶ added in v0.9.7
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 MatchNodeinNodeList ¶ added in v0.9.5
func UnmarshalNetworkList ¶ added in v0.9.2
func UnmarshalNetworkStatus ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.