pod

Documentation

Index

• func GetImages(spec core.PodSpec) (images []string)
• func GetTerminatedContainersStatusesByPod(pod *core.Pod) map[string]*core.ContainerStateTerminated
• type Manager
  • func NewPodManager(clientset kubernetes.Interface) *Manager
  • func (pw *Manager) GetContainerLogsByJob(ctx context.Context, job *batch.Job, container string) (io.ReadCloser, error)
  • func (pw *Manager) GetPodByJob(ctx context.Context, job *batch.Job) (*core.Pod, error)
  • func (pw *Manager) GetPodByName(ctx context.Context, namespace, name string) (*core.Pod, error)
  • func (pw *Manager) GetPodLogs(ctx context.Context, pod *core.Pod, container string) (io.ReadCloser, error)
  • func (pw *Manager) GetPodSpecByWorkload(ctx context.Context, workload kube.Object) (spec core.PodSpec, object meta.Object, err error)
  • func (pw *Manager) GetTerminatedContainersStatusesByJob(ctx context.Context, job *batch.Job) (statuses map[string]*core.ContainerStateTerminated, err error)
  • func (pw *Manager) LogRunnerErrors(ctx context.Context, job *batch.Job)

Functions

func GetImages

func GetImages(spec core.PodSpec) (images []string)

GetImages gets a slice of images for the specified PodSpec.

func GetTerminatedContainersStatusesByPod

func GetTerminatedContainersStatusesByPod(pod *core.Pod) map[string]*core.ContainerStateTerminated

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewPodManager

func NewPodManager(clientset kubernetes.Interface) *Manager

func (*Manager) GetContainerLogsByJob

func (pw *Manager) GetContainerLogsByJob(ctx context.Context, job *batch.Job, container string) (io.ReadCloser, error)

func (*Manager) GetPodByJob

func (pw *Manager) GetPodByJob(ctx context.Context, job *batch.Job) (*core.Pod, error)

GetPodByJob gets the Pod controller by the specified Job.

func (*Manager) GetPodByName

func (pw *Manager) GetPodByName(ctx context.Context, namespace, name string) (*core.Pod, error)

func (*Manager) GetPodLogs

func (pw *Manager) GetPodLogs(ctx context.Context, pod *core.Pod, container string) (io.ReadCloser, error)

func (*Manager) GetPodSpecByWorkload

func (pw *Manager) GetPodSpecByWorkload(ctx context.Context, workload kube.Object) (spec core.PodSpec, object meta.Object, err error)

GetPodSpecByWorkload returns a PodSpec of the specified Workload.

func (*Manager) GetTerminatedContainersStatusesByJob

func (pw *Manager) GetTerminatedContainersStatusesByJob(ctx context.Context, job *batch.Job) (statuses map[string]*core.ContainerStateTerminated, err error)

func (*Manager) LogRunnerErrors

func (pw *Manager) LogRunnerErrors(ctx context.Context, job *batch.Job)

TODO Consider moving this generic code to kube.runnableJob and call it in case of failure