in internal/kubelib/logs.go [80:88]
func (f *logsFollower) Start(ctx context.Context) { f.wg.Add(1) go f.discoverPods(ctx) f.wg.Add(f.maxConcurrency) for i := 0; i < f.maxConcurrency; i++ { go f.followPodLogs(ctx) } }