test_utils

Documentation

Index

• Constants
• func Cmd(cmd string) string
• func CmdWithStdin(cmd, stdin_string string) string
• func CreateContainer(netconf string, k8sName string, ip string) (container_id, netnspath string, session *gexec.Session, contVeth netlink.Link, ...)
• func CreateContainerNamespace() (containerNs ns.NetNS, containerId, netnspath string, err error)
• func CreateContainerNamespaceWithCid(container_id string) (containerNs ns.NetNS, containerId, netnspath string, err error)
• func CreateContainerWithId(netconf string, k8sName string, ip string, containerId string) (container_id, netnspath string, session *gexec.Session, contVeth netlink.Link, ...)
• func CreateHostVeth(containerId string, k8sName string, k8sNamespace string) error
• func DeleteContainer(netconf, netnspath, name string) (exitCode int, err error)
• func DeleteContainerWithId(netconf, netnspath, name, containerId string) (exitCode int, err error)
• func GetResultForCurrent(session *gexec.Session, cniVersion string) (*current.Result, error)
• func RunIPAMPlugin(netconf, command, args, cniVersion string) (*current.Result, types.Error, int)
• func WipeEtcd()
• func WipeK8sPods()

Constants

const K8S_TEST_NS = "test"

Functions

func Cmd

func Cmd(cmd string) string

func CmdWithStdin

func CmdWithStdin(cmd, stdin_string string) string

func CreateContainer

func CreateContainer(netconf string, k8sName string, ip string) (container_id, netnspath string, session *gexec.Session, contVeth netlink.Link, contAddr []netlink.Addr, contRoutes []netlink.Route, err error)

func CreateContainerNamespace

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

func CreateContainerNamespaceWithCid

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

func CreateContainerWithId

func CreateContainerWithId(netconf string, k8sName string, ip string, containerId string) (container_id, netnspath string, session *gexec.Session, contVeth netlink.Link, contAddr []netlink.Addr, contRoutes []netlink.Route, err error)

Create container with the giving containerId when containerId is not empty

func CreateHostVeth

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

Create veth pair on host

func DeleteContainer

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

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

func DeleteContainerWithId

func DeleteContainerWithId(netconf, netnspath, name, containerId 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 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