Function dockerCmd

cli/docker.go:156–453

()

}

func dockerCmd() *cobra.Command {
	var flags flags

	cmd := &cobra.Command{
		Use:   "docker",
		Short: "Create a docker-based CVM",
		RunE: func(cmd *cobra.Command, args []string) (err error) {
			var (
				ctx, cancel                 = context.WithCancel(cmd.Context()) //nolint
				log                         = slog.Make(slogjson.Sink(cmd.ErrOrStderr()), slogkubeterminate.Make()).Leveled(slog.LevelDebug)
				blog        buildlog.Logger = buildlog.JSONLogger{Encoder: json.NewEncoder(os.Stderr)}
			)

			// We technically leak a context here, but it's impact is negligible.
			signalCtx, signalCancel := context.WithCancel(ctx)
			sigs := make(chan os.Signal, 1)
			signal.Notify(sigs, syscall.SIGTERM, syscall.SIGINT, syscall.SIGWINCH)

			// Spawn a goroutine to wait for a signal.
			go func() {
				defer signalCancel()
				log.Info(ctx, "waiting for signal")
				<-sigs
				log.Info(ctx, "got signal, canceling context")
			}()

			if flags.noStartupLogs {
				log = slog.Make(slogjson.Sink(io.Discard))
				blog = buildlog.NopLogger{}
			}

			httpClient, err := xhttp.Client(log, flags.extraCertsPath)
			if err != nil {
				//nolint
				return xerrors.Errorf("http client: %w", err)
			}

			if !flags.noStartupLogs && flags.agentToken != "" && flags.coderURL != "" {
				coderURL, err := url.Parse(flags.coderURL)
				if err != nil {
					return xerrors.Errorf("parse coder URL %q: %w", flags.coderURL, err)
				}

				agent, err := buildlog.OpenCoderClient(ctx, log, coderURL, httpClient, flags.agentToken)
				if err != nil {
					// Don't fail workspace startup on
					// an inability to push build logs.
					log.Error(ctx, "failed to instantiate coder build log client, no logs will be pushed", slog.Error(err))
				} else {
					blog = buildlog.MultiLogger(
						buildlog.OpenCoderLogger(ctx, agent, log),
						blog,
					)
				}
			}
			defer blog.Close()

			defer func(err *error) {