Versions in this module Expand all Collapse all v0 v0.0.1 Jun 26, 2024 Changes in this version + type DirectoryConfig struct + GlobalHooksDir string + ModulesDir string + TempDir string + type KubeConfigManager interface + IsModuleEnabled func(moduleName string) bool + SafeReadConfig func(handler func(config *config.KubeConfig)) + SaveConfigValues func(key string, values utils.Values) error + UpdateModuleConfig func(moduleName string) error + type ModuleManager struct + GlobalHooksDir string + ModulesDir string + TempDir string + func NewModuleManager(ctx context.Context, cfg *ModuleManagerConfig) *ModuleManager + func (mm *ModuleManager) AddEnabledModuleByConfigName(name string) + func (mm *ModuleManager) AddEnabledModuleName(name string) + func (mm *ModuleManager) ApplyBindingActions(moduleHook *hooks.ModuleHook, bindingActions []go_hook.BindingAction) error + func (mm *ModuleManager) AreModulesInited() bool + func (mm *ModuleManager) DeleteEnabledModuleByConfigName(name string) + func (mm *ModuleManager) DeleteEnabledModuleName(name string) + func (mm *ModuleManager) DeleteModule(moduleName string, logLabels map[string]string) error + func (mm *ModuleManager) DisableModuleHooks(moduleName string) + func (mm *ModuleManager) DumpDynamicEnabled() string + func (mm *ModuleManager) DynamicEnabledChecksum() string + func (mm *ModuleManager) EnableModuleScheduleBindings(moduleName string) + func (mm *ModuleManager) GetDependencies() *ModuleManagerDependencies + func (mm *ModuleManager) GetEnabledModuleNames() []string + func (mm *ModuleManager) GetGlobal() *modules.GlobalModule + func (mm *ModuleManager) GetGlobalHook(name string) *hooks.GlobalHook + func (mm *ModuleManager) GetGlobalHooksInOrder(bindingType BindingType) []string + func (mm *ModuleManager) GetGlobalHooksNames() []string + func (mm *ModuleManager) GetKubeConfigValid() bool + func (mm *ModuleManager) GetModule(name string) *modules.BasicModule + func (mm *ModuleManager) GetModuleEventsChannel() chan events.ModuleEvent + func (mm *ModuleManager) GetModuleNames() []string + func (mm *ModuleManager) GlobalSynchronizationNeeded() bool + func (mm *ModuleManager) GlobalSynchronizationState() *modules.SynchronizationState + func (mm *ModuleManager) HandleGlobalEnableKubernetesBindings(hookName string, ...) error + func (mm *ModuleManager) HandleKubeEvent(kubeEvent KubeEvent, ...) + func (mm *ModuleManager) HandleModuleEnableKubernetesBindings(moduleName string, ...) error + func (mm *ModuleManager) HandleNewKubeConfig(kubeConfig *config.KubeConfig) (*ModulesState, error) + func (mm *ModuleManager) HandleScheduleEvent(crontab string, ...) error + func (mm *ModuleManager) Init() error + func (mm *ModuleManager) IsModuleEnabled(moduleName string) bool + func (mm *ModuleManager) LoopByBinding(binding BindingType, ...) + func (mm *ModuleManager) PushConvergeModulesTask(moduleName, moduleState string) + func (mm *ModuleManager) PushDeleteModuleTask(moduleName string) + func (mm *ModuleManager) PushRunModuleTask(moduleName string, doModuleStartup bool) error + func (mm *ModuleManager) RefreshEnabledState(logLabels map[string]string) (*ModulesState, error) + func (mm *ModuleManager) RefreshStateFromHelmReleases(logLabels map[string]string) (*ModulesState, error) + func (mm *ModuleManager) RegisterModule(moduleSource, modulePath string) error + func (mm *ModuleManager) RegisterModuleHooks(ml *modules.BasicModule, logLabels map[string]string) error + func (mm *ModuleManager) RunGlobalHook(hookName string, binding BindingType, bindingContext []BindingContext, ...) (string, string, error) + func (mm *ModuleManager) RunModule(moduleName string, logLabels map[string]string) (bool, error) + func (mm *ModuleManager) RunModuleHook(moduleName, hookName string, binding BindingType, ...) (beforeChecksum string, afterChecksum string, err error) + func (mm *ModuleManager) RunModuleHooks(m *modules.BasicModule, bt sh_op_types.BindingType, ...) error + func (mm *ModuleManager) RunModuleWithNewStaticValues(moduleName, moduleSource, modulePath string) error + func (mm *ModuleManager) SendModuleEvent(ev events.ModuleEvent) + func (mm *ModuleManager) SetKubeConfigValid(valid bool) + func (mm *ModuleManager) SetKubeConfigValuesValid(valid bool) + func (mm *ModuleManager) SetModuleEventsChannel(ec chan events.ModuleEvent) + func (mm *ModuleManager) SetModuleLoader(ld loader.ModuleLoader) + func (mm *ModuleManager) SetModulePhaseAndNotify(module *modules.BasicModule, phase modules.ModuleRunPhase) + func (mm *ModuleManager) Start() + func (mm *ModuleManager) Stop() + func (mm *ModuleManager) UpdateModuleHookStatusAndNotify(module *modules.BasicModule, hookName string, err error) + func (mm *ModuleManager) UpdateModuleKubeConfig(moduleName string) error + func (mm *ModuleManager) UpdateModuleLastErrorAndNotify(module *modules.BasicModule, err error) + type ModuleManagerConfig struct + Dependencies ModuleManagerDependencies + DirectoryConfig DirectoryConfig + 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 + TaskQueues *queue.TaskQueueSet + type ModulesState struct + AllEnabledModules []string + ModulesToDisable []string + ModulesToEnable []string + ModulesToPurge []string + ModulesToReload []string
Go to main page