Documentation ¶
Overview ¶
Package util contains utility functions which are used in the agent implementation.
Index ¶
- Constants
- func CallPSCommand(cmd string) (string, error)
- func ConfigureInterfaceAddress(ifaceName string, ipConfig *net.IPNet) error
- func ConfigureInterfaceAddressWithDefaultGateway(ifaceName string, ipConfig *net.IPNet, gateway string) error
- func ConfigureLinkAddresses(idx int, ipNets []*net.IPNet) error
- func CreateHNSNetwork(hnsNetName string, subnetCIDR *net.IPNet, nodeIP *net.IPNet, ...) (*hcsshim.HNSNetwork, error)
- func DeleteHNSNetwork(hnsNetName string) error
- func DialLocalSocket(address string) (net.Conn, error)
- func EnableHNSNetworkExtension(hnsNetID string, vSwitchExtension string) error
- func EnableHostInterface(ifaceName string) error
- func EnableIPForwarding(ifaceName string) error
- func EnableRSCOnVSwitch(vSwitch string) error
- func GenerateContainerInterfaceKey(containerID string) string
- func GenerateContainerInterfaceName(podName, podNamespace, containerID string) string
- func GenerateNodeTunnelInterfaceKey(nodeName string) string
- func GenerateNodeTunnelInterfaceName(nodeName string) string
- func GetDNServersByInterfaceIndex(ifIndex int) (string, error)
- func GetDefaultGatewayByInterfaceIndex(ifIndex int) (string, error)
- func GetHostInterfaceStatus(ifaceName string) (string, error)
- func GetIPNetDeviceFromIP(localIP net.IP) (*net.IPNet, *net.Interface, error)
- func GetIPWithFamily(ips []net.IP, addrFamily uint8) (net.IP, error)
- func GetIPv4Addr(ips []net.IP) net.IP
- func GetLocalBroadcastIP(ipNet *net.IPNet) net.IP
- func GetNSPath(containerNetNS string) (string, error)
- func HostInterfaceExists(ifaceName string) bool
- func InvokePSCommand(cmd string) error
- func ListenLocalSocket(address string) (net.Listener, error)
- func PrepareHNSNetwork(subnetCIDR *net.IPNet, nodeIPNet *net.IPNet, uplinkAdapter *net.Interface) error
- func RemoveInterfaceAddress(ifaceName string, ipAddr net.IP) error
- func RemoveManagementInterface(networkName string) error
- func SetAdapterDNSServers(adapterName, dnsServers string) error
- func SetAdapterMACAddress(adapterName string, macConfig *net.HardwareAddr) error
- func SetInterfaceMTU(ifaceName string, mtu int) error
- func SetLinkUp(name string) (net.HardwareAddr, int, error)
- func WindowsHyperVEnabled() (bool, error)
- type ExtensionsPolicy
- type LinkNotFound
Constants ¶
const ( FamilyIPv4 uint8 = 4 FamilyIPv6 uint8 = 6 )
const ( ContainerVNICPrefix = "vEthernet" HNSNetworkType = "Transparent" LocalHNSNetwork = "antrea-hnsnetwork" OVSExtensionID = "583CC151-73EC-4A6A-8B47-578297AD7623" )
Variables ¶
This section is empty.
Functions ¶
func CallPSCommand ¶
func ConfigureInterfaceAddress ¶
ConfigureInterfaceAddress adds IPAddress on the specified interface.
func ConfigureInterfaceAddressWithDefaultGateway ¶
func ConfigureInterfaceAddressWithDefaultGateway(ifaceName string, ipConfig *net.IPNet, gateway string) error
ConfigureInterfaceAddressWithDefaultGateway adds IPAddress on the specified interface and sets the default gateway for the host.
func ConfigureLinkAddresses ¶
ConfigureLinkAddresses adds the provided addresses to the interface identified by index idx, if they are missing from the interface. Any other existing address already configured for the interface will be removed, unless it is a link-local address. At the moment, this function only supports IPv4 addresses and will ignore any address in ipNets that is not IPv4.
func CreateHNSNetwork ¶
func CreateHNSNetwork(hnsNetName string, subnetCIDR *net.IPNet, nodeIP *net.IPNet, adapter *net.Interface) (*hcsshim.HNSNetwork, error)
CreateHNSNetwork creates a new HNS Network, whose type is "Transparent". The NetworkAdapter is using the host interface which is configured with Node IP. HNS Network properties "ManagementIP" and "SourceMac" are used to record the original IP and MAC addresses on the network adapter.
func DeleteHNSNetwork ¶
func DialLocalSocket ¶
DialLocalSocket connects to a Unix domain socket or a Windows named pipe. - If the specified address starts with "\\.\pipe\", connect to a Windows named pipe path. - Else connect to a Unix domain socket.
func EnableHNSNetworkExtension ¶
EnableHNSNetworkExtension enables the specified vSwitchExtension on the target HNS Network. Antrea calls this function to enable OVS Extension on the HNS Network.
func EnableHostInterface ¶
EnableHostInterface sets the specified interface status as UP.
func EnableIPForwarding ¶
EnableIPForwarding enables the IP interface to forward packets that arrive on this interface to other interfaces.
func EnableRSCOnVSwitch ¶
EnableRSCOnVSwitch enables RSC in the vSwitch to reduce host CPU utilization and increase throughput for virtual workloads by coalescing multiple TCP segments into fewer, but larger segments.
func GenerateContainerInterfaceKey ¶
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 ¶
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 ¶
GenerateNodeTunnelInterfaceKey generates a unique string for a Node's tunnel interface as: node/<Node-name>.
func GenerateNodeTunnelInterfaceName ¶
GenerateNodeTunnelInterfaceName generates a unique interface name for the tunnel to the Node, using the Node's name.
func GetDNServersByInterfaceIndex ¶
GetDNServersByInterfaceIndex returns the DNS servers configured on the specified interface.
func GetDefaultGatewayByInterfaceIndex ¶
GetDefaultGatewayByInterfaceIndex returns the default gateway configured on the specified interface.
func GetHostInterfaceStatus ¶
func GetIPNetDeviceFromIP ¶
GetIPNetDeviceFromIP returns a local IP/mask and associated device from IP.
func GetLocalBroadcastIP ¶
GetLocalBroadcastIP returns the last IP address in a subnet. This IP is always working as the broadcast address in the subnet on Windows, and an active route entry that uses it as the destination is added by default when a new IP is configured on the interface.
func HostInterfaceExists ¶
func InvokePSCommand ¶
func ListenLocalSocket ¶
ListenLocalSocket creates a listener on a Unix domain socket or a Windows named pipe. - If the specified address starts with "\\.\pipe\", create a listener on the a Windows named pipe path. - Else create a listener on a local Unix domain socket.
func PrepareHNSNetwork ¶
func PrepareHNSNetwork(subnetCIDR *net.IPNet, nodeIPNet *net.IPNet, uplinkAdapter *net.Interface) error
PrepareHNSNetwork creates HNS Network for containers.
func RemoveInterfaceAddress ¶
RemoveInterfaceAddress removes IPAddress from the specified interface.
func RemoveManagementInterface ¶
RemoveManagementInterface removes the management interface of the HNS Network, and then the physical interface can be added to the OVS bridge. This function is called only if Hyper-V feature is installed on the host.
func SetAdapterDNSServers ¶
SetAdapterDNSServers configures DNSServers on network adapter.
func SetAdapterMACAddress ¶
func SetAdapterMACAddress(adapterName string, macConfig *net.HardwareAddr) error
ConfigureMACAddress set specified MAC address on interface.
func SetInterfaceMTU ¶
SetInterfaceMTU configures interface MTU on host for Pods. MTU change cannot be realized with HNSEndpoint because there's no MTU field in HNSEndpoint: https://github.com/Microsoft/hcsshim/blob/4a468a6f7ae547974bc32911395c51fb1862b7df/internal/hns/hnsendpoint.go#L12
func WindowsHyperVEnabled ¶
WindowsHyperVEnabled checks if the Hyper-V is enabled on the host. Hyper-V feature contains multiple components/sub-features. According to the test, OVS requires "Microsoft-Hyper-V" feature to be enabled.
Types ¶
type ExtensionsPolicy ¶
type ExtensionsPolicy struct {
Extensions []vSwitchExtensionPolicy `json:"Extensions"`
}
type LinkNotFound ¶
type LinkNotFound struct {
// contains filtered or unexported fields
}
Directories ¶
Path | Synopsis |
---|---|
Package ethtool provides Go wrappers for ioctl ethtool system calls on Linux
|
Package ethtool provides Go wrappers for ioctl ethtool system calls on Linux |
Package systcl contains utility functions to read and write sysctl configuration on Linux.
|
Package systcl contains utility functions to read and write sysctl configuration on Linux. |
Package winfirewall contains utility functions to configure the Windows firewall.
|
Package winfirewall contains utility functions to configure the Windows firewall. |