func (d *podDiscoverer) run(ctx context.Context, in chan<- resource) {
    d.Info("pod_discoverer is started")
    defer func() { close(d.stopCh); d.Info("pod_discoverer is stopped") }()

    defer d.queue.ShutDown()