Versions in this module Expand all Collapse all v0 v0.0.1 Dec 20, 2019 Changes in this version + func GetFirstTerminationMessage(pod *corev1.Pod) string + func GetJobPod(ctx context.Context, kubeClientset kubernetes.Interface, ...) (*corev1.Pod, error) + func GetJobPodByJobName(ctx context.Context, kubeClientset kubernetes.Interface, ...) (*corev1.Pod, error) + func GetOperationsResult(ctx context.Context, pod *corev1.Pod, result interface{}) error + func IsJobComplete(job *batchv1.Job) bool + func IsJobFailed(job *batchv1.Job) bool + func IsJobSucceeded(job *batchv1.Job) bool + func JobFailedMessage(job *batchv1.Job) string + type Client struct + Dynamic dynamic.Interface + Kube *kntest.KubeClient + Namespace string + func NewClient(configPath string, clusterName string, namespace string) (*Client, error) + func (c *Client) CreateNamespaceIfNeeded() error + func (c *Client) DeleteNamespaceIfNeeded() error + func (c *Client) DuplicateSecret(t *testing.T, name, namespace string) + func (c *Client) LogsFor(namespace, name string, gvr schema.GroupVersionResource) (string, error) + func (c *Client) WaitForResourceReady(namespace, name string, gvr schema.GroupVersionResource, timeout time.Duration) error + func (c *Client) WaitUntilJobDone(namespace, name string, timeout time.Duration) (string, error)
Go to main page