testutils

Documentation

Index

• Constants
• func CheckSysctlValue(sysctlPath, value string) error
• func Cmd(cmd string) string
• func CreateContainer(netconf, podName, podNamespace string, ip string) (container_id string, session *gexec.Session, contVeth netlink.Link, ...)
• func CreateContainerNamespace() (containerNs ns.NetNS, containerId string, err error)
• func CreateContainerNamespaceWithCid(container_id string) (containerNs ns.NetNS, containerId string, err error)
• func CreateContainerWithId(netconf, podName, podNamespace, ip, containerId string) (container_id string, session *gexec.Session, contVeth netlink.Link, ...)
• func CreateHostVeth(containerId, k8sName, k8sNamespace, nodename string) error
• func DeleteContainer(netconf, netnspath, podName, podNamespace string) (exitCode int, err error)
• func DeleteContainerWithId(netconf, netnspath, podName, podNamespace, containerId string) (exitCode int, err error)
• func DeleteContainerWithIdAndIfaceName(netconf, netnspath, podName, podNamespace, containerId, ifaceName string) (exitCode int, err error)
• func GetResultForCurrent(session *gexec.Session, cniVersion string) (*current.Result, error)
• func MustCreateNewIPPool(c client.Interface, cidr string, ipip, natOutgoing, ipam bool)
• func RunCNIPluginWithId(netconf, podName, podNamespace, ip, containerId, ifName string, ...) (session *gexec.Session, contVeth netlink.Link, contAddr []netlink.Addr, ...)
• func RunIPAMPlugin(netconf, command, args, cniVersion string) (*current.Result, types.Error, int)
• func WipeEtcd()
• func WipeK8sPods()

Constants

const K8S_TEST_NS = "test"

const TEST_DEFAULT_NS = "default"

Functions

func CheckSysctlValue

func CheckSysctlValue(sysctlPath, value string) error

CheckSysctlValue is a utility function to assert sysctl value is set to what is expected.

func Cmd

func Cmd(cmd string) string

func CreateContainer

func CreateContainer(netconf, podName, podNamespace string, ip string) (container_id string, session *gexec.Session, contVeth netlink.Link, contAddr []netlink.Addr, contRoutes []netlink.Route, targetNs ns.NetNS, err error)

func CreateContainerNamespace

func CreateContainerNamespace() (containerNs ns.NetNS, containerId string, err error)

func CreateContainerNamespaceWithCid

func CreateContainerNamespaceWithCid(container_id string) (containerNs ns.NetNS, containerId string, err error)

func CreateContainerWithId

func CreateContainerWithId(netconf, podName, podNamespace, ip, containerId string) (container_id string, session *gexec.Session, contVeth netlink.Link, contAddr []netlink.Addr, contRoutes []netlink.Route, targetNs ns.NetNS, err error)

Create container with the giving containerId when containerId is not empty

func CreateHostVeth

func CreateHostVeth(containerId, k8sName, k8sNamespace, nodename string) error

Create veth pair on host

func DeleteContainer

func DeleteContainer(netconf, netnspath, podName, podNamespace string) (exitCode int, err error)

Executes the Calico CNI plugin and return the error code of the command.

func DeleteContainerWithId

func DeleteContainerWithId(netconf, netnspath, podName, podNamespace, containerId string) (exitCode int, err error)

func DeleteContainerWithIdAndIfaceName

func DeleteContainerWithIdAndIfaceName(netconf, netnspath, podName, podNamespace, containerId, ifaceName string) (exitCode int, err error)

func GetResultForCurrent

func GetResultForCurrent(session *gexec.Session, cniVersion string) (*current.Result, error)

GetResultForCurrent takes the session output with cniVersion and returns the Result in current.Result format.

func MustCreateNewIPPool

func MustCreateNewIPPool(c client.Interface, cidr string, ipip, natOutgoing, ipam bool)

MustCreateNewIPPool creates a new Calico IPAM IP Pool.

func RunCNIPluginWithId

func RunCNIPluginWithId(
	netconf,
	podName,
	podNamespace,
	ip,
	containerId,
	ifName string,
	targetNs ns.NetNS,
) (
	session *gexec.Session,
	contVeth netlink.Link,
	contAddr []netlink.Addr,
	contRoutes []netlink.Route,
	err error,
)

RunCNIPluginWithId calls CNI plugin with a containerID and targetNs passed to it. This is for when you want to call CNI for an existing container.

func RunIPAMPlugin

func RunIPAMPlugin(netconf, command, args, cniVersion string) (*current.Result, types.Error, int)

RunIPAMPlugin sets ENV vars required then calls the IPAM plugin specified in the config and returns the result and exitCode.

func WipeEtcd

func WipeEtcd()

Delete everything under /calico from etcd.

func WipeK8sPods

func WipeK8sPods()

Delete all K8s pods from the "test" namespace