Versions in this module Expand all Collapse all v0 v0.1.0 Sep 6, 2019 Changes in this version + const FinalizerKey + func CalculateHoursToDelete(retentionPeriodHours, currentHourOfDay int) []string + func CompletedWorkflowsLabelSelector() *v1.LabelSelector + func CompletedWorkflowsSelectorOutsideRetentionPeriod(retentionPeriodHours int, currentTime time.Time) *v1.LabelSelector + func FinalizersIdentical(o1 v1.Object, o2 v1.Object) bool + func HasCompletedLabel(w *v1alpha1.FlyteWorkflow) bool + func HasFinalizer(meta v1.Object) bool + func IgnoreCompletedWorkflowsLabelSelector() *v1.LabelSelector + func IsDeleted(meta v1.Object) bool + func NewWorkQueue(ctx context.Context, cfg config.WorkqueueConfig, name string) (workqueue.RateLimitingInterface, error) + func ResetFinalizers(meta v1.Object) + func SetCompletedLabel(w *v1alpha1.FlyteWorkflow, currentTime time.Time) + func SetFinalizerIfEmpty(meta v1.Object, finalizer string) + type BatchingWorkQueue struct + func (b *BatchingWorkQueue) AddToSubQueue(item interface{}) + func (b *BatchingWorkQueue) AddToSubQueueAfter(item interface{}, duration time.Duration) + func (b *BatchingWorkQueue) AddToSubQueueRateLimited(item interface{}) + func (b *BatchingWorkQueue) ShutdownAll() + func (b *BatchingWorkQueue) Start(ctx context.Context) + type CompositeWorkQueue interface + AddToSubQueue func(item interface{}) + AddToSubQueueAfter func(item interface{}, duration time.Duration) + AddToSubQueueRateLimited func(item interface{}) + ShutdownAll func() + Start func(ctx context.Context) + func NewCompositeWorkQueue(ctx context.Context, cfg config.CompositeQueueConfig, scope promutils.Scope) (CompositeWorkQueue, error) + type Controller struct + func New(ctx context.Context, cfg *config.Config, kubeclientset kubernetes.Interface, ...) (*Controller, error) + func (c *Controller) Run(ctx context.Context) error + type GarbageCollector struct + func NewGarbageCollector(cfg *config.Config, scope promutils.Scope, clk clock.Clock, ...) (*GarbageCollector, error) + func (g *GarbageCollector) StartGC(ctx context.Context) error + type Handler interface + Handle func(ctx context.Context, namespace, key string) error + Initialize func(ctx context.Context) error + type Propeller struct + func NewPropellerHandler(_ context.Context, cfg *config.Config, wfStore workflowstore.FlyteWorkflow, ...) *Propeller + func (p *Propeller) Handle(ctx context.Context, namespace, name string) error + func (p *Propeller) Initialize(ctx context.Context) error + type SimpleWorkQueue struct + func (s *SimpleWorkQueue) AddToSubQueue(item interface{}) + func (s *SimpleWorkQueue) AddToSubQueueAfter(item interface{}, duration time.Duration) + func (s *SimpleWorkQueue) AddToSubQueueRateLimited(item interface{}) + func (s *SimpleWorkQueue) ShutdownAll() + func (s *SimpleWorkQueue) Start(ctx context.Context) + type WorkerPool struct + func NewWorkerPool(ctx context.Context, scope promutils.Scope, workQueue CompositeWorkQueue, ...) *WorkerPool + func (w *WorkerPool) Initialize(ctx context.Context) error + func (w *WorkerPool) Run(ctx context.Context, threadiness int, synced ...cache.InformerSynced) error