helm_resources_manager

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
	KubeClient() *klient.Client
}

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 struct {
	// contains filtered or unexported fields
}