Method Start

pkg/shell-operator/operator.go:198–227

Start runs the operator: opens listeners, primes queues, spawns the metric and event goroutines. It is non-blocking. Calling Start twice is a no-op; the first call's error is returned to subsequent callers.

(_ context.Context)

// and event goroutines. It is non-blocking. Calling Start twice is a no-op;
// the first call's error is returned to subsequent callers.
func (op *ShellOperator) Start(_ context.Context) error {
	op.startOnce.Do(func() {
		op.logger.Info("start shell-operator")

		if op.APIServer != nil {
			op.APIServer.Start(op.ctx)
		}

		if op.TaskQueues != nil {
			op.bootstrapMainQueue(op.TaskQueues)
			op.TaskQueues.StartMain(op.ctx)
			op.initAndStartHookQueues()
		}

		// Start emit "live" metrics. Goroutines tracked via op.wg so Shutdown
		// can wait for them.
		op.runMetrics()

		// Managers generate events. Start the demux loop before informers so
		// no early Kubernetes event is dropped (#42).
		if op.ManagerEventsHandler != nil {
			op.ManagerEventsHandler.Start()
		}

		if op.ScheduleManager != nil {
			op.ScheduleManager.Start()
		}
	})
	return op.startErr
}

// Run is a convenience that Start()s the operator, blocks until ctx is
// canceled, then performs a synchronous Shutdown with a derived timeout. Use