Function NewClient

cmd/ctr/commands/client.go:60–90

NewClient returns a new containerd client

(cliContext *cli.Context, opts ...containerd.Opt)

// NewClient returns a new containerd client
func NewClient(cliContext *cli.Context, opts ...containerd.Opt) (*containerd.Client, context.Context, context.CancelFunc, error) {
	timeoutOpt := containerd.WithTimeout(cliContext.Duration("connect-timeout"))
	opts = append(opts, timeoutOpt)
	socketPath := cliContext.String("address")
	if _, err := os.Stat(socketPath); err != nil {
		return nil, nil, nil, fmt.Errorf("cannot access socket %s: %w", socketPath, err)
	}
	client, err := containerd.New(socketPath, opts...)
	if err != nil {
		return nil, nil, nil, err
	}
	ctx, cancel := AppContext(cliContext)
	var suppressDeprecationWarnings bool
	if s := os.Getenv("CONTAINERD_SUPPRESS_DEPRECATION_WARNINGS"); s != "" {
		suppressDeprecationWarnings, err = strconv.ParseBool(s)
		if err != nil {
			log.L.WithError(err).Warn("Failed to parse CONTAINERD_SUPPRESS_DEPRECATION_WARNINGS=" + s)
		}
	}
	if !suppressDeprecationWarnings {
		resp, err := client.IntrospectionService().Server(ctx)
		if err != nil {
			log.L.WithError(err).Warn("Failed to check deprecations")
		} else {
			for _, d := range resp.Deprecations {
				log.L.Warn("DEPRECATION: " + d.Message)
			}
		}
	}
	return client, ctx, cancel, nil
}