func()

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)
	}
}