module_manager

Jul 15, 2025

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) GetCritical(moduleName string) bool

+ func (mm *ModuleManager) GetFunctionalDependencies() map[string][]string

Apr 25, 2025

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) CreateTasksByBinding(binding BindingType, ...) []sh_task.Task

Apr 24, 2025

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) SetModuleMaintenanceState(moduleName string, state utils.Maintenance)

Mar 25, 2025

Changes in this version

type DirectoryConfig

+ ChrootDir string

type ModuleManager

+ func (mm *ModuleManager) AddObjectsToChrootEnvironment(objects ...environmentmanager.ObjectDescriptor)

+ func (mm *ModuleManager) EnvironmentManagerEnabled() bool

+ func (mm *ModuleManager) GetGraphDOTDescription() ([]byte, error)

Nov 5, 2024

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) UpdateModulesMetrics()

Oct 4, 2024

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) ModuleHasCRDs(moduleName string) bool

+ func (mm *ModuleManager) SetGlobalDiscoveryAPIVersions(apiVersions []string)

type ModulesState

+ AllEnabledModulesByOrder map[node.NodeWeight][]string

Aug 30, 2024

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) GetUpdatedByExtender(moduleName string) (string, error)

Jul 3, 2024

Changes in this version

type KubeConfigManager

+ KubeConfigEventCh func() chan config.KubeConfigEvent

type ModuleManager

+ func (mm *ModuleManager) AddExtender(ex extenders.Extender) error

+ func (mm *ModuleManager) ApplyNewKubeConfigValues(kubeConfig *config.KubeConfig, globalValuesChanged bool) error

+ func (mm *ModuleManager) FilterModuleByExtender(extName extenders.ExtenderName, moduleName string, logLabels map[string]string) (*bool, error)

+ func (mm *ModuleManager) GetGraphImage() (image.Image, error)

+ func (mm *ModuleManager) RecalculateGraph(logLabels map[string]string) bool

+ func (mm *ModuleManager) RunModuleWithNewOpenAPISchema(moduleName, moduleSource, modulePath string) error

+ func (mm *ModuleManager) SchedulerEventCh() chan extenders.ExtenderEvent

Apr 23, 2024

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) RunModuleWithNewStaticValues(moduleName, moduleSource, modulePath string) error

Mar 28, 2024

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) SetModuleEventsChannel(ec chan events.ModuleEvent)

+ func (mm *ModuleManager) SetModulePhaseAndNotify(module *modules.BasicModule, phase modules.ModuleRunPhase)

+ func (mm *ModuleManager) UpdateModuleHookStatusAndNotify(module *modules.BasicModule, hookName string, err error)

+ func (mm *ModuleManager) UpdateModuleLastErrorAndNotify(module *modules.BasicModule, err error)

Mar 5, 2024

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) PushConvergeModulesTask(moduleName, moduleState string)

+ func (mm *ModuleManager) PushDeleteModuleTask(moduleName string)

+ func (mm *ModuleManager) PushRunModuleTask(moduleName string) error

+ func (mm *ModuleManager) RegisterModule(moduleSource, modulePath string) error

+ func (mm *ModuleManager) UpdateModuleKubeConfig(moduleName string) error

Jan 12, 2024

Changes in this version

type KubeConfigManager

+ IsModuleEnabled func(moduleName string) bool

+ SafeReadConfig func(handler func(config *config.KubeConfig))

+ UpdateModuleConfig func(moduleName string) error

type ModuleManager

+ func (mm *ModuleManager) AddEnabledModuleByConfigName(name string)

+ func (mm *ModuleManager) AddEnabledModuleName(name string)

+ func (mm *ModuleManager) AreModulesInited() bool

+ func (mm *ModuleManager) DeleteEnabledModuleByConfigName(name string)

+ func (mm *ModuleManager) DeleteEnabledModuleName(name string)

+ func (mm *ModuleManager) PushDeleteModule(moduleName string)

+ func (mm *ModuleManager) PushRerunModule(moduleName string) error

+ func (mm *ModuleManager) ReregisterModule(moduleName, modulePath string) error

type ModuleManagerDependencies

+ TaskQueues *queue.TaskQueueSet

Nov 30, 2023

Changes in this version

type ModuleManager

+ func (mm *ModuleManager) GetDependencies() *ModuleManagerDependencies

+ func (mm *ModuleManager) GetGlobal() *modules.GlobalModule

+ func (mm *ModuleManager) GetModuleEventsChannel() chan events.ModuleEvent

+ func (mm *ModuleManager) RunModuleHooks(m *modules.BasicModule, bt sh_op_types.BindingType, ...) error

+ func (mm *ModuleManager) SendModuleEvent(ev events.ModuleEvent)

+ func (mm *ModuleManager) SetModuleLoader(ld loader.ModuleLoader)

Oct 27, 2023

Changes in this version

type KubeConfigManager

+ SaveConfigValues func(key string, values utils.Values) error

type ModuleDefinition

+ Description string

type ModuleObject

+ SetDescription func(description string)

Jul 20, 2023

Changes in this version

+ const ModuleDefinitionFileName

type Module

+ Tags []string

+ func NewModuleWithNameValidation(name, path string, order int) (*Module, error)

+ type ModuleDefinition struct

+ Tags []string

+ Weight int

type ModuleManager

+ func (mm *ModuleManager) ValidateModule(module *Module) error

type ModuleObject

+ SetTags func(tags []string)

May 25, 2023

Changes in this version

type Module

+ Source string

type ModuleManager

+ func (mm *ModuleManager) SetModuleSource(moduleName, source string)

+ func (mm *ModuleManager) SetupModuleProducer(producer ModuleProducer)

+ func (mm *ModuleManager) SyncModulesCR(client klient.Client) error

+ type ModuleManagerConfig struct

+ Dependencies ModuleManagerDependencies

+ DirectoryConfig DirectoryConfig

+ type ModuleObject interface

+ SetEnabledState func(state bool)

+ SetName func(name string)

+ SetSource func(source string)

+ SetWeight func(weight int)

+ type ModuleProducer interface

+ GetGVK func() schema.GroupVersionKind

+ NewModule func() ModuleObject

type ModuleSet

+ func (s *ModuleSet) Len() int

Apr 24, 2023

Changes in this version

+ const ModuleNameIdx

+ const ModuleOrderIdx

+ const PathsSeparator

+ const ValuesFileName

+ func LoadCommonStaticValues(modulesDirs string) (utils.Values, error)

+ type DirectoryConfig struct

+ GlobalHooksDir string

+ ModulesDir string

+ TempDir string

+ type KubeConfigManager interface

+ SaveGlobalConfigValues func(values utils.Values) error

+ SaveModuleConfigValues func(moduleName string, values utils.Values) error

type Module

+ Order int

type ModuleManager

+ GlobalHooksDir string

+ ModulesDir string

+ TempDir string

+ ValuesValidator *validation.ValuesValidator

+ func (mm *ModuleManager) ApplyBindingActions(moduleHook *ModuleHook, bindingActions []go_hook.BindingAction) error

+ func (mm *ModuleManager) DumpDynamicEnabled() string

+ func (mm *ModuleManager) LoopByBinding(binding BindingType, fn func(gh *GlobalHook, m *Module, mh *ModuleHook))

+ func (mm *ModuleManager) RegisterGlobalHooks() error

+ func (mm *ModuleManager) RegisterModules() error

+ func (mm *ModuleManager) SetKubeConfigValuesValid(valid bool)

+ func (mm *ModuleManager) Stop()

+ type ModuleManagerDependencies struct

+ Helm *helm.ClientFactory

+ HelmResourcesManager helm_resources_manager.HelmResourcesManager

+ HookMetricStorage *metric_storage.MetricStorage

+ KubeConfigManager KubeConfigManager

+ KubeEventsManager kube_events_manager.KubeEventsManager

+ KubeObjectPatcher *object_patch.ObjectPatcher

+ MetricStorage *metric_storage.MetricStorage

+ ScheduleManager schedule_manager.ScheduleManager

+ type ModuleSet struct

+ func (s *ModuleSet) Add(modules ...*Module)

+ func (s *ModuleSet) Get(name string) *Module

+ func (s *ModuleSet) Has(name string) bool

+ func (s *ModuleSet) List() []*Module

+ func (s *ModuleSet) NamesInOrder() []string

Dec 12, 2022

Changes in this version

type ModuleManager

+ GetModuleNames func() []string

+ GetValuesValidator func() *validation.ValuesValidator

type ModuleState

+ LastModuleErr error

+ func (s *ModuleState) GetLastHookErr() error

+ func (s *ModuleState) SetLastHookErr(hookName string, err error)

Aug 23, 2022

Changes in this version

+ func NewModuleManager() *moduleManager

type CommonHook

+ func (h *CommonHook) ShouldEnableSchedulesOnStartup() bool

type HookExecutor

+ Helm *helm.Helm

+ func (e *HookExecutor) WithHelm(helm *helm.Helm)

type Module

+ func (m *Module) WithHelm(helm *helm.Helm)

type ModuleManager

+ ApplyModuleDynamicValuesPatches func(moduleName string, values utils.Values) (utils.Values, error)

+ GetEnabledModuleNames func() []string

+ GetKubeConfigValid func() bool

+ HandleNewKubeConfig func(kubeConfig *kube_config_manager.KubeConfig) (*ModulesState, error)

+ IsModuleEnabled func(moduleName string) bool

+ ModuleConfigValues func(moduleName string) utils.Values

+ ModuleDynamicValuesPatches func(moduleName string) []utils.ValuesPatch

+ RefreshEnabledState func(logLabels map[string]string) (*ModulesState, error)

+ RefreshStateFromHelmReleases func(logLabels map[string]string) (*ModulesState, error)

+ SetKubeConfigValid func(valid bool)

+ WithHelm func(*helm.Helm)

type ModulesState

+ AllEnabledModules []string

+ ModulesToEnable []string

+ ModulesToPurge []string

+ ModulesToReload []string

Mar 22, 2022

Changes in this version

type KubernetesBindingSynchronizationState

+ BindingName string

+ HookName string

type Module

+ func (m *Module) HasKubernetesHooks() bool

type ModuleManager

+ EnableModuleScheduleBindings func(moduleName string)

+ GlobalSynchronizationState func() *SynchronizationState

+ type ModuleRunPhase string

+ const CanRunHelm

+ const EnableScheduleBindings

+ const OnStartupDone

+ const QueueSynchronizationTasks

+ const Startup

+ const WaitForSynchronization

type ModuleState

+ Phase ModuleRunPhase

+ func NewModuleState() *ModuleState

+ func (s *ModuleState) Synchronization() *SynchronizationState

+ type SynchronizationState struct

+ func NewSynchronizationState() *SynchronizationState

+ func (s *SynchronizationState) DebugDumpState(logEntry *log.Entry)

+ func (s *SynchronizationState) DoneForBinding(id string)

+ func (s *SynchronizationState) HasQueued() bool

+ func (s *SynchronizationState) IsComplete() bool

+ func (s *SynchronizationState) QueuedForBinding(metadata task.HookMetadata)

Feb 25, 2022

Changes in this version

type ModuleManager

+ GetGlobalHooksNames func() []string

Dec 15, 2021

Changes in this version

type ModuleState

+ Enabled bool

Dec 1, 2021

Changes in this version

type ModuleManager

+ UpdateGlobalConfigValues func(configValues utils.Values)

+ UpdateGlobalDynamicValuesPatches func(valuesPatch utils.ValuesPatch)

+ UpdateModuleConfigValues func(moduleName string, configValues utils.Values)

+ UpdateModuleDynamicValuesPatches func(moduleName string, valuesPatch utils.ValuesPatch)

Oct 18, 2021

Changes in this version

+ var ValidModuleNameRe = regexp.MustCompile(`^[0-9][0-9][0-9]-(.*)$`)

+ func CreateEmptyWritableFile(filePath string) error

+ func GetGlobalHookConfigSchema(version string) *spec.Schema

+ func GetModuleHookConfigSchema(version string) *spec.Schema

+ func MergeLayers(initial utils.Values, layers ...interface{}) utils.Values

+ func NewHookConfigFromGoConfig(input *go_hook.HookConfig) (config.HookConfig, error)

+ func NewMainModuleManager() *moduleManager

+ func ReadOpenAPIFiles(openApiDir string) (configSchemaBytes, valuesSchemaBytes []byte, err error)

+ type AfterAllConfig struct

+ Order float64

+ type AfterDeleteHelmConfig struct

+ Order float64

+ type AfterHelmConfig struct

+ Order float64

+ type ApplyDefaultsForGlobal struct

+ SchemaType validation.SchemaType

+ ValuesValidator *validation.ValuesValidator

+ func (a *ApplyDefaultsForGlobal) Transform(values utils.Values) utils.Values

+ type ApplyDefaultsForModule struct

+ ModuleValuesKey string

+ SchemaType validation.SchemaType

+ ValuesValidator *validation.ValuesValidator

+ func (a *ApplyDefaultsForModule) Transform(values utils.Values) utils.Values

+ type BeforeAllConfig struct

+ Order float64

+ type BeforeHelmConfig struct

+ Order float64

+ type ChangeType string

+ const Changed

+ type CommonHook struct

+ GoHook go_hook.GoHook

+ KubernetesBindingSynchronizationState map[string]*KubernetesBindingSynchronizationState

+ func (c *CommonHook) WithGoHook(h go_hook.GoHook)

+ func (c *CommonHook) WithModuleManager(moduleManager *moduleManager)

+ func (h *CommonHook) GetGoHook() go_hook.GoHook

+ func (h *CommonHook) GetName() string

+ func (h *CommonHook) GetPath() string

+ func (h *CommonHook) SynchronizationDone() bool

+ func (h *CommonHook) SynchronizationNeeded() bool

+ func (h *CommonHook) SynchronizationQueued() bool

+ type Event struct

+ ModulesChanges []ModuleChange

+ Type EventType

+ type EventType string

+ const AmbiguousState

+ const GlobalChanged

+ const ModulesChanged

+ type GlobalHook struct

+ Config *GlobalHookConfig

+ func NewGlobalHook(name, path string) *GlobalHook

+ func SearchGlobalGoHooks() (hooks []*GlobalHook, err error)

+ func SearchGlobalHooks(hooksDir string) (hooks []*GlobalHook, err error)

+ func SearchGlobalShellHooks(hooksDir string) (hooks []*GlobalHook, err error)

+ func (g *GlobalHook) Order(binding BindingType) float64

+ func (g *GlobalHook) WithConfig(configOutput []byte) (err error)

+ func (g *GlobalHook) WithGoConfig(config *go_hook.HookConfig) (err error)

+ func (gh *GlobalHook) GetConfigDescription() string

+ func (h *GlobalHook) GetConfigValues() utils.Values

+ func (h *GlobalHook) GetValues() (utils.Values, error)

+ func (h *GlobalHook) PrepareTmpFilesForHookRun(bindingContext []byte) (tmpFiles map[string]string, err error)

+ func (h *GlobalHook) Run(bindingType BindingType, bindingContext []BindingContext, ...) error

+ type GlobalHookConfig struct

+ AfterAll *AfterAllConfig

+ BeforeAll *BeforeAllConfig

+ GlobalV0 *GlobalHookConfigV0

+ GlobalV1 *GlobalHookConfigV0

+ func NewGlobalHookConfigFromGoConfig(input *go_hook.HookConfig) (*GlobalHookConfig, error)

+ func (c *GlobalHookConfig) Bindings() []BindingType

+ func (c *GlobalHookConfig) BindingsCount() int

+ func (c *GlobalHookConfig) ConvertAfterAll(value interface{}) (*AfterAllConfig, error)

+ func (c *GlobalHookConfig) ConvertAndCheck(data []byte) error

+ func (c *GlobalHookConfig) ConvertAndCheckV0() (err error)

+ func (c *GlobalHookConfig) ConvertAndCheckV1() (err error)

+ func (c *GlobalHookConfig) ConvertBeforeAll(value interface{}) (*BeforeAllConfig, error)

+ func (c *GlobalHookConfig) HasBinding(binding BindingType) bool

+ func (c *GlobalHookConfig) LoadAndValidate(data []byte) error

+ type GlobalHookConfigV0 struct

+ AfterAll interface{}

+ BeforeAll interface{}

+ type Hook interface

+ GetConfigValues func() utils.Values

+ GetGoHook func() go_hook.GoHook

+ GetName func() string

+ GetPath func() string

+ GetValues func() (utils.Values, error)

+ Order func(binding sh_op_types.BindingType) float64

+ PrepareTmpFilesForHookRun func(bindingContext []byte) (map[string]string, error)

+ WithConfig func(configOutput []byte) (err error)

+ WithGoConfig func(config *go_hook.HookConfig) (err error)

+ WithHookController func(hookController controller.HookController)

+ WithModuleManager func(moduleManager *moduleManager)

+ type HookExecutor struct

+ ConfigValuesPatchPath string

+ ConfigValuesPath string

+ ConfigVersion string

+ Context []BindingContext

+ ContextPath string

+ Hook Hook

+ KubernetesPatchPath string

+ LogLabels map[string]string

+ MetricsPath string

+ ObjectPatcher *object_patch.ObjectPatcher

+ ValuesPatchPath string

+ ValuesPath string

+ func NewHookExecutor(h Hook, context []BindingContext, configVersion string, ...) *HookExecutor

+ func (e *HookExecutor) Config() (configOutput []byte, err error)

+ func (e *HookExecutor) Run() (result *HookResult, err error)

+ func (e *HookExecutor) RunGoHook() (result *HookResult, err error)

+ func (e *HookExecutor) WithLogLabels(logLabels map[string]string)

+ type HookResult struct

+ BindingActions []go_hook.BindingAction

+ Metrics []metric_operation.MetricOperation

+ ObjectPatcherOperations []object_patch.Operation

+ Patches map[utils.ValuesPatchType]*utils.ValuesPatch

+ Usage *executor.CmdUsage

+ type KubernetesBindingSynchronizationState struct

+ Done bool

+ Queued bool

+ func (k *KubernetesBindingSynchronizationState) String() string

+ type Module struct

+ CommonStaticConfig *utils.ModuleConfig

+ IsReady bool

+ LastReleaseManifests []manifest.Manifest

+ Name string

+ Path string

+ State *ModuleState

+ StaticConfig *utils.ModuleConfig

+ func NewModule(name, path string) *Module

+ func SearchModules(modulesDir string) (modules []*Module, err error)

+ func (m *Module) ConfigValues() utils.Values

+ func (m *Module) Delete(logLabels map[string]string) error

+ func (m *Module) PrepareValuesYamlFile() (string, error)

+ func (m *Module) Run(logLabels map[string]string) (bool, error)

+ func (m *Module) RunOnStartup(logLabels map[string]string) error

+ func (m *Module) SafeName() string

+ func (m *Module) ShouldRunHelmUpgrade(helmClient client.HelmClient, releaseName string, checksum string, ...) (bool, error)

+ func (m *Module) StaticAndConfigValues() utils.Values

+ func (m *Module) StaticAndNewValues(newValues utils.Values) utils.Values

+ func (m *Module) SynchronizationDone() bool

+ func (m *Module) SynchronizationNeeded() bool

+ func (m *Module) SynchronizationQueued() bool

+ func (m *Module) Values() (utils.Values, error)

+ func (m *Module) ValuesForEnabledScript(precedingEnabledModules []string) (utils.Values, error)

+ func (m *Module) ValuesKey() string

+ func (m *Module) ValuesPatches() []utils.ValuesPatch

+ func (m *Module) WithMetricStorage(mstor *metric_storage.MetricStorage)

+ func (m *Module) WithModuleManager(moduleManager *moduleManager)

+ type ModuleChange struct

+ ChangeType ChangeType

+ Name string

+ type ModuleHook struct

+ Config *ModuleHookConfig

+ Module *Module

+ func NewModuleHook(name, path string) *ModuleHook

+ func SearchModuleGoHooks(module *Module) (hooks []*ModuleHook, err error)

+ func SearchModuleHooks(module *Module) (hooks []*ModuleHook, err error)

+ func SearchModuleShellHooks(module *Module) (hooks []*ModuleHook, err error)

+ func (h *ModuleHook) GetConfigValues() utils.Values

+ func (h *ModuleHook) GetValues() (utils.Values, error)

+ func (h *ModuleHook) PrepareTmpFilesForHookRun(bindingContext []byte) (tmpFiles map[string]string, err error)

+ func (h *ModuleHook) Run(bindingType BindingType, context []BindingContext, logLabels map[string]string, ...) error

+ func (m *ModuleHook) GetConfigDescription() string

+ func (m *ModuleHook) Order(binding BindingType) float64

+ func (m *ModuleHook) WithConfig(configOutput []byte) (err error)

+ func (m *ModuleHook) WithGoConfig(config *go_hook.HookConfig) (err error)

+ func (m *ModuleHook) WithModule(module *Module)

+ type ModuleHookConfig struct

+ AfterDeleteHelm *AfterDeleteHelmConfig

+ AfterHelm *AfterHelmConfig

+ BeforeHelm *BeforeHelmConfig

+ ModuleV0 *ModuleHookConfigV0

+ ModuleV1 *ModuleHookConfigV0

+ func NewModuleHookConfigFromGoConfig(input *go_hook.HookConfig) (*ModuleHookConfig, error)

+ func (c *ModuleHookConfig) Bindings() []BindingType

+ func (c *ModuleHookConfig) BindingsCount() int

+ func (c *ModuleHookConfig) ConvertAfterDeleteHelm(value interface{}) (*AfterDeleteHelmConfig, error)

+ func (c *ModuleHookConfig) ConvertAfterHelm(value interface{}) (*AfterHelmConfig, error)

+ func (c *ModuleHookConfig) ConvertAndCheck(data []byte) error

+ func (c *ModuleHookConfig) ConvertAndCheckV0() (err error)

+ func (c *ModuleHookConfig) ConvertAndCheckV1() (err error)

+ func (c *ModuleHookConfig) ConvertBeforeHelm(value interface{}) (*BeforeHelmConfig, error)

+ func (c *ModuleHookConfig) HasBinding(binding BindingType) bool

+ func (c *ModuleHookConfig) LoadAndValidate(data []byte) error

+ type ModuleHookConfigV0 struct

+ AfterDeleteHelm interface{}

+ AfterHelm interface{}

+ BeforeHelm interface{}

+ type ModuleManager interface

+ ApplyEnabledPatch func(enabledPatch utils.ValuesPatch) error

+ Ch func() chan Event

+ DeleteModule func(moduleName string, logLabels map[string]string) error

+ DisableModuleHooks func(moduleName string)

+ DiscoverModulesState func(logLabels map[string]string) (*ModulesState, error)

+ DumpState func()

+ DynamicEnabledChecksum func() string

+ GetGlobalHook func(name string) *GlobalHook

+ GetGlobalHooksInOrder func(bindingType BindingType) []string

+ GetModule func(name string) *Module

+ GetModuleHook func(name string) *ModuleHook

+ GetModuleHookNames func(moduleName string) []string

+ GetModuleHooksInOrder func(moduleName string, bindingType BindingType) []string

+ GetModuleNamesInOrder func() []string

+ GlobalConfigValues func() utils.Values

+ GlobalStaticAndConfigValues func() utils.Values

+ GlobalStaticAndNewValues func(newValues utils.Values) utils.Values

+ GlobalSynchronizationDone func() bool

+ GlobalSynchronizationNeeded func() bool

+ GlobalValues func() (utils.Values, error)

+ GlobalValuesPatches func() []utils.ValuesPatch

+ HandleGlobalEnableKubernetesBindings func(hookName string, ...) error

+ HandleKubeEvent func(kubeEvent KubeEvent, ...)

+ HandleModuleEnableKubernetesBindings func(hookName string, ...) error

+ HandleScheduleEvent func(crontab string, ...) error

+ Init func() error

+ RegisterModuleHooks func(module *Module, logLabels map[string]string) error

+ Retry func()

+ RunGlobalHook func(hookName string, binding BindingType, bindingContext []BindingContext, ...) (beforeChecksum string, afterChecksum string, err error)

+ RunModule func(moduleName string, onStartup bool, logLabels map[string]string, ...) (bool, error)

+ RunModuleHook func(hookName string, binding BindingType, bindingContext []BindingContext, ...) error

+ Start func()

+ StartModuleHooks func(moduleName string)

+ SynchronizationDone func(id string)

+ SynchronizationQueued func(id string)

+ WithContext func(ctx context.Context)

+ WithDirectories func(modulesDir string, globalHooksDir string, tempDir string) ModuleManager

+ WithHelmResourcesManager func(manager helm_resources_manager.HelmResourcesManager)

+ WithHookMetricStorage func(storage *metric_storage.MetricStorage)

+ WithKubeConfigManager func(kubeConfigManager kube_config_manager.KubeConfigManager) ModuleManager

+ WithKubeEventManager func(kube_events_manager.KubeEventsManager)

+ WithKubeObjectPatcher func(*object_patch.ObjectPatcher)

+ WithMetricStorage func(storage *metric_storage.MetricStorage)

+ WithScheduleManager func(schedule_manager.ScheduleManager)

+ type ModuleState struct

+ MonitorsStarted bool

+ OnStartupDone bool

+ ShouldWaitForSynchronization bool

+ SynchronizationDone bool

+ SynchronizationTasksQueued bool

+ WaitStarted bool

+ type ModulesState struct

+ EnabledModules []string

+ ModulesToDisable []string

+ NewlyEnabledModules []string

+ ReleasedUnknownModules []string

+ type ValuesTransform func(values utils.Values) utils.Values

+ type ValuesTransformer interface

+ Transform func(values utils.Values) utils.Values