netdata/netdata

// SPDX-License-Identifier: GPL-3.0-or-later

package k8s_state

func (ks *KubeState) runUpdateState(in <-chan resource) {
    for {
        select {
        case <-ks.ctx.Done():
            return
        case r := <-in:
            ks.state.Lock()
            switch r.kind() {
            case kubeResourceNode:
                ks.updateNodeState(r)
            case kubeResourcePod:
                ks.updatePodState(r)
            }
            ks.state.Unlock()
        }
    }
}

func copyLabels(dst, src map[string]string) {
    for k, v := range src {
        dst[k] = v
    }
}