cost-model/core/pkg/model/kubemodel/node.go

package kubemodel

import (
	"fmt"
	"time"
)

// @bingen:generate:Node
type Node struct {
	UID                          string            `json:"uid"`                          // @bingen:field[version=1]
	ClusterUID                   string            `json:"clusterUid"`                   // @bingen:field[version=1]
	ProviderResourceUID          string            `json:"providerResourceUid"`          // @bingen:field[version=1]
	Name                         string            `json:"name"`                         // @bingen:field[version=1]
	Labels                       map[string]string `json:"labels,omitempty"`             // @bingen:field[version=1]
	Annotations                  map[string]string `json:"annotations,omitempty"`        // @bingen:field[version=1]
	Start                        time.Time         `json:"start"`                        // @bingen:field[version=1]
	End                          time.Time         `json:"end"`                          // @bingen:field[version=1]
	CpuMillicoreSecondsAllocated uint64            `json:"cpuMillicoreSecondsAllocated"` // @bingen:field[version=1]
	RAMByteSecondsAllocated      uint64            `json:"ramByteSecondsAllocated"`      // @bingen:field[version=1]
	// PublicIPSeconds represents the cumulative public IP allocation (count × seconds) for this node.
	// Calculated as: number of ExternalIP addresses from Kubernetes node Status.Addresses × window duration in seconds.
	// Used for cost attribution of public IP addresses associated with the node.
	PublicIPSecondsAllocated uint64 `json:"publicIpSecondsAllocated"` // @bingen:field[version=1]
	CpuMillicoreUsageAverage uint64 `json:"cpuMillicoreUsageAverage"` // @bingen:field[version=1]
	CpuMillicoreUsageMax     uint64 `json:"cpuMillicoreUsageMax"`     // @bingen:field[version=1]
	RAMByteUsageAverage      uint64 `json:"ramByteUsageAverage"`      // @bingen:field[version=1]
	RAMByteUsageMax          uint64 `json:"ramByteUsageMax"`          // @bingen:field[version=1]
}

func (kms *KubeModelSet) RegisterNode(uid, name string) error {
	if uid == "" {
		err := fmt.Errorf("UID is nil for Node '%s'", name)
		kms.Error(err)
		return err
	}

	if _, ok := kms.Nodes[uid]; !ok {
		clusterUID := ""

		if kms.Cluster == nil {
			kms.Warnf("RegisterNode(%s, %s): Cluster is nil", uid, name)
		} else {
			clusterUID = kms.Cluster.UID
		}

		kms.Nodes[uid] = &Node{
			UID:        uid,
			ClusterUID: clusterUID,
			Name:       name,
		}

		kms.Metadata.ObjectCount++
	}

	return nil
}