code: func newSourceApiserverFromLW(lw cache.ListerWatcher, updates chan<- interface{}) {
  	send := func(objs []interface{}) {
  		var pods []*v1.Pod
  		for _, o := range objs {
  			pods = append(pods, o.(*v1.Pod))
  		}
  		updates <- kubetypes.PodUpdate{Pods: pods, Op: kubetypes.SET, Source: kubetypes.ApiserverSource}
  	}
  	r := cache.NewReflector(lw, &v1.Pod{}, cache.NewUndeltaStore(send, cache.MetaNamespaceKeyFunc), 0)
  	go r.Run(wait.NeverStop)
  }
docs: // newSourceApiserverFromLW holds creates a config source that watches and pulls from the apiserver.