in internal/kubelib/logs.go [90:102]
func (f *logsFollower) isNewTarget(target k8scorev1.ObjectReference) bool {
f.handledTargetsMu.Lock()
defer f.handledTargetsMu.Unlock()
_, exists := f.handledTargets[target]
if exists {
// already handled
return false
}
f.handledTargets[target] = struct{}{}
return true
}