containerd

Documentation

Index

• func Import(ctx context.Context, namespace string, reqs ...*ImportRequest) error
• func NewRunner(debug bool, args *runner.Args, setters ...runner.Option) runner.Runner
• func WithMemoryLimit(limit int64) oci.SpecOpts
• func WithRootfsPropagation(rp string) oci.SpecOpts
• type ImportRequest
• type Importer
  • func NewImporter(namespace string, options ...ImporterOption) *Importer
  • func (i *Importer) Import(ctx context.Context, reqs ...*ImportRequest) (err error)
• type ImporterOption
  • func WithContainerdAddress(address string) ImporterOption
• type StdinCloser
  • func (s *StdinCloser) Read(p []byte) (int, error)
  • func (s *StdinCloser) WaitAndClose(ctx context.Context, task containerd.Task)

Functions

func Import

func Import(ctx context.Context, namespace string, reqs ...*ImportRequest) error

Import imports the images specified by the import requests.

func NewRunner

func NewRunner(debug bool, args *runner.Args, setters ...runner.Option) runner.Runner

NewRunner creates runner.Runner that runs a container in containerd.

func WithMemoryLimit

func WithMemoryLimit(limit int64) oci.SpecOpts

WithMemoryLimit sets the linux resource memory limit field.

func WithRootfsPropagation

func WithRootfsPropagation(rp string) oci.SpecOpts

WithRootfsPropagation sets the root filesystem propagation.

Types

type ImportRequest

type ImportRequest struct {
	Path    string
	Options []containerd.ImportOpt
}

ImportRequest represents an image import request.

type Importer

type Importer struct {
	// contains filtered or unexported fields
}

Importer implements image import.

func NewImporter

func NewImporter(namespace string, options ...ImporterOption) *Importer

NewImporter builds new Importer.

func (*Importer) Import

func (i *Importer) Import(ctx context.Context, reqs ...*ImportRequest) (err error)

Import imports the images specified by the import requests.

type ImporterOption

type ImporterOption func(*importerOptions)

ImporterOption configures containerd Inspector.

func WithContainerdAddress

func WithContainerdAddress(address string) ImporterOption

WithContainerdAddress configures containerd address to use.

type StdinCloser

type StdinCloser struct {
	Stdin  io.Reader
	Closer chan struct{}
}

StdinCloser wraps io.Reader providing a signal when reader is read till EOF.

func (*StdinCloser) Read

func (s *StdinCloser) Read(p []byte) (int, error)

func (*StdinCloser) WaitAndClose

func (s *StdinCloser) WaitAndClose(ctx context.Context, task containerd.Task)

WaitAndClose closes containerd task stdin when StdinCloser is exhausted.