helm_resources_manager

Documentation

Index

• type HelmResourcesManager
  • func NewHelmResourcesManager(ctx context.Context, kclient *klient.Client, logger *log.Logger) (HelmResourcesManager, error)
• type ResourceMonitorConfig
• type ResourcesMonitor
  • func NewResourcesMonitor(ctx context.Context, cfg *ResourceMonitorConfig) *ResourcesMonitor
  • func (r *ResourcesMonitor) AbsentResources() ([]manifest.Manifest, error)
  • func (r *ResourcesMonitor) GetHelmReleaseStatus(moduleName string) (string, error)
  • func (r *ResourcesMonitor) Pause()
  • func (r *ResourcesMonitor) ResourceIds() []string
  • func (r *ResourcesMonitor) Resume()
  • func (r *ResourcesMonitor) Start()
  • func (r *ResourcesMonitor) Stop()

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 ResourceMonitorConfig

type ResourceMonitorConfig struct {
	ModuleName       string
	Manifests        []manifest.Manifest
	DefaultNamespace string

	KubeClient *klient.Client
	Cache      cr_cache.Cache

	AbsentCb func(moduleName string, unexpectedStatus bool, absent []manifest.Manifest, defaultNs string)

	HelmStatusGetter func(releaseName string) (revision string, status string, err error)

	Logger *log.Logger
}

type ResourcesMonitor

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

func NewResourcesMonitor

func NewResourcesMonitor(ctx context.Context, cfg *ResourceMonitorConfig) *ResourcesMonitor

func (*ResourcesMonitor) AbsentResources

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

func (*ResourcesMonitor) GetHelmReleaseStatus

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()