Documentation ¶
Index ¶
Constants ¶
const ( // Interval represent the interval to run Garabge Collection Interval time.Duration = 10 * time.Second )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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