func()

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