in internal/kubelib/logs.go [182:194]
func (f *logsFollower) followPodLogs(ctx context.Context) {
defer f.wg.Done()
for {
select {
case <-ctx.Done():
return
case p := <-f.podLogsChan:
// TODO: log error
_ = f.followPodLog(ctx, p)
}
}
}