Documentation ¶
Index ¶
- type HelmResourcesManager
- type 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()
- func (r *ResourcesMonitor) WithAbsentCb(cb func(string, bool, []manifest.Manifest, string))
- func (r *ResourcesMonitor) WithDefaultNamespace(ns string)
- func (r *ResourcesMonitor) WithLogLabels(logLabels map[string]string)
- func (r *ResourcesMonitor) WithManifests(manifests []manifest.Manifest)
- func (r *ResourcesMonitor) WithModuleName(name string)
- func (r *ResourcesMonitor) WithStatusGetter(...)
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 ¶
type ResourcesMonitor ¶
type ResourcesMonitor struct {
// contains filtered or unexported fields
}
func NewResourcesMonitor ¶
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 (*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))
Click to show internal directories.
Click to hide internal directories.