homelab/pkg/cnpg/helm.go

package cnpg

import (
	"time"

	"danicos.dev/daniel/go-kube/pkg/flux"
	"danicos.dev/daniel/homelab/pkg/root"

	helm "github.com/fluxcd/helm-controller/api/v2"
	source "github.com/fluxcd/source-controller/api/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func HelmSource() source.HelmRepository {
	spec := source.HelmRepositorySpec{
		Interval: durHour(root.FLUX_HELM_MONITORING_INTERVAL),
		URL:      root.HELM_CLOUD_NATIVE_PG_URL,
	}
	return flux.NewFluxHelmRepositorySource(meta, spec)
}

func HelmRelease() helm.HelmRelease {
	interval := durHour(12)
	spec := helm.HelmReleaseSpec{
		Interval: durMin(30),
		Chart: &helm.HelmChartTemplate{
			Spec: helm.HelmChartTemplateSpec{
				Chart:    root.HELM_CLOUD_NATIVE_PG_CHART,
				Version:  root.HELM_CLOUD_NATIVE_PG_CHART_VERSION,
				Interval: &interval,
				SourceRef: helm.CrossNamespaceObjectReference{
					Kind:      flux.MetaHelmRepository.Kind,
					Name:      meta.Meta().Name,
					Namespace: Namespace.Name,
				},
			},
		},
		Install: &helm.Install{CRDs: helm.Create},
		Upgrade: &helm.Upgrade{CRDs: helm.CreateReplace},
	}
	return flux.NewFluxHelmRelease(meta, spec)
}

func durHour(d int64) metav1.Duration {
	return metav1.Duration{Duration: (time.Duration(d) * time.Hour)}
}

func durMin(d int64) metav1.Duration {
	return metav1.Duration{Duration: (time.Duration(d) * time.Minute)}
}