kubeutils

Documentation

Index

• func BuildConfig() (*rest.Config, error)
• func GetNodeInternalIP(node *v1.Node) (string, error)
• func GetUnreachableNodes(c clientset.Interface, namespace string) ([]*v1.Node, error)
• func GetUnreadyNodes(c clientset.Interface) (*v1.NodeList, error)
• func ReportUnreachableIPs(c clientset.Interface, unreachableNodes []NetNode, reportingNodeIP string, ...) error
• type NetNode

Functions

func BuildConfig

func BuildConfig() (*rest.Config, error)

func GetNodeInternalIP

func GetNodeInternalIP(node *v1.Node) (string, error)

GetNodeInternalIP returns the internal IP address of the node object Maybe we should error if there's more than a single IP unless opted in (as workloads could be commiting remote data)

func GetUnreachableNodes

func GetUnreachableNodes(c clientset.Interface, namespace string) ([]*v1.Node, error)

GetUnreachableNodes get nodes that are REPORTED as unreachanble by the function above - used from the monitor thread to provide a consensus of node Unreachability

func GetUnreadyNodes

func GetUnreadyNodes(c clientset.Interface) (*v1.NodeList, error)

GetUnreadyNodes returns all the nodes that could be down

func ReportUnreachableIPs

func ReportUnreachableIPs(c clientset.Interface, unreachableNodes []NetNode, reportingNodeIP string, namespace string) error

ReportUnreachableIPs records the ip addresses that can't be contacted - Used by the detector thread to report all node(s) that are unreachable (from a given source)

Types

type NetNode

type NetNode struct {
	IP   string
	Node *v1.Node
}

NetNode provides details of which node can't be contacted