addon_operator

Apr 10, 2024

Changes in this version

type AddonOperator

+ DebugServer *debug.Server

Mar 5, 2024

Changes in this version

type AddonOperator

+ LeaderElector *leaderelection.LeaderElector

+ MetricStorage *metric_storage.MetricStorage

+ func (op *AddonOperator) StartAPIServer()

+ func (op *AddonOperator) WithLeaderElector(config *leaderelection.LeaderElectionConfig) error

Dec 8, 2023

Changes in this version

type AddonOperator

+ func (op *AddonOperator) RegisterDiscoveryRoute(dbgSrv *debug.Server)

Oct 27, 2023

Changes in this version

type AddonOperator

+ func (op *AddonOperator) KubeClient() *client.Client

+ func (op *AddonOperator) Setup() error

+ func (op *AddonOperator) SetupKubeConfigManager(bk backend.ConfigHandler)

Sep 25, 2023

Changes in this version

type AddonOperator

+ ExplicitlyPurgeModules []string

May 25, 2023

Changes in this version

type AddonOperator

+ AdmissionServer *AdmissionServer

+ func (op *AddonOperator) EmitModulesSync()

+ func (op *AddonOperator) OnFirstConvergeDone()

+ type AdmissionServer struct

+ func NewAdmissionServer(listenPort, certsDir string) *AdmissionServer

+ func (as *AdmissionServer) RegisterHandler(route string, handler http.Handler)

Apr 24, 2023

Changes in this version

type AddonOperator

+ func (op *AddonOperator) Assemble(modulesDir string, globalHooksDir string, tempDir string, ...) (err error)

+ func (op *AddonOperator) RegisterDebugGlobalRoutes(dbgSrv *debug.Server)

+ func (op *AddonOperator) RegisterDebugModuleRoutes(dbgSrv *debug.Server)

+ func (op *AddonOperator) RegisterDefaultRoutes()

+ func (op *AddonOperator) SetupModuleManager(modulesDir string, globalHooksDir string, tempDir string, ...)

Dec 12, 2022

Changes in this version

+ func Bootstrap(op *AddonOperator) error

type AddonOperator

+ InitialKubeConfig *kube_config_manager.KubeConfig

Aug 23, 2022

Changes in this version

+ const ConvergeEventProp

+ func AssembleAddonOperator(op *AddonOperator, modulesDir string, globalHooksDir string, tempDir string, ...) (err error)

+ func ConvergeModulesInQueue(q *queue.TaskQueue) int

+ func ConvergeTasksInQueue(q *queue.TaskQueue) int

+ func DefaultHelmMonitorKubeClient(metricStorage *metric_storage.MetricStorage, metricLabels map[string]string) klient.Client

+ func DrainNonMainQueue(q *queue.TaskQueue)

+ func InitDefaultHelmResourcesManager(ctx context.Context, metricStorage *metric_storage.MetricStorage) (helm_resources_manager.HelmResourcesManager, error)

+ func IsConvergeTask(t sh_task.Task) bool

+ func IsFirstConvergeTask(t sh_task.Task) bool

+ func ModulesWithPendingModuleRun(q *queue.TaskQueue) map[string]struct

+ func NewConvergeModulesTask(description string, convergeEvent ConvergeEvent, logLabels map[string]string) sh_task.Task

+ func RegisterDebugGlobalRoutes(dbgSrv *debug.Server, op *AddonOperator)

+ func RegisterDebugModuleRoutes(dbgSrv *debug.Server, op *AddonOperator)

+ func RegisterDefaultRoutes(op *AddonOperator)

+ func RemoveAdjacentConvergeModules(q *queue.TaskQueue, afterId string)

+ func RemoveCurrentConvergeTasks(q *queue.TaskQueue, afterId string) bool

+ func SetupModuleManager(op *AddonOperator, modulesDir string, globalHooksDir string, tempDir string, ...)

+ func StartLiveTicksUpdater(metricStorage *metric_storage.MetricStorage)

+ func StartTasksQueueLengthUpdater(metricStorage *metric_storage.MetricStorage, tqs *queue.TaskQueueSet)

type AddonOperator

+ ConvergeState *ConvergeState

+ Helm *helm.Helm

+ func Init() (*AddonOperator, error)

+ func (op *AddonOperator) AllowHandleScheduleEvent(hook *module_manager.CommonHook) bool

+ func (op *AddonOperator) BootstrapMainQueue(tqs *queue.TaskQueueSet)

+ func (op *AddonOperator) CreateAfterAllTasks(logLabels map[string]string, eventDescription string) ([]sh_task.Task, error)

+ func (op *AddonOperator) CreateAndStartQueue(queueName string) bool

+ func (op *AddonOperator) CreateAndStartQueuesForAllModuleHooks()

+ func (op *AddonOperator) CreateAndStartQueuesForGlobalHooks()

+ func (op *AddonOperator) CreateAndStartQueuesForModuleHooks(moduleName string)

+ func (op *AddonOperator) CreateBeforeAllTasks(logLabels map[string]string, eventDescription string) []sh_task.Task

+ func (op *AddonOperator) CreateBootstrapTasks(logLabels map[string]string) []sh_task.Task

+ func (op *AddonOperator) CreateConvergeModulesTasks(state *module_manager.ModulesState, logLabels map[string]string, ...) []sh_task.Task

+ func (op *AddonOperator) CreatePurgeTasks(modulesToPurge []string, t sh_task.Task) []sh_task.Task

+ func (op *AddonOperator) CreateReloadModulesTasks(moduleNames []string, logLabels map[string]string, eventDescription string) []sh_task.Task

+ func (op *AddonOperator) HandleConvergeModules(t sh_task.Task, logLabels map[string]string) (res queue.TaskResult)

+ func (op *AddonOperator) HandleDiscoverHelmReleases(t sh_task.Task, labels map[string]string) (res queue.TaskResult)

+ func (op *AddonOperator) HandleGlobalHookEnableKubernetesBindings(t sh_task.Task, labels map[string]string) (res queue.TaskResult)

+ func (op *AddonOperator) HandleModuleDelete(t sh_task.Task, labels map[string]string) (status queue.TaskStatus)

+ func (op *AddonOperator) HandleModulePurge(t sh_task.Task, labels map[string]string) (status queue.TaskStatus)

+ func (op *AddonOperator) RegisterManagerEventsHandlers()

+ func (op *AddonOperator) UpdateFirstConvergeStatus(convergeTasks int)

+ type ConvergeEvent string

+ const GlobalValuesChanged

+ const KubeConfigChanged

+ const OperatorStartup

+ const ReloadAllModules

+ type ConvergePhase string

+ const RunBeforeAll

+ const StandBy

+ const WaitAfterAll

+ const WaitBeforeAll

+ const WaitDeleteAndRunModules

+ type ConvergeState struct

+ Activation string

+ FirstDone bool

+ FirstStarted bool

+ Phase ConvergePhase

+ StartedAt int64

+ func NewConvergeState() *ConvergeState

Mar 22, 2022

Changes in this version

type AddonOperator

+ func (op *AddonOperator) IsStartupConvergeDone() bool

+ func (op *AddonOperator) NeedAddCrontabTask(hook *module_manager.CommonHook) bool

+ func (op *AddonOperator) SetStartupConvergeDone()

Dec 15, 2021

Changes in this version

type AddonOperator

+ func (op *AddonOperator) DrainModuleQueues(modName string)

Oct 18, 2021

Changes in this version

+ var DefaultHelmMonitorKubeClientMetricLabels = map[string]string

+ func InitAndStart(operator *AddonOperator) error

+ func QueueHasPendingModuleRunTask(q *queue.TaskQueue, moduleName string) bool

+ func RegisterAddonOperatorMetrics(metricStorage *metric_storage.MetricStorage)

+ func RegisterHookMetrics(metricStorage *metric_storage.MetricStorage)

+ type AddonOperator struct

+ ConvergeActivation string

+ ConvergeStarted int64

+ GlobalHooksDir string

+ HelmMonitorKubeClientMetricLabels map[string]string

+ HelmResourcesManager helm_resources_manager.HelmResourcesManager

+ KubeConfigManager kube_config_manager.KubeConfigManager

+ ModuleManager module_manager.ModuleManager

+ ModulesDir string

+ StartupConvergeDone bool

+ StartupConvergeStarted bool

+ func DefaultOperator() *AddonOperator

+ func NewAddonOperator() *AddonOperator

+ func (op *AddonOperator) CheckConvergeStatus(t sh_task.Task)

+ func (op *AddonOperator) CreateReloadAllTasks(onStartup bool, logLabels map[string]string, eventDescription string) []sh_task.Task

+ func (op *AddonOperator) DefineEventHandlers()

+ func (op *AddonOperator) GetHelmMonitorKubeClientMetricLabels() map[string]string

+ func (op *AddonOperator) HandleGlobalHookRun(t sh_task.Task, labels map[string]string) (res queue.TaskResult)

+ func (op *AddonOperator) HandleModuleHookRun(t sh_task.Task, labels map[string]string) (res queue.TaskResult)

+ func (op *AddonOperator) HandleModuleRun(t sh_task.Task, labels map[string]string) (res queue.TaskResult)

+ func (op *AddonOperator) InitAndStartHookQueues()

+ func (op *AddonOperator) InitHelmMonitorKubeClient() (klient.Client, error)

+ func (op *AddonOperator) InitMetricStorage()

+ func (op *AddonOperator) InitModuleManager() error

+ func (op *AddonOperator) MainQueueHasConvergeTasks() int

+ func (op *AddonOperator) PrepopulateMainQueue(tqs *queue.TaskQueueSet)

+ func (op *AddonOperator) RunAddonOperatorMetrics()

+ func (op *AddonOperator) RunDiscoverModulesState(discoverTask sh_task.Task, logLabels map[string]string) ([]sh_task.Task, error)

+ func (op *AddonOperator) SetupDebugServerHandles()

+ func (op *AddonOperator) SetupHttpServerHandles()

+ func (op *AddonOperator) Shutdown()

+ func (op *AddonOperator) Start()

+ func (op *AddonOperator) StartModuleManagerEventHandler()

+ func (op *AddonOperator) Stop()

+ func (op *AddonOperator) TaskHandler(t sh_task.Task) queue.TaskResult

+ func (op *AddonOperator) UpdateWaitInQueueMetric(t sh_task.Task)

+ func (op *AddonOperator) WithContext(ctx context.Context) *AddonOperator

+ func (op *AddonOperator) WithGlobalHooksDir(dir string)

+ func (op *AddonOperator) WithModulesDir(dir string)