helm_resources_manager

Documentation

Index

• type HelmResourcesManager
  • func NewHelmResourcesManager() HelmResourcesManager
• type MockHelmResourcesManager
  • func (h *MockHelmResourcesManager) AbsentResources(moduleName string) ([]manifest.Manifest, error)
  • func (h *MockHelmResourcesManager) Ch() chan AbsentResourcesEvent
  • func (h *MockHelmResourcesManager) GetAbsentResources(templates []manifest.Manifest, defaultNamespace string) ([]manifest.Manifest, error)
  • func (h *MockHelmResourcesManager) GetMonitor(moduleName string) *ResourcesMonitor
  • func (h *MockHelmResourcesManager) HasMonitor(moduleName string) bool
  • func (h *MockHelmResourcesManager) PauseMonitor(moduleName string)
  • func (h *MockHelmResourcesManager) PauseMonitors()
  • func (h *MockHelmResourcesManager) ResumeMonitor(moduleName string)
  • func (h *MockHelmResourcesManager) ResumeMonitors()
  • func (h *MockHelmResourcesManager) StartMonitor(moduleName string, manifests []manifest.Manifest, defaultNamespace string)
  • func (h *MockHelmResourcesManager) Stop()
  • func (h *MockHelmResourcesManager) StopMonitor(moduleName string)
  • func (h *MockHelmResourcesManager) StopMonitors()
  • func (h *MockHelmResourcesManager) WithContext(ctx context.Context)
  • func (h *MockHelmResourcesManager) WithDefaultNamespace(namespace string)
  • func (h *MockHelmResourcesManager) WithKubeClient(client klient.Client)
• type ResourcesMonitor
  • func NewResourcesMonitor() *ResourcesMonitor
  • func (r *ResourcesMonitor) AbsentResources() ([]manifest.Manifest, error)
  • func (r *ResourcesMonitor) Pause()
  • func (r *ResourcesMonitor) ResourceIds() []string
  • func (r *ResourcesMonitor) Resume()
  • func (r *ResourcesMonitor) Start()
  • func (r *ResourcesMonitor) Stop()
  • func (r *ResourcesMonitor) WithAbsentCb(cb func(string, []manifest.Manifest, string))
  • func (r *ResourcesMonitor) WithContext(ctx context.Context)
  • func (r *ResourcesMonitor) WithDefaultNamespace(ns string)
  • func (r *ResourcesMonitor) WithKubeClient(client klient.Client)
  • func (r *ResourcesMonitor) WithLogLabels(logLabels map[string]string)
  • func (r *ResourcesMonitor) WithManifests(manifests []manifest.Manifest)
  • func (r *ResourcesMonitor) WithModuleName(name string)

Types

type HelmResourcesManager

type HelmResourcesManager interface {
	WithContext(ctx context.Context)
	WithKubeClient(client klient.Client)
	WithDefaultNamespace(namespace string)
	Stop()
	StopMonitors()
	PauseMonitors()
	ResumeMonitors()
	StartMonitor(moduleName string, manifests []manifest.Manifest, defaultNamespace string)
	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 AbsentResourcesEvent
}

func NewHelmResourcesManager

func NewHelmResourcesManager() HelmResourcesManager

type MockHelmResourcesManager

type MockHelmResourcesManager struct {
	MonitorsNames []string
}

func (*MockHelmResourcesManager) AbsentResources

func (h *MockHelmResourcesManager) AbsentResources(moduleName string) ([]manifest.Manifest, error)

func (*MockHelmResourcesManager) Ch

func (h *MockHelmResourcesManager) Ch() chan AbsentResourcesEvent

func (*MockHelmResourcesManager) GetAbsentResources

func (h *MockHelmResourcesManager) GetAbsentResources(templates []manifest.Manifest, defaultNamespace string) ([]manifest.Manifest, error)

func (*MockHelmResourcesManager) GetMonitor

func (h *MockHelmResourcesManager) GetMonitor(moduleName string) *ResourcesMonitor

func (*MockHelmResourcesManager) HasMonitor

func (h *MockHelmResourcesManager) HasMonitor(moduleName string) bool

func (*MockHelmResourcesManager) PauseMonitor

func (h *MockHelmResourcesManager) PauseMonitor(moduleName string)

func (*MockHelmResourcesManager) PauseMonitors

func (h *MockHelmResourcesManager) PauseMonitors()

func (*MockHelmResourcesManager) ResumeMonitor

func (h *MockHelmResourcesManager) ResumeMonitor(moduleName string)

func (*MockHelmResourcesManager) ResumeMonitors

func (h *MockHelmResourcesManager) ResumeMonitors()

func (*MockHelmResourcesManager) StartMonitor

func (h *MockHelmResourcesManager) StartMonitor(moduleName string, manifests []manifest.Manifest, defaultNamespace string)

func (*MockHelmResourcesManager) Stop

func (h *MockHelmResourcesManager) Stop()

func (*MockHelmResourcesManager) StopMonitor

func (h *MockHelmResourcesManager) StopMonitor(moduleName string)

func (*MockHelmResourcesManager) StopMonitors

func (h *MockHelmResourcesManager) StopMonitors()

func (*MockHelmResourcesManager) WithContext

func (h *MockHelmResourcesManager) WithContext(ctx context.Context)

func (*MockHelmResourcesManager) WithDefaultNamespace

func (h *MockHelmResourcesManager) WithDefaultNamespace(namespace string)

func (*MockHelmResourcesManager) WithKubeClient

func (h *MockHelmResourcesManager) WithKubeClient(client klient.Client)

type ResourcesMonitor

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

func NewResourcesMonitor

func NewResourcesMonitor() *ResourcesMonitor

func (*ResourcesMonitor) AbsentResources

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

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 manifests are present in cluster.

func (*ResourcesMonitor) Stop

func (r *ResourcesMonitor) Stop()

func (*ResourcesMonitor) WithAbsentCb

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

func (*ResourcesMonitor) WithContext

func (r *ResourcesMonitor) WithContext(ctx context.Context)

func (*ResourcesMonitor) WithDefaultNamespace

func (r *ResourcesMonitor) WithDefaultNamespace(ns string)

func (*ResourcesMonitor) WithKubeClient

func (r *ResourcesMonitor) WithKubeClient(client klient.Client)

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)