source

Documentation

Index

• type IntervalSource
  • func NewIntervalSource(interval time.Duration) *IntervalSource
  • func (i *IntervalSource) InjectStopChannel(stop <-chan struct{}) error
  • func (i *IntervalSource) Start(h handler.EventHandler, queue workqueue.RateLimitingInterface, ...) error

Types

type IntervalSource

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

func NewIntervalSource

func NewIntervalSource(interval time.Duration) *IntervalSource

func (*IntervalSource) InjectStopChannel

func (i *IntervalSource) InjectStopChannel(stop <-chan struct{}) error

func (*IntervalSource) Start

func (i *IntervalSource) Start(h handler.EventHandler, queue workqueue.RateLimitingInterface, _ ...predicate.Predicate) error