controller

Documentation

Index

• type CreatedByAnnotation
• type PodController
  • func NewPodController(kclient *kubernetes.Clientset, namespace string, dryRun bool, ...) *PodController
  • func (c *PodController) Process(obj interface{})
  • func (c *PodController) Run(stopCh <-chan struct{})

Types

type CreatedByAnnotation

type CreatedByAnnotation struct {
	Kind       string
	ApiVersion string
	Reference  struct {
		Kind            string
		Namespace       string
		Name            string
		Uid             string
		ApiVersion      string
		ResourceVersion string
	}
}

CreatedByAnnotation type used to match pods created by job

type PodController

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

PodController watches the kubernetes api for changes to Pods and delete completed Pods without specific annotation

func NewPodController

func NewPodController(kclient *kubernetes.Clientset, namespace string, dryRun bool, opts map[string]float64) *PodController

NewPodController creates a new NewPodController

func (*PodController) Process

func (c *PodController) Process(obj interface{})

func (*PodController) Run

func (c *PodController) Run(stopCh <-chan struct{})

Run starts the process for listening for pod changes and acting upon those changes.