garbagecollect

Documentation

Index

• type GarbageCollect
• type Source
  • func NewGarbageCollectSource(collector GarbageCollect, stopChan <-chan struct{}, log loghelper.Logger) *Source
  • func (gc *Source) Start(ctx context.Context, h handler.EventHandler, ...) error

Types

type GarbageCollect

type GarbageCollect interface {
	GarbageCollect(workqueue.RateLimitingInterface) error
}

type Source

type Source struct {
	Period time.Duration
	// contains filtered or unexported fields
}

func NewGarbageCollectSource

func NewGarbageCollectSource(collector GarbageCollect, stopChan <-chan struct{}, log loghelper.Logger) *Source

func (*Source) Start

func (gc *Source) Start(ctx context.Context, h handler.EventHandler, queue workqueue.RateLimitingInterface, p ...predicate.Predicate) error