kubernetes/staging/src/k8s.io/client-go/tools/watch/informerwatcher.go

func newEventProcessor(out chan<- watch.Event) *eventProcessor {}

type eventProcessor

func (e *eventProcessor) run() {}

func (e *eventProcessor) takeBatch() []watch.Event {}

func (e *eventProcessor) writeBatch(events []watch.Event) {}

func (e *eventProcessor) push(event watch.Event) {}

func (e *eventProcessor) stopped() bool {}

func (e *eventProcessor) stop() {}

// NewIndexerInformerWatcher will create an IndexerInformer and wrap it into watch.Interface
// so you can use it anywhere where you'd have used a regular Watcher returned from Watch method.
// it also returns a channel you can use to wait for the informers to fully shutdown.
func NewIndexerInformerWatcher(lw cache.ListerWatcher, objType runtime.Object) (cache.Indexer, cache.Controller, watch.Interface, <-chan struct{}