Versions in this module Expand all Collapse all v0 v0.0.1 Jun 26, 2024 Changes in this version + type BasicModule struct + Name string + Order uint32 + Path string + func NewBasicModule(name, path string, order uint32, staticValues utils.Values, ...) (*BasicModule, error) + func (bm *BasicModule) ApplyNewStaticValues(values utils.Values) error + func (bm *BasicModule) DeregisterHooks() + func (bm *BasicModule) GenerateNewConfigValues(kubeConfigValues utils.Values, validate bool) (utils.Values, error) + func (bm *BasicModule) GetConfigValues(withPrefix bool) utils.Values + func (bm *BasicModule) GetEnabledScriptResult() *bool + func (bm *BasicModule) GetHookByName(name string) *hooks.ModuleHook + func (bm *BasicModule) GetHookErrorsSummary() string + func (bm *BasicModule) GetHooks(bt ...sh_op_types.BindingType) []*hooks.ModuleHook + func (bm *BasicModule) GetLastHookError() error + func (bm *BasicModule) GetModuleError() error + func (bm *BasicModule) GetName() string + func (bm *BasicModule) GetOrder() uint32 + func (bm *BasicModule) GetPath() string + func (bm *BasicModule) GetPhase() ModuleRunPhase + func (bm *BasicModule) GetSchemaStorage() *validation.SchemaStorage + func (bm *BasicModule) GetStaticValues() utils.Values + func (bm *BasicModule) GetValues(withPrefix bool) utils.Values + func (bm *BasicModule) GetValuesPatches() []utils.ValuesPatch + func (bm *BasicModule) GetValuesStorage() *ValuesStorage + func (bm *BasicModule) HasKubernetesHooks() bool + func (bm *BasicModule) HooksControllersReady() bool + func (bm *BasicModule) RegisterHooks(logger *log.Entry) ([]*hooks.ModuleHook, error) + func (bm *BasicModule) ResetState() + func (bm *BasicModule) RunEnabledScript(tmpDir string, precedingEnabledModules []string, logLabels map[string]string) (bool, error) + func (bm *BasicModule) RunHookByName(hookName string, binding sh_op_types.BindingType, ...) (string, string, error) + func (bm *BasicModule) RunHooksByBinding(binding sh_op_types.BindingType, logLabels map[string]string) error + func (bm *BasicModule) SaveConfigValues(configV utils.Values) + func (bm *BasicModule) SaveHookError(hookName string, err error) + func (bm *BasicModule) SetError(err error) + func (bm *BasicModule) SetHooksControllersReady() + func (bm *BasicModule) SetPhase(phase ModuleRunPhase) + func (bm *BasicModule) SetStateEnabled(e bool) + func (bm *BasicModule) Synchronization() *SynchronizationState + func (bm *BasicModule) SynchronizationNeeded() bool + func (bm *BasicModule) Validate() error + func (bm *BasicModule) ValidateConfigValues() error + func (bm *BasicModule) ValidateValues() error + func (bm *BasicModule) WithDependencies(dep *hooks.HookExecutionDependencyContainer) + type EnabledPatchReport struct + Done chan error + Patch utils.ValuesPatch + type GlobalModule struct + func NewGlobalModule(hooksDir string, staticValues utils.Values, ...) (*GlobalModule, error) + func (gm *GlobalModule) EnabledReportChannel() chan *EnabledPatchReport + func (gm *GlobalModule) GenerateNewConfigValues(kubeConfigValues utils.Values, validate bool) (utils.Values, error) + func (gm *GlobalModule) GetConfigValues(withPrefix bool) utils.Values + func (gm *GlobalModule) GetHookByName(name string) *hooks.GlobalHook + func (gm *GlobalModule) GetHooks(bt ...sh_op_types.BindingType) []*hooks.GlobalHook + func (gm *GlobalModule) GetName() string + func (gm *GlobalModule) GetSchemaStorage() *validation.SchemaStorage + func (gm *GlobalModule) GetValues(withPrefix bool) utils.Values + func (gm *GlobalModule) GetValuesPatches() []utils.ValuesPatch + func (gm *GlobalModule) RegisterHooks() ([]*hooks.GlobalHook, error) + func (gm *GlobalModule) RunHookByName(hookName string, binding sh_op_types.BindingType, ...) (string, string, error) + func (gm *GlobalModule) SaveConfigValues(configV utils.Values) + func (gm *GlobalModule) SetEnabledModules(enabledModules []string) + type HelmModule struct + func NewHelmModule(bm *BasicModule, tmpDir string, deps *HelmModuleDependencies, ...) (*HelmModule, error) + func (hm *HelmModule) PrepareValuesYamlFile() (string, error) + func (hm *HelmModule) Render(namespace string, debug bool) (string, error) + func (hm *HelmModule) RunHelmInstall(logLabels map[string]string) error + type HelmModuleDependencies struct + HelmClientFactory *helm.ClientFactory + HelmResourceManager HelmResourceManager + HelmValuesValidator HelmValuesValidator + MetricsStorage MetricsStorage + type HelmResourceManager interface + GetAbsentResources func(manifests []manifest.Manifest, defaultNamespace string) ([]manifest.Manifest, error) + HasMonitor func(moduleName string) bool + StartMonitor func(moduleName string, manifests []manifest.Manifest, defaultNamespace string) + type HelmValuesValidator interface + ValidateModuleHelmValues func(string, utils.Values) error + type HooksStorage struct + func (hs *HooksStorage) AddHook(hk *hooks.ModuleHook) + type MetricsStorage interface + HistogramObserve func(metric string, value float64, labels map[string]string, buckets []float64) + type ModuleRunPhase string + const CanRunHelm + const EnableScheduleBindings + const HooksDisabled + const OnStartupDone + const QueueSynchronizationTasks + const Startup + const WaitForSynchronization + 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) + type ValuesStorage struct + func NewValuesStorage(moduleName string, staticValues utils.Values, configBytes, valuesBytes []byte) (*ValuesStorage, error) + func (vs *ValuesStorage) CommitValues() error + func (vs *ValuesStorage) GenerateNewConfigValues(configV utils.Values, validate bool) (utils.Values, error) + func (vs *ValuesStorage) GetConfigValues(withPrefix bool) utils.Values + func (vs *ValuesStorage) GetSchemaStorage() *validation.SchemaStorage + func (vs *ValuesStorage) GetValues(withPrefix bool) utils.Values + func (vs *ValuesStorage) SaveConfigValues(configV utils.Values)
Go to main page