model/flux.go

Rama main · réplica de lectura del repositorio original.

package model

import (
	"maps"

	"github.com/coroot/coroot/timeseries"
)

const (
	ApplicationKindFluxGitRepository  ApplicationKind = "GitRepository"
	ApplicationKindFluxOCIRepository  ApplicationKind = "OCIRepository"
	ApplicationKindFluxHelmRepository ApplicationKind = "HelmRepository"
	ApplicationKindFluxHelmChart      ApplicationKind = "HelmChart"
	ApplicationKindFluxHelmRelease    ApplicationKind = "HelmRelease"
	ApplicationKindFluxKustomization  ApplicationKind = "Kustomization"
	ApplicationKindFluxResourceSet    ApplicationKind = "ResourceSet"
)

type Flux struct {
	Repositories   map[ApplicationId]*FluxRepository
	HelmCharts     map[ApplicationId]*FluxHelmChart
	HelmReleases   map[ApplicationId]*FluxHelmRelease
	Kustomizations map[ApplicationId]*FluxKustomization
	ResourceSets   map[ApplicationId]*FluxResourceSet
}

func NewFlux() *Flux {
	return &Flux{
		Repositories:   make(map[ApplicationId]*FluxRepository),
		HelmCharts:     make(map[ApplicationId]*FluxHelmChart),
		HelmReleases:   make(map[ApplicationId]*FluxHelmRelease),
		Kustomizations: make(map[ApplicationId]*FluxKustomization),
		ResourceSets:   make(map[ApplicationId]*FluxResourceSet),
	}
}

func (f *Flux) Merge(other *Flux) {
	maps.Copy(f.Repositories, other.Repositories)
	maps.Copy(f.HelmCharts, other.HelmCharts)
	maps.Copy(f.HelmReleases, other.HelmReleases)
	maps.Copy(f.Kustomizations, other.Kustomizations)
	maps.Copy(f.ResourceSets, other.ResourceSets)
}

type FluxStatus struct {
	Status Status
	Reason LabelLastValue
}

type FluxRepository struct {
	Ready     FluxStatus
	Url       LabelLastValue
	Interval  LabelLastValue
	Suspended bool
}

type FluxHelmChart struct {
	Ready        FluxStatus
	Chart        string
	Version      string
	Interval     string
	RepositoryId ApplicationId
	LastInfo     timeseries.Time
	Suspended    bool
}

type FluxHelmRelease struct {
	Ready           FluxStatus
	LastInfo        timeseries.Time
	TargetNamespace string
	Chart           string
	Version         string
	Interval        string
	RepositoryId    ApplicationId
	Suspended       bool
}

type FluxKustomization struct {
	Ready                 FluxStatus
	LastInfo              timeseries.Time
	TargetNamespace       string
	Path                  string
	Interval              string
	LastAppliedRevision   string
	LastAttemptedRevision string
	RepositoryId          ApplicationId
	DependsOn             map[ApplicationId]*FluxKustomization
	InventoryEntries      map[ApplicationId]bool
	Suspended             bool
}

type FluxResourceSet struct {
	LastAppliedRevision LabelLastValue
	Ready               FluxStatus
	DependsOn           map[ApplicationId]bool
	InventoryEntries    map[ApplicationId]bool
}