queue

Aug 8, 2025

Changes in this version

+ var MergeTasks = []sh_task.TaskType

+ type Callback func(compactedTasks []sh_task.Task, targetTask sh_task.Task)

+ func CompactionCallback(moduleManager ModuleManager, logger *log.Logger) Callback

+ type ModuleManager interface

+ GetModule func(moduleName string) *modules.BasicModule

+ GlobalSynchronizationState func() *modules.SynchronizationState

Jul 15, 2025

Changes in this version

type Service

+ func (s *Service) GetQueueLength(queueName string) int

Apr 25, 2025

Changes in this version

+ var ErrQueueNotFound = errors.New("queue is not found")

+ type Service struct

+ Handle func(ctx context.Context, t sh_task.Task) queue.TaskResult

+ func NewService(ctx context.Context, cfg *ServiceConfig, logger *log.Logger) *Service

+ func (s *Service) AddLastTaskToMain(t sh_task.Task) error

+ func (s *Service) AddLastTaskToQueue(queueName string, t sh_task.Task) error

+ func (s *Service) CombineBindingContextForHook(queueName string, t sh_task.Task, stopCombineFn func(tsk sh_task.Task) bool) *shell_operator.CombineResult

+ func (s *Service) CreateAndStartQueue(queueName string)

+ func (s *Service) DrainNonMainQueue(queueName string)

+ func (s *Service) GetNumberOfConvergeTasks() int

+ func (s *Service) IsQueueExists(queueName string) bool

+ func (s *Service) MainQueueHasPendingModuleRunTask(moduleName string) bool

+ func (s *Service) ModuleEnsureCRDsTasksInMainQueueAfterId(afterId string) bool

+ func (s *Service) RemoveAdjacentConvergeModules(queueName string, afterId string)

+ type ServiceConfig struct

+ Engine *shell_operator.ShellOperator

+ Handle func(ctx context.Context, t sh_task.Task) queue.TaskResult