containerd

Documentation

Index

• func UpdateFetchProgress(done <-chan struct{}, client *containerd.Client, progress *progress.ImageFetch)
• func WithCwd(cwd string) oci.SpecOpts
• func WithEnv(overrides []string) oci.SpecOpts
• func WithMounts(mounts []model.Mount) oci.SpecOpts
• type DirectIO
  • func NewDirectIO(ctx context.Context, stdin, stdout, stderr string, terminal bool) (f *DirectIO, err error)
  • func (f *DirectIO) Cancel()
  • func (f *DirectIO) Close() error
  • func (f *DirectIO) Config() cio.Config
  • func (f *DirectIO) Delete() error
  • func (f *DirectIO) IOCreate(id string) (cio.IO, error)
  • func (f *DirectIO) Wait()

Functions

func UpdateFetchProgress

func UpdateFetchProgress(done <-chan struct{}, client *containerd.Client, progress *progress.ImageFetch)

UpdateFetchProgress start goroutine to update the fetch status until done channel closes

func WithCwd

func WithCwd(cwd string) oci.SpecOpts

WithCwd spets the container current working directory (cwd)

func WithEnv

func WithEnv(overrides []string) oci.SpecOpts

WithEnv you can add or override process environment variables overrides should be list of strings in format 'KEY=value'

func WithMounts

func WithMounts(mounts []model.Mount) oci.SpecOpts

WithMounts you can add mount points to the container

Types

type DirectIO

type DirectIO struct {
	Stdin  io.WriteCloser
	Stdout io.ReadCloser
	Stderr io.ReadCloser
	// contains filtered or unexported fields
}

DirectIO allows task IO to be handled externally by the caller

func NewDirectIO

func NewDirectIO(ctx context.Context, stdin, stdout, stderr string, terminal bool) (f *DirectIO, err error)

NewDirectIO returns an IO implementation that exposes the pipes directly

func (*DirectIO) Cancel

func (f *DirectIO) Cancel()

Cancel stops any IO copy operations

Not applicable for DirectIO

func (*DirectIO) Close

func (f *DirectIO) Close() error

Close closes all open fds

func (*DirectIO) Config

func (f *DirectIO) Config() cio.Config

Config returns the IOConfig

func (*DirectIO) Delete

func (f *DirectIO) Delete() error

Delete removes the underlying directory containing fifos

func (*DirectIO) IOCreate

func (f *DirectIO) IOCreate(id string) (cio.IO, error)

IOCreate returns IO avaliable for use with task creation

func (*DirectIO) Wait

func (f *DirectIO) Wait()

Wait on any IO copy operations

Not applicable for DirectIO