pod

Documentation

Index

• type Manager
  • func NewPodManager(clientset kubernetes.Interface) *Manager
  • func (pw *Manager) GetPodByJob(job *batch.Job) (*core.Pod, error)
  • func (pw *Manager) GetPodByName(namespace, name string) (*core.Pod, error)
  • func (pw *Manager) GetPodLogs(pod *core.Pod, container string) (io.ReadCloser, error)
  • func (pw *Manager) GetPodLogsByJob(job *batch.Job, container string) (io.ReadCloser, error)
  • func (pw *Manager) GetPodSpecByWorkload(workload kube.Workload) (spec core.PodSpec, err error)

Types

type Manager

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

func NewPodManager

func NewPodManager(clientset kubernetes.Interface) *Manager

func (*Manager) GetPodByJob

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

GetPodByJob gets the Pod controller by the specified Job.

func (*Manager) GetPodByName

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

func (*Manager) GetPodLogs

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

func (*Manager) GetPodLogsByJob

func (pw *Manager) GetPodLogsByJob(job *batch.Job, container string) (io.ReadCloser, error)

func (*Manager) GetPodSpecByWorkload

func (pw *Manager) GetPodSpecByWorkload(workload kube.Workload) (spec core.PodSpec, err error)

GetPodSpecByWorkload returns a PodSpec of the specified Workload.