func (p *Pod) Run(ctx context.Context, ch chan<- []*targetgroup.Group) {
	defer p.queue.ShutDown()

	if !cache.WaitForCacheSync(ctx.Done(), p.informer.HasSynced) {
		level.Error(p.logger).Log("msg", "pod informer unable to sync cache")
		return
	}

	go func() {
		for p.process(ctx, ch) {
		}
	}()

	// Block until the target provider is explicitly canceled.
	<-ctx.Done()
}
func (p *Pod) Run(ctx context.Context, ch chan<- []*targetgroup.Group) {
	defer p.queue.ShutDown()

	if !cache.WaitForCacheSync(ctx.Done(), p.informer.HasSynced) {
		level.Error(p.logger).Log("msg", "pod informer unable to sync cache")
		return
	}

	go func() {
		for p.process(ctx, ch) {
		}
	}()

	
	<-ctx.Done()
}
func ( p * Pod ) Run ( ctx context . Context , ch chan <- [ ] * targetgroup . Group ) { defer p . queue . ShutDown ( ) if ! cache . WaitForCacheSync ( ctx . Done ( ) , p . informer . HasSynced ) { level . Error ( p . logger ) . Log ( " " , " " ) return } go func ( ) { for p . process ( ctx , ch ) { } } ( ) // Block until the target provider is explicitly canceled. <- ctx . Done ( ) }
// Run implements the Discoverer interface.
Run implements the Discoverer interface .