containerd

Documentation

Index

• func Import(ctx context.Context, namespace string, reqs ...*ImportRequest) error
• func NewRunner(logToConsole bool, args *runner.Args, setters ...runner.Option) runner.Runner
• func WithCustomSeccompProfile(override func(*specs.LinuxSeccomp)) oci.SpecOpts
• func WithOOMScoreAdj(score int) 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(logToConsole bool, args *runner.Args, setters ...runner.Option) runner.Runner

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

func WithCustomSeccompProfile

func WithCustomSeccompProfile(override func(*specs.LinuxSeccomp)) oci.SpecOpts

WithCustomSeccompProfile allows to override default seccomp profile.

func WithOOMScoreAdj

func WithOOMScoreAdj(score int) oci.SpecOpts

WithOOMScoreAdj sets the oom score.

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.