netdata/netdata

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

package k8s_state

func (ks *KubeState) updateNodeState(r resource) {
    if r.value() == nil {
        if ns, ok := ks.state.nodes[r.source()]; ok {
            ns.deleted = true
        }
        return
    }

    node, err := toNode(r)
    if err != nil {
        ks.Warning(err)
        return
    }

    if myNodeName != "" && node.Name != myNodeName {
        return
    }

    ns, ok := ks.state.nodes[r.source()]
    if !ok {
        ns = newNodeState()
        ks.state.nodes[r.source()] = ns
    }

    if !ok {
        ns.name = node.Name
        ns.creationTime = node.CreationTimestamp.Time
        ns.allocatableCPU = int64(node.Status.Allocatable.Cpu().AsApproximateFloat64() * 1000)
        ns.allocatableMem = node.Status.Allocatable.Memory().Value()
        ns.allocatablePods = node.Status.Allocatable.Pods().Value()
        copyLabels(ns.labels, node.Labels)
    }

    ns.unSchedulable = node.Spec.Unschedulable

    for _, c := range node.Status.Conditions {
        if v, ok := ns.conditions[string(c.Type)]; !ok {
            ns.conditions[string(c.Type)] = &nodeStateCondition{new: true, status: c.Status}
        } else {
            v.status = c.Status
        }
    }
}