Versions in this module Expand all Collapse all v0 v0.0.1 Jun 26, 2024 Changes in this version + var DefaultHelmMonitorKubeClientMetricLabels = map[string]string + func ConvergeModulesInQueue(q *queue.TaskQueue) int + func ConvergeTasksInQueue(q *queue.TaskQueue) int + func DrainNonMainQueue(q *queue.TaskQueue) + func InitDefaultHelmResourcesManager(ctx context.Context, metricStorage *metric_storage.MetricStorage) (helm_resources_manager.HelmResourcesManager, error) + func ModulesWithPendingModuleRun(q *queue.TaskQueue) map[string]struct + func QueueHasPendingModuleRunTask(q *queue.TaskQueue, moduleName string) bool + func RemoveAdjacentConvergeModules(q *queue.TaskQueue, afterId string) + func RemoveCurrentConvergeTasks(q *queue.TaskQueue, afterId string) bool + func StartLiveTicksUpdater(metricStorage *metric_storage.MetricStorage) + func StartTasksQueueLengthUpdater(metricStorage *metric_storage.MetricStorage, tqs *queue.TaskQueueSet) + type AddonOperator struct + AdmissionServer *AdmissionServer + ConvergeState *converge.ConvergeState + DebugServer *debug.Server + Helm *helm.ClientFactory + HelmResourcesManager helm_resources_manager.HelmResourcesManager + InitialKubeConfig *config.KubeConfig + KubeConfigManager *kube_config_manager.KubeConfigManager + LeaderElector *leaderelection.LeaderElector + MetricStorage *metric_storage.MetricStorage + ModuleManager *module_manager.ModuleManager + func NewAddonOperator(ctx context.Context) *AddonOperator + func (op *AddonOperator) Assemble(debugServer *debug.Server) (err error) + func (op *AddonOperator) BootstrapMainQueue(tqs *queue.TaskQueueSet) + func (op *AddonOperator) CheckConvergeStatus(t sh_task.Task) + 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) DrainModuleQueues(modName string) + 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) HandleGlobalHookRun(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) HandleModuleHookRun(t sh_task.Task, labels map[string]string) (res queue.TaskResult) + func (op *AddonOperator) HandleModulePurge(t sh_task.Task, labels map[string]string) (status queue.TaskStatus) + func (op *AddonOperator) HandleModuleRun(t sh_task.Task, labels map[string]string) (res queue.TaskResult) + func (op *AddonOperator) InitModuleManager() error + func (op *AddonOperator) IsStartupConvergeDone() bool + func (op *AddonOperator) KubeClient() *client.Client + func (op *AddonOperator) RegisterDebugGlobalRoutes(dbgSrv *debug.Server) + func (op *AddonOperator) RegisterDebugModuleRoutes(dbgSrv *debug.Server) + func (op *AddonOperator) RegisterDiscoveryRoute(dbgSrv *debug.Server) + func (op *AddonOperator) RegisterManagerEventsHandlers() + func (op *AddonOperator) Setup() error + func (op *AddonOperator) SetupKubeConfigManager(bk backend.ConfigHandler) + func (op *AddonOperator) SetupModuleManager(modulesDir string, globalHooksDir string, tempDir string) + func (op *AddonOperator) Start(_ context.Context) error + func (op *AddonOperator) StartAPIServer() + func (op *AddonOperator) StartModuleManagerEventHandler() + func (op *AddonOperator) Stop() + func (op *AddonOperator) TaskHandler(t sh_task.Task) queue.TaskResult + func (op *AddonOperator) UpdateFirstConvergeStatus(convergeTasks int) + func (op *AddonOperator) UpdateWaitInQueueMetric(t sh_task.Task) + func (op *AddonOperator) WithLeaderElector(config *leaderelection.LeaderElectionConfig) error + type AdmissionServer struct + func NewAdmissionServer(listenPort, certsDir string) *AdmissionServer + func (as *AdmissionServer) RegisterHandler(route string, handler http.Handler)
Go to main page