Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Command = cli.Command{ Name: "run", Usage: "run a container", ArgsUsage: "[flags] Image|RootFS ID [COMMAND] [ARG...]", Flags: append([]cli.Flag{ cli.BoolFlag{ Name: "rm", Usage: "remove the container after running", }, cli.BoolFlag{ Name: "null-io", Usage: "send all IO to /dev/null", }, cli.BoolFlag{ Name: "detach,d", Usage: "detach from the task after it has started execution", }, cli.StringFlag{ Name: "fifo-dir", Usage: "directory used for storing IO FIFOs", }, }, append(commands.SnapshotterFlags, commands.ContainerFlags...)...), Action: func(context *cli.Context) error { var ( err error id = context.Args().Get(1) ref = context.Args().First() tty = context.Bool("tty") detach = context.Bool("detach") ) if ref == "" { return errors.New("image ref must be provided") } if id == "" { return errors.New("container id must be provided") } client, ctx, cancel, err := commands.NewClient(context) if err != nil { return err } defer cancel() container, err := NewContainer(ctx, client, context) if err != nil { return err } if context.Bool("rm") && !detach { defer container.Delete(ctx, containerd.WithSnapshotCleanup) } var con console.Console if tty { con = console.Current() defer con.Reset() if err := con.SetRaw(); err != nil { return err } } opts := getNewTaskOpts(context) ioOpts := []cio.Opt{cio.WithFIFODir(context.String("fifo-dir"))} task, err := tasks.NewTask(ctx, client, container, context.String("checkpoint"), con, context.Bool("null-io"), ioOpts, opts...) if err != nil { return err } var statusC <-chan containerd.ExitStatus if !detach { defer task.Delete(ctx) if statusC, err = task.Wait(ctx); err != nil { return err } } if context.IsSet("pid-file") { if err := commands.WritePidFile(context.String("pid-file"), int(task.Pid())); err != nil { return err } } if err := task.Start(ctx); err != nil { return err } if detach { return nil } if tty { if err := tasks.HandleConsoleResize(ctx, task, con); err != nil { logrus.WithError(err).Error("console resize") } } else { sigc := commands.ForwardAllSignals(ctx, task) defer commands.StopCatch(sigc) } status := <-statusC code, _, err := status.Result() if err != nil { return err } if _, err := task.Delete(ctx); err != nil { return err } if code != 0 { return cli.NewExitError("", int(code)) } return nil }, }
Command runs a container
Functions ¶
func NewContainer ¶
func NewContainer(ctx gocontext.Context, client *containerd.Client, context *cli.Context) (containerd.Container, error)
NewContainer creates a new container
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.