net

Documentation

Index

• Constants
• Variables
• func AddAddresses(link netlink.Link, cidrs []*net.IPNet) (newAddrs []*net.IPNet, err error)
• func AddChainWithRules(ipt *iptables.IPTables, table, chain string, rulespecs [][]string) error
• func AddRoute(link netlink.Link, scope netlink.Scope, dst *net.IPNet, gw net.IP) error
• func AttachContainer(netNSPath, id, ifName, bridgeName string, mtu int, withMulticastRoute bool, ...) error
• func CheckAddressOverlap(addr net.IP, ignoreIfaceNames map[string]struct{}) error
• func CheckNetworkFree(subnet *net.IPNet, ignoreIfaceNames map[string]struct{}) error
• func ConfigureARP(prefix, rootPath string) error
• func ConnectedToBridgeVethPeerIds(bridgeName string) ([]int, error)
• func CreateAndAttachVeth(name, peerName, bridgeName string, mtu int, keepTXOn bool, errIfLinkExist bool, ...) (*netlink.Veth, error)
• func DetachContainer(netNSPath, id, ifName string, cidrs []*net.IPNet) error
• func DetectHairpin(portIfName string, log *logrus.Logger) error
• func EnforceAddrAssignType(bridgeName string) (setAddr bool, err error)
• func EnsureInterface(ifaceName string) (*net.Interface, error)
• func EnsureInterfaceAndMcastRoute(ifaceName string) (*net.Interface, error)
• func EthtoolTXOff(name string) error
• func Expose(bridgeName string, ipAddr *net.IPNet, removeDefaultRoute, npc bool, ...) error
• func FindBridgeIP(bridgeName string, subnet *net.IPNet) (net.IP, error)
• func GetSystemPeerName(dbPrefix, hostRoot string) (string, error)
• func LinkAddIfNotExist(link netlink.Link) error
• func ListenUnixSocket(pathname string) (net.Listener, error)
• func LocalAddresses() ([]*net.IPNet, error)
• func MACfromUUID(uuid []byte) net.HardwareAddr
• func NSPathByPid(pid int) string
• func NSPathByPidWithRoot(root string, pid int) string
• func RandomMAC() (net.HardwareAddr, error)
• func WithNetNS(ns netns.NsHandle, work func() error) error
• func WithNetNSByPath(path string, work func() error) error
• func WithNetNSLink(ns netns.NsHandle, ifName string, work func(link netlink.Link) error) error
• type Bridge
  • func EnsureBridge(procPath string, config *BridgeConfig, log *logrus.Logger, ips ipset.Interface) (Bridge, error)
  • func ExistingBridgeType(weaveBridgeName, datapathName string) (Bridge, error)
• type BridgeConfig
• type Dev
  • func GetBridgeNetDev(bridgeName string) (Dev, error)
  • func GetNetDevsByVethPeerIds(processID int, peerIDs []int) ([]Dev, error)
  • func GetWeaveNetDevs(processID int) ([]Dev, error)
• type EthtoolValue
• type IFReqData
• type NoMasqLocalTracker
  • func NewNoMasqLocalTracker(ips ipset.Interface) *NoMasqLocalTracker
  • func (t *NoMasqLocalTracker) HandleUpdate(prevRanges, currRanges []address.Range, local bool) error
  • func (t *NoMasqLocalTracker) String() string

Constants

const (
	WeaveBridgeName  = "weave"
	DatapathName     = "datapath"
	DatapathIfName   = "vethwe-datapath"
	BridgeIfName     = "vethwe-bridge"
	PcapIfName       = "vethwe-pcap"
	NoMasqLocalIpset = ipset.Name("weaver-no-masq-local")
)

const (
	SIOCETHTOOL     = 0x8946     // linux/sockios.h
	ETHTOOL_GTXCSUM = 0x00000016 // linux/ethtool.h
	ETHTOOL_STXCSUM = 0x00000017 // linux/ethtool.h
	IFNAMSIZ        = 16         // linux/if.h
)

const (
	VethName = "ethwe" // name inside container namespace

)

Variables

var ErrBridgeNoIP = fmt.Errorf("Bridge has no IP address")

var ErrLinkNotFound = errors.New("Link not found")

Functions

func AddAddresses

func AddAddresses(link netlink.Link, cidrs []*net.IPNet) (newAddrs []*net.IPNet, err error)

func AddChainWithRules

func AddChainWithRules(ipt *iptables.IPTables, table, chain string, rulespecs [][]string) error

AddChainWithRules creates a chain and appends given rules to it.

If the chain exists, but its rules are not the same as the given ones, the function will flush the chain and then will append the rules.

func AddRoute

func AddRoute(link netlink.Link, scope netlink.Scope, dst *net.IPNet, gw net.IP) error

func AttachContainer

func AttachContainer(netNSPath, id, ifName, bridgeName string, mtu int, withMulticastRoute bool, cidrs []*net.IPNet, keepTXOn bool, hairpinMode bool) error

func CheckAddressOverlap

func CheckAddressOverlap(addr net.IP, ignoreIfaceNames map[string]struct{}) error

For a specific address, we only care if it is actually *inside* an existing route, because weave-local traffic never hits IP routing.

func CheckNetworkFree

func CheckNetworkFree(subnet *net.IPNet, ignoreIfaceNames map[string]struct{}) error

A network is considered free if it does not overlap any existing routes on this host. This is the same approach taken by Docker.

func ConfigureARP

func ConfigureARP(prefix, rootPath string) error

configureARP is a helper for the Docker plugin which doesn't set the addresses itself

func ConnectedToBridgeVethPeerIds

func ConnectedToBridgeVethPeerIds(bridgeName string) ([]int, error)

ConnectedToBridgeVethPeerIds returns peer indexes of veth links connected to the given bridge. The peer index is used to query from a container netns whether the container is connected to the bridge.

func CreateAndAttachVeth

func CreateAndAttachVeth(name, peerName, bridgeName string, mtu int, keepTXOn bool, errIfLinkExist bool, init func(peer netlink.Link) error) (*netlink.Veth, error)

create and attach a veth to the Weave bridge

func DetachContainer

func DetachContainer(netNSPath, id, ifName string, cidrs []*net.IPNet) error

func DetectHairpin

func DetectHairpin(portIfName string, log *logrus.Logger) error

func EnforceAddrAssignType

func EnforceAddrAssignType(bridgeName string) (setAddr bool, err error)

func EnsureInterface

func EnsureInterface(ifaceName string) (*net.Interface, error)

Wait for an interface to come up.

func EnsureInterfaceAndMcastRoute

func EnsureInterfaceAndMcastRoute(ifaceName string) (*net.Interface, error)

Wait for an interface to come up and have a route added to the multicast subnet. This matches the behaviour in 'weave attach', which is the only context in which we expect this to be called. If you change one, change the other to match.

func EthtoolTXOff

func EthtoolTXOff(name string) error

Disable TX checksum offload on specified interface

func Expose

func Expose(bridgeName string, ipAddr *net.IPNet, removeDefaultRoute, npc bool, skipNAT bool) error

Expose makes the network accessible from a host by assigning a given IP address to the weave bridge.

List of params: * "bridgeName" - a name of the weave bridge. * "ipAddr" - IP addr to be assigned to the bridge. * "removeDefaultRoute" - whether to remove a default route installed by the kernel (used only in the AWSVPC mode). * "npc" - whether is Weave NPC running. * "skipNAT" - whether to skip adding iptables NAT rules

func FindBridgeIP

func FindBridgeIP(bridgeName string, subnet *net.IPNet) (net.IP, error)

func GetSystemPeerName

func GetSystemPeerName(dbPrefix, hostRoot string) (string, error)

GetSystemPeerName returns an ID derived from concatenated machine-id (either systemd or dbus), the system (aka bios) UUID and the hypervisor UUID. It is tweaked and formatted to be usable as a mac address

func LinkAddIfNotExist

func LinkAddIfNotExist(link netlink.Link) error

func ListenUnixSocket

func ListenUnixSocket(pathname string) (net.Listener, error)

func LocalAddresses

func LocalAddresses() ([]*net.IPNet, error)

func MACfromUUID

func MACfromUUID(uuid []byte) net.HardwareAddr

func NSPathByPid

func NSPathByPid(pid int) string

func NSPathByPidWithRoot

func NSPathByPidWithRoot(root string, pid int) string

func RandomMAC

func RandomMAC() (net.HardwareAddr, error)

func WithNetNS

func WithNetNS(ns netns.NsHandle, work func() error) error

func WithNetNSByPath

func WithNetNSByPath(path string, work func() error) error

func WithNetNSLink

func WithNetNSLink(ns netns.NsHandle, ifName string, work func(link netlink.Link) error) error

Types

type Bridge

type Bridge interface {
	IsFastdp() bool // does this bridge use fastdp?
	String() string // human-readable type string
	// contains filtered or unexported methods
}

func EnsureBridge

func EnsureBridge(procPath string, config *BridgeConfig, log *logrus.Logger, ips ipset.Interface) (Bridge, error)

func ExistingBridgeType

func ExistingBridgeType(weaveBridgeName, datapathName string) (Bridge, error)

type BridgeConfig

type BridgeConfig struct {
	DockerBridgeName string
	WeaveBridgeName  string
	DatapathName     string
	NoFastdp         bool
	NoBridgedFastdp  bool
	AWSVPC           bool
	NPC              bool
	MTU              int
	Mac              string
	Port             int
	NoMasqLocal      bool
}

type Dev

type Dev struct {
	Name  string           `json:"Name,omitempty"`
	MAC   net.HardwareAddr `json:"MAC,omitempty"`
	CIDRs []*net.IPNet     `json:"CIDRs,omitempty"`
}

func GetBridgeNetDev

func GetBridgeNetDev(bridgeName string) (Dev, error)

Get the weave bridge interface. NB: Should be called from the root network namespace.

func GetNetDevsByVethPeerIds

func GetNetDevsByVethPeerIds(processID int, peerIDs []int) ([]Dev, error)

func GetWeaveNetDevs

func GetWeaveNetDevs(processID int) ([]Dev, error)

Lookup the weave interface of a container

type EthtoolValue

type EthtoolValue struct {
	Cmd  uint32
	Data uint32
}

linux/ethtool.h 'struct ethtool_value'

type IFReqData

type IFReqData struct {
	Name [IFNAMSIZ]byte
	Data uintptr
}

linux/if.h 'struct ifreq'

type NoMasqLocalTracker

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

func NewNoMasqLocalTracker

func NewNoMasqLocalTracker(ips ipset.Interface) *NoMasqLocalTracker

func (*NoMasqLocalTracker) HandleUpdate

func (t *NoMasqLocalTracker) HandleUpdate(prevRanges, currRanges []address.Range, local bool) error

func (*NoMasqLocalTracker) String

func (t *NoMasqLocalTracker) String() string