util

Documentation

Overview

Package util contains utility functions which are used in the agent implementation.

Index

• func ConfigureLinkAddress(idx int, gwIPNet *net.IPNet) error
• func DialLocalSocket(address string) (net.Conn, error)
• func GenerateContainerInterfaceKey(containerID string) string
• func GenerateContainerInterfaceName(podName, podNamespace, containerID string) string
• func GenerateNodeTunnelInterfaceKey(nodeName string) string
• func GenerateNodeTunnelInterfaceName(nodeName string) string
• func GetIPNetDeviceFromIP(localIP net.IP) (*net.IPNet, *net.Interface, error)
• func GetNSDevInterface(nsPath, dev string) (*net.Interface, error)
• func GetNSPath(netnsName string) (string, error)
• func GetNSPeerDevBridge(nsPath, dev string) (*net.Interface, string, error)
• func GetNetLink(dev string) netlink.Link
• func ListenLocalSocket(address string) (net.Listener, error)
• func SetLinkUp(name string) (net.HardwareAddr, int, error)
• type LinkNotFound

Functions

func ConfigureLinkAddress

func ConfigureLinkAddress(idx int, gwIPNet *net.IPNet) error

func DialLocalSocket

func DialLocalSocket(address string) (net.Conn, error)

DialLocalSocket connects to a Unix domain socket.

func GenerateContainerInterfaceKey

func GenerateContainerInterfaceKey(containerID string) string

GenerateContainerInterfaceKey generates a unique string for a Pod's interface as: container/<Container-ID>. We must use ContainerID instead of PodNamespace + PodName because there could be more than one container associated with the same Pod at some point. For example, when deleting a StatefulSet Pod with 0 second grace period, the Pod will be removed from the Kubernetes API very quickly and a new Pod will be created immediately, and kubelet may process the deletion of the previous Pod and the addition of the new Pod simultaneously.

func GenerateContainerInterfaceName

func GenerateContainerInterfaceName(podName, podNamespace, containerID string) string

GenerateContainerInterfaceName generates a unique interface name using the Pod's namespace, name and containerID. The output should be deterministic (so that multiple calls to GenerateContainerInterfaceName with the same parameters return the same value). The output has the length of interfaceNameLength(15). The probability of collision should be neglectable.

func GenerateNodeTunnelInterfaceKey

func GenerateNodeTunnelInterfaceKey(nodeName string) string

GenerateNodeTunnelInterfaceKey generates a unique string for a Node's tunnel interface as: node/<Node-name>.

func GenerateNodeTunnelInterfaceName

func GenerateNodeTunnelInterfaceName(nodeName string) string

GenerateNodeTunnelInterfaceName generates a unique interface name for the tunnel to the Node, using the Node's name.

func GetIPNetDeviceFromIP

func GetIPNetDeviceFromIP(localIP net.IP) (*net.IPNet, *net.Interface, error)

GetIPNetDeviceFromIP returns a local IP/mask and associated device from IP.

func GetNSDevInterface

func GetNSDevInterface(nsPath, dev string) (*net.Interface, error)

GetNSDevInterface returns interface of dev in namespace nsPath.

func GetNSPath

func GetNSPath(netnsName string) (string, error)

GetNSPath returns the path of the specified netns.

func GetNSPeerDevBridge

func GetNSPeerDevBridge(nsPath, dev string) (*net.Interface, string, error)

GetPeerLinkBridge returns peer device and its attached bridge (if applicable) for device dev in network space indicated by nsPath

func GetNetLink

func GetNetLink(dev string) netlink.Link

GetNetLink returns dev link from name.

func ListenLocalSocket

func ListenLocalSocket(address string) (net.Listener, error)

ListenLocalSocket creates a listener on a Unix domain socket.

func SetLinkUp

func SetLinkUp(name string) (net.HardwareAddr, int, error)

Types

type LinkNotFound

type LinkNotFound struct {
	// contains filtered or unexported fields
}