controller

Documentation

Index

• type CreatedByAnnotation
• type Kleaner
  • func NewKleaner(ctx context.Context, kclient *kubernetes.Clientset, namespace string, ...) *Kleaner
  • func (c *Kleaner) DeleteJob(job *batchv1.Job)
  • func (c *Kleaner) DeletePod(pod *corev1.Pod)
  • func (c *Kleaner) Process(obj interface{})
  • func (c *Kleaner) Run()
• type PodController
  • func NewPodController(ctx context.Context, kclient *kubernetes.Clientset, namespace string, ...) *PodController
  • func (c *PodController) Process(obj interface{})
  • func (c *PodController) Run()

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 Kleaner

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

Kleaner watches the kubernetes api for changes to Pods and Jobs and delete those according to configured timeouts

func NewKleaner

func NewKleaner(ctx context.Context, kclient *kubernetes.Clientset, namespace string, dryRun bool, deleteSuccessfulAfter,
	deleteFailedAfter, deletePendingAfter, deleteOrphanedAfter, deleteEvictedAfter time.Duration, ignoreOwnedByCronjob bool,
	labelSelector string,
	stopCh <-chan struct{}) *Kleaner

NewKleaner creates a new NewKleaner

func (*Kleaner) DeleteJob

func (c *Kleaner) DeleteJob(job *batchv1.Job)

func (*Kleaner) DeletePod

func (c *Kleaner) DeletePod(pod *corev1.Pod)

func (*Kleaner) Process

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

func (*Kleaner) Run

func (c *Kleaner) Run()

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

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(ctx context.Context, kclient *kubernetes.Clientset, namespace string, dryRun bool, keepSuccessHours,
	keepFailedHours, keepPendingHours int64, stopCh <-chan struct{}) *PodController

NewPodController creates a new NewPodController

func (*PodController) Process

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

func (*PodController) Run

func (c *PodController) Run()

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