service

package

v1.17.0 Latest Latest Go to latest Published: Nov 14, 2025 License: Apache-2.0 Imports: 37 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/flant/addon-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func ConvergeModulesInQueue(q *queue.TaskQueue) int
func ConvergeTasksInQueue(q *queue.TaskQueue) int
type TaskHandlerService
- func NewTaskHandlerService(ctx context.Context, config *TaskHandlerServiceConfig, logger *log.Logger) *TaskHandlerService
type TaskHandlerServiceConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConvergeModulesInQueue ¶

func ConvergeModulesInQueue(q *queue.TaskQueue) int

func ConvergeTasksInQueue ¶

func ConvergeTasksInQueue(q *queue.TaskQueue) int

Types ¶

type TaskHandlerService ¶

type TaskHandlerService struct {
	// contains filtered or unexported fields
}

func NewTaskHandlerService ¶

func NewTaskHandlerService(ctx context.Context, config *TaskHandlerServiceConfig, logger *log.Logger) *TaskHandlerService

NewTaskHandlerService creates a new task handler service

func (*TaskHandlerService) CheckConvergeStatus ¶

func (s *TaskHandlerService) CheckConvergeStatus(t sh_task.Task)

CheckConvergeStatus monitors the convergence process and updates metrics. It detects when convergence starts and completes, tracks timing metrics, and keeps track of the first convergence for operator readiness.

func (*TaskHandlerService) GetCRDExtraLabels ¶

func (s *TaskHandlerService) GetCRDExtraLabels() map[string]string

func (*TaskHandlerService) GetConvergeState ¶

func (s *TaskHandlerService) GetConvergeState() *converge.ConvergeState

func (*TaskHandlerService) GetDiscoveredGVKs ¶ added in v1.7.5

func (s *TaskHandlerService) GetDiscoveredGVKs() *discovercrds.DiscoveredGVKs

func (*TaskHandlerService) GetFunctionalScheduler ¶ added in v1.10.0

func (s *TaskHandlerService) GetFunctionalScheduler() *functional.Scheduler

func (*TaskHandlerService) GetHelm ¶

func (s *TaskHandlerService) GetHelm() *helm.ClientFactory

func (*TaskHandlerService) GetHelmResourcesManager ¶

func (s *TaskHandlerService) GetHelmResourcesManager() helm_resources_manager.HelmResourcesManager

func (*TaskHandlerService) GetKubeClient ¶

func (s *TaskHandlerService) GetKubeClient() *klient.Client

func (*TaskHandlerService) GetKubeConfigManager ¶

func (s *TaskHandlerService) GetKubeConfigManager() *kube_config_manager.KubeConfigManager

func (*TaskHandlerService) GetMetricStorage ¶

func (s *TaskHandlerService) GetMetricStorage() metricsstorage.Storage

func (*TaskHandlerService) GetModuleManager ¶

func (s *TaskHandlerService) GetModuleManager() *module_manager.ModuleManager

func (*TaskHandlerService) GetParallelTaskChannels ¶

func (s *TaskHandlerService) GetParallelTaskChannels() *paralleltask.TaskChannels

func (*TaskHandlerService) GetQueueService ¶

func (s *TaskHandlerService) GetQueueService() *taskqueue.Service

func (*TaskHandlerService) GetTaskFactory ¶

func (s *TaskHandlerService) GetTaskFactory() map[sh_task.TaskType]func(t sh_task.Task, logger *log.Logger) task.Task

func (*TaskHandlerService) Handle ¶

func (s *TaskHandlerService) Handle(ctx context.Context, t sh_task.Task) queue.TaskResult

TaskHandler handles tasks in queue.

func (*TaskHandlerService) ParallelHandle ¶

func (s *TaskHandlerService) ParallelHandle(ctx context.Context, t sh_task.Task) queue.TaskResult

ParallelHandle handles limited types of tasks in parallel queues.

func (*TaskHandlerService) UpdateFirstConvergeStatus ¶

func (s *TaskHandlerService) UpdateFirstConvergeStatus(convergeTasks int)

UpdateFirstConvergeStatus tracks the progress of the first convergence operation and logs when it completes.

func (*TaskHandlerService) UpdateWaitInQueueMetric ¶

func (s *TaskHandlerService) UpdateWaitInQueueMetric(t sh_task.Task)

UpdateWaitInQueueMetric increases task_wait_in_queue_seconds_total counter for the task type. TODO pass queue name from handler, not from task

type TaskHandlerServiceConfig ¶

type TaskHandlerServiceConfig struct {
	Engine               *shell_operator.ShellOperator
	ParallelTaskChannels *paralleltask.TaskChannels
	Helm                 *helm.ClientFactory
	HelmResourcesManager helm_resources_manager.HelmResourcesManager
	ModuleManager        *module_manager.ModuleManager
	MetricStorage        metricsstorage.Storage
	KubeConfigManager    *kube_config_manager.KubeConfigManager
	ConvergeState        *converge.ConvergeState
	CRDExtraLabels       map[string]string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL