shell_operator

func (*ManagerEventsHandler) Start ¶

func (m *ManagerEventsHandler) Start()

func (*ManagerEventsHandler) Stop ¶

func (m *ManagerEventsHandler) Stop()

func (*ManagerEventsHandler) WithContext ¶

func (m *ManagerEventsHandler) WithContext(ctx context.Context)

func (*ManagerEventsHandler) WithKubeEventHandler ¶

func (m *ManagerEventsHandler) WithKubeEventHandler(fn func(kubeEvent KubeEvent) []task.Task)

func (*ManagerEventsHandler) WithKubeEventsManager ¶

func (m *ManagerEventsHandler) WithKubeEventsManager(mgr kube_events_manager.KubeEventsManager)

func (*ManagerEventsHandler) WithScheduleEventHandler ¶

func (m *ManagerEventsHandler) WithScheduleEventHandler(fn func(crontab string) []task.Task)

func (*ManagerEventsHandler) WithScheduleManager ¶

func (m *ManagerEventsHandler) WithScheduleManager(mgr schedule_manager.ScheduleManager)

func (*ManagerEventsHandler) WithTaskQueueSet ¶

func (m *ManagerEventsHandler) WithTaskQueueSet(tqs *queue.TaskQueueSet)

func (*ShellOperator) CombineBindingContextForHook ¶

func (op *ShellOperator) CombineBindingContextForHook(q *queue.TaskQueue, t task.Task, stopCombineFn func(tsk task.Task) bool) []BindingContext

CombineBindingContextForHook combines binding contexts from a sequence of task with similar hook name and task type into array of binding context and delete excess tasks from queue. Also, compacts sequences of binding contexts with similar group. If input task has no metadata, result will be nil. Metadata should implement HookNameAccessor and BindingContextAccessor interfaces.

func (*ShellOperator) Init ¶

func (op *ShellOperator) Init() (err error)

Init does some basic checks and instantiate dependencies

- check directories - start debug server - initialize dependencies:

• metric storage
• kubernetes client config
• empty set of task queues
• hook manager
• kubernetes events manager
• schedule manager

func (*ShellOperator) InitAndStartHookQueues ¶

func (op *ShellOperator) InitAndStartHookQueues()

CreateQueues create all queues defined in hooks

func (*ShellOperator) InitHookManager ¶

func (op *ShellOperator) InitHookManager() (err error)

InitHookManager load hooks from HooksDir and defines event handlers that emit tasks.

func (*ShellOperator) PrepopulateMainQueue ¶

func (op *ShellOperator) PrepopulateMainQueue(tqs *queue.TaskQueueSet)

PrepopulateMainQueue adds tasks to run hooks with OnStartup bindings and tasks to enable kubernetes bindings.

func (*ShellOperator) RunMetrics ¶

func (op *ShellOperator) RunMetrics()

func (*ShellOperator) SetupDebugServerHandles ¶

func (op *ShellOperator) SetupDebugServerHandles()

func (*ShellOperator) SetupHttpServerHandles ¶

func (op *ShellOperator) SetupHttpServerHandles()

func (*ShellOperator) Start ¶

func (op *ShellOperator) Start()

func (*ShellOperator) StartHttpServer ¶

func (op *ShellOperator) StartHttpServer(ip string, port string) error

func (*ShellOperator) Stop ¶

func (op *ShellOperator) Stop()

func (*ShellOperator) TaskHandler ¶

func (op *ShellOperator) TaskHandler(t task.Task) queue.TaskResult

TaskHandler

func (*ShellOperator) WithContext ¶

func (op *ShellOperator) WithContext(ctx context.Context) *ShellOperator

func (*ShellOperator) WithHooksDir ¶

func (op *ShellOperator) WithHooksDir(dir string)

func (*ShellOperator) WithKubernetesClient ¶

func (op *ShellOperator) WithKubernetesClient(klient kube.KubernetesClient)

func (*ShellOperator) WithMetricStorage ¶

func (op *ShellOperator) WithMetricStorage(metricStorage *metrics_storage.MetricStorage)

func (*ShellOperator) WithTempDir ¶

func (op *ShellOperator) WithTempDir(dir string)