diff --git a/logs/pod_watcher.go b/logs/pod_watcher.go index 43caa32..a540bd5 100644 --- a/logs/pod_watcher.go +++ b/logs/pod_watcher.go @@ -83,9 +83,7 @@ func NewPodWatcher(client KubernetesClient, namespace string, container string, } // WatchPods blocks while it watches the pods which match the Selector of the -// provided deployment. -// -// Cancelling ctx will result in the event loop exiting immediately. +// provided resource. func (pw *PodWatcher) WatchPods(ctx context.Context) error { var wg sync.WaitGroup err := pw.watchPods(ctx, &wg)