package commands

import "github.com/containerd/containerd/cmd/ctr/commands"

Index ¶

• Variables
• func AppContext(context *cli.Context) (gocontext.Context, gocontext.CancelFunc)
• func ForwardAllSignals(ctx gocontext.Context, task killer) chan os.Signal
• func GetResolver(ctx gocontext.Context, clicontext *cli.Context) (remotes.Resolver, error)
• func LabelArgs(labelStrings []string) map[string]string
• func NewClient(context *cli.Context) (*containerd.Client, gocontext.Context, gocontext.CancelFunc, error)
• func ObjectWithLabelArgs(clicontext *cli.Context) (string, map[string]string)
• func ParseSignal(rawSignal string) (syscall.Signal, error)
• func PrintAsJSON(x interface{})
• func StopCatch(sigc chan os.Signal)
• func WritePidFile(path string, pid int) error

Variables ¶

var (
	// SnapshotterFlags are cli flags specifying snapshotter names
	SnapshotterFlags = []cli.Flag{
		cli.StringFlag{
			Name:   "snapshotter",
			Usage:  "snapshotter name. Empty value stands for the default value.",
			Value:  containerd.DefaultSnapshotter,
			EnvVar: "CONTAINERD_SNAPSHOTTER",
		},
	}

	// LabelFlag is a cli flag specifying labels
	LabelFlag = cli.StringSliceFlag{
		Name:  "label",
		Usage: "labels to attach to the image",
	}

	// RegistryFlags are cli flags specifying registry options
	RegistryFlags = []cli.Flag{
		cli.BoolFlag{
			Name:  "skip-verify,k",
			Usage: "skip SSL certificate validation",
		},
		cli.BoolFlag{
			Name:  "plain-http",
			Usage: "allow connections using plain HTTP",
		},
		cli.StringFlag{
			Name:  "user,u",
			Usage: "user[:password] Registry user and password",
		},
		cli.StringFlag{
			Name:  "refresh",
			Usage: "refresh token for authorization server",
		},
	}
)

var PushTracker = docker.NewInMemoryTracker()

PushTracker returns a new InMemoryTracker which tracks the ref status

Functions ¶

func AppContext ¶

func AppContext(context *cli.Context) (gocontext.Context, gocontext.CancelFunc)

AppContext returns the context for a command. Should only be called once per command, near the start.

This will ensure the namespace is picked up and set the timeout, if one is defined.

func ForwardAllSignals ¶

func ForwardAllSignals(ctx gocontext.Context, task killer) chan os.Signal

ForwardAllSignals forwards signals

func GetResolver ¶

func GetResolver(ctx gocontext.Context, clicontext *cli.Context) (remotes.Resolver, error)

GetResolver prepares the resolver from the environment and options

func LabelArgs ¶

func LabelArgs(labelStrings []string) map[string]string

LabelArgs returns a map of label key,value pairs

func NewClient ¶

func NewClient(context *cli.Context) (*containerd.Client, gocontext.Context, gocontext.CancelFunc, error)

NewClient returns a new containerd client

func ObjectWithLabelArgs ¶

func ObjectWithLabelArgs(clicontext *cli.Context) (string, map[string]string)

ObjectWithLabelArgs returns the first arg and a LabelArgs object

func ParseSignal ¶

func ParseSignal(rawSignal string) (syscall.Signal, error)

ParseSignal parses a given string into a syscall.Signal it checks that the signal exists in the platform-appropriate signalMap

func PrintAsJSON ¶

func PrintAsJSON(x interface{})

PrintAsJSON prints input in JSON format

func StopCatch ¶

func StopCatch(sigc chan os.Signal)

StopCatch stops and closes a channel

func WritePidFile ¶

func WritePidFile(path string, pid int) error

WritePidFile writes the pid atomically to a file

Source Files ¶

client.go commands.go resolver.go signal_map_unix.go signals.go

Directories ¶