func()

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
}