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...]", SkipArgReorder: true, Flags: append([]cli.Flag{ cli.BoolFlag{ Name: "rm", Usage: "Remove the container after running, cannot be used with --detach", }, cli.BoolFlag{ Name: "null-io", Usage: "Send all IO to /dev/null", }, cli.StringFlag{ Name: "log-uri", Usage: "Log uri", }, cli.BoolFlag{ Name: "detach,d", Usage: "Detach from the task after it has started execution, cannot be used with --rm", }, cli.StringFlag{ Name: "fifo-dir", Usage: "Directory used for storing IO FIFOs", }, cli.StringFlag{ Name: "cgroup", Usage: "Cgroup path (To disable use of cgroup, set to \"\" explicitly)", }, cli.StringFlag{ Name: "platform", Usage: "Run image for specific platform", }, cli.BoolFlag{ Name: "cni", Usage: "Enable cni networking for the container", }, }, append(platformRunFlags, append(append(commands.SnapshotterFlags, []cli.Flag{commands.SnapshotterLabels}...), commands.ContainerFlags...)...)...), Action: func(context *cli.Context) error { var ( err error id string ref string rm = context.Bool("rm") tty = context.Bool("tty") detach = context.Bool("detach") config = context.IsSet("config") enableCNI = context.Bool("cni") ) if config { id = context.Args().First() if context.NArg() > 1 { return errors.New("with spec config file, only container id should be provided") } } else { id = context.Args().Get(1) ref = context.Args().First() if ref == "" { return errors.New("image ref must be provided") } } if id == "" { return errors.New("container id must be provided") } if rm && detach { return errors.New("flags --detach and --rm cannot be specified together") } 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 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 } } var network gocni.CNI if enableCNI { if network, err = gocni.New(gocni.WithDefaultConf); err != nil { return err } } opts := tasks.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"), context.String("log-uri"), ioOpts, opts...) if err != nil { return err } var statusC <-chan containerd.ExitStatus if !detach { defer func() { if enableCNI { if err := network.Remove(ctx, commands.FullID(ctx, container), ""); err != nil { logrus.WithError(err).Error("network review") } } 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 enableCNI { netNsPath, err := getNetNSPath(ctx, task) if err != nil { return err } if _, err := network.Setup(ctx, commands.FullID(ctx, container), netNsPath); 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 ¶ added in v1.1.0
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.