helm_resources_manager

package
v1.5.0-slog4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2024 License: Apache-2.0 Imports: 17 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HelmResourcesManager 

type HelmResourcesManager interface {
	WithDefaultNamespace(namespace string)
	Stop()
	StopMonitors()
	PauseMonitors()
	ResumeMonitors()
	StartMonitor(moduleName string, manifests []manifest.Manifest, defaultNamespace string, LastReleaseStatus func(releaseName string) (revision string, status string, err error))
	HasMonitor(moduleName string) bool
	StopMonitor(moduleName string)
	PauseMonitor(moduleName string)
	ResumeMonitor(moduleName string)
	AbsentResources(moduleName string) ([]manifest.Manifest, error)
	GetMonitor(moduleName string) *ResourcesMonitor
	GetAbsentResources(templates []manifest.Manifest, defaultNamespace string) ([]manifest.Manifest, error)
	Ch() chan ReleaseStatusEvent
}

func NewHelmResourcesManager 

func NewHelmResourcesManager(ctx context.Context, kclient *klient.Client, logger *log.Logger) (HelmResourcesManager, error)

type ResourcesMonitor 

type ResourcesMonitor struct {
	// contains filtered or unexported fields
}

func NewResourcesMonitor 

func NewResourcesMonitor(ctx context.Context, kclient *klient.Client, cache cr_cache.Cache, logger *log.Logger) *ResourcesMonitor

func (*ResourcesMonitor) AbsentResources 

func (r *ResourcesMonitor) AbsentResources() ([]manifest.Manifest, error)

func (*ResourcesMonitor) GetHelmReleaseStatus added in v1.4.3 

func (r *ResourcesMonitor) GetHelmReleaseStatus(moduleName string) (string, error)

GetHelmReleaseStatus returns last release status

func (*ResourcesMonitor) Pause 

func (r *ResourcesMonitor) Pause()

Pause prevent execution of absent callback

func (*ResourcesMonitor) ResourceIds 

func (r *ResourcesMonitor) ResourceIds() []string

func (*ResourcesMonitor) Resume 

func (r *ResourcesMonitor) Resume()

Resume allows execution of absent callback

func (*ResourcesMonitor) Start 

func (r *ResourcesMonitor) Start()

Start creates a timer and check if all deployed manifests are present in the cluster.

func (*ResourcesMonitor) Stop 

func (r *ResourcesMonitor) Stop()

func (*ResourcesMonitor) WithAbsentCb 

func (r *ResourcesMonitor) WithAbsentCb(cb func(string, bool, []manifest.Manifest, string))

func (*ResourcesMonitor) WithDefaultNamespace 

func (r *ResourcesMonitor) WithDefaultNamespace(ns string)

func (*ResourcesMonitor) WithLogLabels 

func (r *ResourcesMonitor) WithLogLabels(logLabels map[string]string)

func (*ResourcesMonitor) WithManifests 

func (r *ResourcesMonitor) WithManifests(manifests []manifest.Manifest)

func (*ResourcesMonitor) WithModuleName 

func (r *ResourcesMonitor) WithModuleName(name string)

func (*ResourcesMonitor) WithStatusGetter added in v1.4.3 

func (r *ResourcesMonitor) WithStatusGetter(lastReleaseStatus func(releaseName string) (revision string, status string, err error))

Source Files

View all Source files

Directories

Path Synopsis
test
mock

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.