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{ … }