Versions in this module Expand all Collapse all v1 v1.32.0 Mar 15, 2022 v1.31.9 Feb 17, 2022 Changes in this version + const POD_STATUS_FAILED + const POD_STATUS_SUCCESS + func DefaultHandlerWaitingFunc(watcher watch.Interface, pod *v1.Pod) (string, error) + type HandlerWaitingFunc func(watcher watch.Interface, pod *v1.Pod) error + type PodManager struct + func New(inCluster bool) *PodManager + func (pm *PodManager) CreateConfigRefSpec(configMapRefsNames []string) []v1.ConfigMapEnvSource + func (pm *PodManager) CreateEnvsRefSpec(envMapRefsValues map[string]string) []v1.EnvVar + func (pm *PodManager) CreateJob(namespace string, prefixName string, jobSpec batchv1.JobSpec) (*v1.Pod, error) + func (pm *PodManager) CreateJobSpec(jobNamePrefix string, containerName string, containerImage string, ...) *batchv1.JobSpec + func (pm *PodManager) DeleteJob(namespace string, jobName string) error + func (pm *PodManager) DeletePod(namespace string, podName string) error + func (pm *PodManager) GetPod(namespace string, podName string) (*v1.Pod, error) + func (pm *PodManager) GetPodLogs(namespace string, podName string) (string, string, error) + func (pm *PodManager) GetPods(namespace string) (*v1.PodList, error) + func (pm *PodManager) WaitForPodReady(namespace string, pod *v1.Pod) (string, error)