utils

Documentation

Index

• func CleanUpIPAM(conf types.NetConf, args *skel.CmdArgs, logger *logrus.Entry) error
• func CleanUpNamespace(args *skel.CmdArgs, logger *logrus.Entry) error
• func ConfigureIPForwarding(hasIPv4, hasIPv6, enable bool) error
• func ConfigureLogging(logLevel string)
• func DoNetworking(destNetworks []*net.IPNet, ips []*current.IPConfig, ...) (contVethMAC string, err error)
• func GetCurrentThreadNetNSPath() string
• func Min(a, b int) int
• func ReleaseIPAllocation(logger *logrus.Entry, ipamType string, stdinData []byte)
• type WEPIdentifiers
  • func GetIdentifiers(args *skel.CmdArgs) (*WEPIdentifiers, error)

Functions

func CleanUpIPAM

func CleanUpIPAM(conf types.NetConf, args *skel.CmdArgs, logger *logrus.Entry) error

CleanUpIPAM calls IPAM plugin to release the IP address. It also contains IPAM plugin specific changes needed before calling the plugin.

func CleanUpNamespace

func CleanUpNamespace(args *skel.CmdArgs, logger *logrus.Entry) error

CleanUpNamespace deletes the devices in the network namespace.

func ConfigureIPForwarding

func ConfigureIPForwarding(hasIPv4, hasIPv6, enable bool) error

func ConfigureLogging

func ConfigureLogging(logLevel string)

Set up logging for both Calico and libcalico using the provided log level,

func DoNetworking

func DoNetworking(destNetworks []*net.IPNet, ips []*current.IPConfig, contNetNS, contVethName, hostVethName string, ipForward bool, logger *logrus.Entry) (contVethMAC string, err error)

DoNetworking performs the networking for the given config and IPAM result

func GetCurrentThreadNetNSPath

func GetCurrentThreadNetNSPath() string

GetCurrentThreadNetNSPath returns the string to represent the current namespace of the current thread. This is an exported copy of getCurrentThreadNetNSPath from github.com/containernetworking/plugins/pkg/ns/ns_linux.go

func Min

func Min(a, b int) int

func ReleaseIPAllocation

func ReleaseIPAllocation(logger *logrus.Entry, ipamType string, stdinData []byte)

ReleaseIPAllocation is called to cleanup IPAM allocations if something goes wrong during CNI ADD execution.

Types

type WEPIdentifiers

type WEPIdentifiers struct {
	ContainerID string
	Endpoint    string
	Namespace   string
	Pod         string
}

func GetIdentifiers

func GetIdentifiers(args *skel.CmdArgs) (*WEPIdentifiers, error)

GetIdentifiers takes CNI command arguments, and extracts identifiers i.e. pod name, pod namespace, container ID, endpoint(container interface name) and orchestratorID based on the orchestrator.