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

package kubemodel

import (
	"fmt"
	"time"
)

type OwnerKind string

const (
	OwnerKindDeployment  OwnerKind = "deployment"
	OwnerKindStatefulSet OwnerKind = "statefulset"
	OwnerKindDaemonSet   OwnerKind = "daemonset"
	OwnerKindJob         OwnerKind = "job"
	OwnerKindCronJob     OwnerKind = "cronjob"
	OwnerKindReplicaSet  OwnerKind = "replicaset"
)

// Owner represents a Kubernetes resource owner
type Owner struct {
	UID         string            `json:"uid"`
	OwnerUID    string            `json:"ownerUid"`
	Name        string            `json:"name"`
	Kind        OwnerKind         `json:"kind"`
	Controller  bool              `json:"controller"`
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
	Start       time.Time         `json:"start"`
	End         time.Time         `json:"end"`
}

func (kms *KubeModelSet) RegisterOwner(uid, name, namespace, kind string, isController bool) error {
	if uid == "" {
		err := fmt.Errorf("UID is nil for Owner '%s'", name)
		kms.Error(err)
		return err
	}

	if _, ok := kms.Owners[uid]; !ok {
		namespaceUID := ""

		if ns, ok := kms.idx.namespaceByName[namespace]; !ok {
			kms.Warnf("RegisterOwner(%s, %s, %s, %s, %t): missing namespace '%s'", uid, name, namespace, kind, isController, namespace)
		} else {
			namespaceUID = ns.UID
		}

		kms.Owners[uid] = &Owner{
			UID:        uid,
			Name:       name,
			OwnerUID:   namespaceUID,
			Kind:       OwnerKind(kind),
			Controller: isController,
		}

		kms.Metadata.ObjectCount++
	}

	return nil
}