Versions in this module Expand all Collapse all v0 v0.1.1 May 27, 2026 v0.1.0 May 26, 2026 Changes in this version + func AddNode(clusterName, nodeName string, extraArgs ...string) + func ApplyDaemonSet(client *kubernetes.Clientset, namespace, manifest string) *appsv1.DaemonSet + func ApplyDeployment(client *kubernetes.Clientset, namespace, manifest string) *appsv1.Deployment + func BinkCmd(args ...string) *exec.Cmd + func CleanupAllTestClusters() + func CleanupCluster(name string) + func CleanupKubeconfig(kubeconfigPath string) + func CollectFailureLogs(clusterNames ...string) + func ContainerExists(name string) bool + func CreateCluster(name string) + func CreatePod(client *kubernetes.Clientset, namespace string, pod *corev1.Pod, ...) + func CreateService(client *kubernetes.Clientset, namespace string, service *corev1.Service) *corev1.Service + func DNSContainerName(clusterName string) string + func DeletePod(client *kubernetes.Clientset, namespace, name string) + func ExposeAPI(clusterName, kubeconfigPath string) + func GenerateTestClusterName() string + func GetContainerID(name string) string + func GetNodeCount(client *kubernetes.Clientset) int + func GetPodNodes(client *kubernetes.Clientset, namespace, labelSelector string) []string + func GetVolume(name string) bool + func ImagePull(image string) + func ImagePush(source, destination string) + func ImageRemove(names ...string) + func ImageTag(nameOrID, tag, repo string) + func NewKubeClient(kubeconfigPath string) *kubernetes.Clientset + func NodeContainerName(clusterName, nodeName string) string + func PodExec(kubeconfigPath, namespace, podName string, command []string) (string, error) + func PodmanCmd(args ...string) string + func PodmanExec(container, command string) string + func RemoveControlPlaneTaint(client *kubernetes.Clientset, nodeName string) + func RemoveNode(clusterName, nodeName string, extraArgs ...string) + func RequireBink() + func RequireCommand(cmd string) + func RequireImage(image string) + func RunCommand(cmd *exec.Cmd, timeout ...time.Duration) *gexec.Session + func SSHExec(clusterName, nodeName, command string) string + func SSHExecQuiet(clusterName, nodeName, command string) (string, error) + func SetupKubeClient(clusterName string) (*kubernetes.Clientset, string) + func StopCluster(name string) + func WaitForDaemonSetReady(client *kubernetes.Clientset, namespace, name string, expectedReady int32, ...) + func WaitForNodeReady(client *kubernetes.Clientset, targetNodeName string, timeout time.Duration) + func WaitForPodReady(client *kubernetes.Clientset, namespace, labelSelector string, ...) + func WaitForServiceAccount(client *kubernetes.Clientset, namespace, name string, timeout time.Duration) + type ContainerInfo struct + ID string + Labels map[string]string + Name string + Ports []string + State string + func GetContainer(name string) *ContainerInfo
Go to main page