modules

Oct 4, 2024

Changes in this version

type BasicModule

+ func (bm *BasicModule) CRDExist() bool

+ func (bm *BasicModule) GetCRDFilesPaths() []string

type GlobalModule

+ func (gm *GlobalModule) SetAvailableAPIVersions(apiVersions []string)

type SynchronizationState

+ func (s *SynchronizationState) IsCompleted() bool

Jul 3, 2024

Changes in this version

type BasicModule

+ func (bm *BasicModule) ApplyNewSchemaStorage(schema *validation.SchemaStorage) error

Jun 27, 2024

Changes in this version

type BasicModule

+ func (bm *BasicModule) GetSchemaStorage() *validation.SchemaStorage

+ func (bm *BasicModule) GetValuesStorage() *ValuesStorage

+ func (bm *BasicModule) Validate() error

+ func (bm *BasicModule) ValidateConfigValues() error

+ func (bm *BasicModule) ValidateValues() error

type GlobalModule

+ func (gm *GlobalModule) GetSchemaStorage() *validation.SchemaStorage

type ValuesStorage

+ func (vs *ValuesStorage) GetSchemaStorage() *validation.SchemaStorage

Apr 23, 2024

Changes in this version

type BasicModule

+ func (bm *BasicModule) ApplyNewStaticValues(values utils.Values) error

+ func (bm *BasicModule) GetStaticValues() utils.Values

Mar 28, 2024

Changes in this version

type BasicModule

+ func (bm *BasicModule) GetEnabledScriptResult() *bool

+ func (bm *BasicModule) GetHookErrorsSummary() string

Mar 5, 2024

Changes in this version

type BasicModule

+ func (bm *BasicModule) HooksControllersReady() bool

+ func (bm *BasicModule) SetHooksControllersReady()

type ModuleRunPhase

+ const HooksDisabled

Dec 19, 2023

Changes in this version

type GlobalModule

+ func (gm *GlobalModule) SetEnabledModules(enabledModules []string)

Nov 30, 2023

Changes in this version

+ type BasicModule struct

+ Name string

+ Order uint32

+ Path string

+ func NewBasicModule(name, path string, order uint32, staticValues utils.Values, ...) *BasicModule

+ 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) GetHookByName(name string) *hooks.ModuleHook

+ 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) GetValues(withPrefix bool) utils.Values

+ func (bm *BasicModule) GetValuesPatches() []utils.ValuesPatch

+ func (bm *BasicModule) HasKubernetesHooks() 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) SetPhase(phase ModuleRunPhase)

+ func (bm *BasicModule) SetStateEnabled(e bool)

+ func (bm *BasicModule) Synchronization() *SynchronizationState

+ func (bm *BasicModule) SynchronizationNeeded() bool

+ 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, validator validator, ...) *GlobalModule

+ 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) 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)

+ 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 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, validator validator) *ValuesStorage

+ 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) GetValues(withPrefix bool) utils.Values

+ func (vs *ValuesStorage) SaveConfigValues(configV utils.Values)