Documentation
¶
Index ¶
- type HelmResourcesManager
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 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)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.