Method Run

pkg/shell-operator/operator.go:233–242

Run is a convenience that Start()s the operator, blocks until ctx is canceled, then performs a synchronous Shutdown with a derived timeout. Use it from main() and tests; library consumers that want fine-grained control should call Start and Shutdown directly.

(ctx context.Context)

// it from main() and tests; library consumers that want fine-grained control
// should call Start and Shutdown directly.
func (op *ShellOperator) Run(ctx context.Context) error {
	if err := op.Start(ctx); err != nil {
		return err
	}
	<-ctx.Done()

	shutdownCtx, cancel := context.WithTimeout(context.Background(), DefaultShutdownTimeout)
	defer cancel()
	return op.Shutdown(shutdownCtx)
}

// Shutdown gracefully tears down everything started by Start. It is
// synchronous: when Shutdown returns, no goroutine spawned by the operator is