garbagecollector

Documentation

Index

• Constants
• type DaemonSetJobGarbageCollector
  • func NewDaemonSetJobGarbageCollector(daemonSetJobClient wclientset.Interface, kubeClient kclientset.Interface, ...) *DaemonSetJobGarbageCollector
  • func (c *DaemonSetJobGarbageCollector) CollectDaemonSetJobJobs() error
• type GarbageCollector
  • func NewGarbageCollector(workflowClient wclientset.Interface, kubeClient kclientset.Interface, ...) *GarbageCollector
  • func (c *GarbageCollector) CollectWorkflowJobs() error

Constants

const (
	// Interval represent the interval to run Garabge Collection
	Interval time.Duration = 10 * time.Second
)

Types

type DaemonSetJobGarbageCollector

type DaemonSetJobGarbageCollector struct {
	KubeClient         kclientset.Interface
	DaemonSetJobClient wclientset.Interface
	DaemonSetJobLister wlisters.DaemonSetJobLister
	DaemonSetJobSynced cache.InformerSynced
}

DaemonSetJobGarbageCollector represents a DaemonSetJob Garbage Collector. It collects orphaned Jobs

func NewDaemonSetJobGarbageCollector

func NewDaemonSetJobGarbageCollector(daemonSetJobClient wclientset.Interface, kubeClient kclientset.Interface, daemonSetJobInformerFactory winformers.SharedInformerFactory) *DaemonSetJobGarbageCollector

NewGarbageCollector builds initializes and returns a GarbageCollector

func (*DaemonSetJobGarbageCollector) CollectDaemonSetJobJobs

func (c *DaemonSetJobGarbageCollector) CollectDaemonSetJobJobs() error

CollectDaemonSetJobJobs collect the orphaned jobs. First looking in the daemonsetjob informer list then retrieve from the API and in case NotFound then remove via DeleteCollection primitive

type GarbageCollector

type GarbageCollector struct {
	KubeClient     kclientset.Interface
	WorkflowClient wclientset.Interface
	WorkflowLister wlisters.WorkflowLister
	WorkflowSynced cache.InformerSynced
}

GarbageCollector represents a Workflow Garbage Collector. It collects orphaned Jobs

func NewGarbageCollector

func NewGarbageCollector(workflowClient wclientset.Interface, kubeClient kclientset.Interface, workflowInformerFactory winformers.SharedInformerFactory) *GarbageCollector

NewGarbageCollector builds initializes and returns a GarbageCollector

func (*GarbageCollector) CollectWorkflowJobs

func (c *GarbageCollector) CollectWorkflowJobs() error

CollectWorkflowJobs collect the orphaned jobs. First looking in the workflow informer list then retrieve from the API and in case NotFound then remove via DeleteCollection primitive