nerd

Documentation

Index

• func WithUIDAndGID(uid, gid uint32) containerd.NewTaskOpts
• type BackingProcess
  • func NewBackingProcess(log lager.Logger, p containerd.Process, ctx context.Context) BackingProcess
  • func (p BackingProcess) Delete() error
  • func (p BackingProcess) ID() string
  • func (p BackingProcess) Signal(signal syscall.Signal) error
  • func (p BackingProcess) Wait() (int, error)
• type Nerd
  • func New(client *containerd.Client, context context.Context, ioFifoDir string) *Nerd
  • func (n *Nerd) BundleIDs(labels ...runcontainerd.ContainerFilter) ([]string, error)
  • func (n *Nerd) Create(log lager.Logger, containerID string, spec *specs.Spec, ...) error
  • func (n *Nerd) Delete(log lager.Logger, containerID string) error
  • func (n *Nerd) Exec(log lager.Logger, containerID, processID string, spec *specs.Process, ...) (runcontainerd.BackingProcess, error)
  • func (n *Nerd) GetContainerPID(log lager.Logger, containerID string) (uint32, error)
  • func (n *Nerd) GetProcess(log lager.Logger, containerID, processID string) (runcontainerd.BackingProcess, error)
  • func (n *Nerd) GetTask(log lager.Logger, id string) (runcontainerd.BackingProcess, error)
  • func (n *Nerd) OOMEvents(log lager.Logger) <-chan *apievents.TaskOOM
  • func (n *Nerd) RemoveBundle(log lager.Logger, handle string) error
  • func (n *Nerd) Spec(log lager.Logger, containerID string) (*specs.Spec, error)
  • func (n *Nerd) State(log lager.Logger, containerID string) (int, string, error)
• type NerdStopper
  • func NewNerdStopper(client *containerd.Client) *NerdStopper
  • func (s NerdStopper) Stop() error

Functions

func WithUIDAndGID

func WithUIDAndGID(uid, gid uint32) containerd.NewTaskOpts

Types

type BackingProcess

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

func NewBackingProcess

func NewBackingProcess(log lager.Logger, p containerd.Process, ctx context.Context) BackingProcess

func (BackingProcess) Delete

func (p BackingProcess) Delete() error

func (BackingProcess) ID

func (p BackingProcess) ID() string

func (BackingProcess) Signal

func (p BackingProcess) Signal(signal syscall.Signal) error

func (BackingProcess) Wait

func (p BackingProcess) Wait() (int, error)

type Nerd

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

func New

func New(client *containerd.Client, context context.Context, ioFifoDir string) *Nerd

func (*Nerd) BundleIDs

func (n *Nerd) BundleIDs(labels ...runcontainerd.ContainerFilter) ([]string, error)

func (*Nerd) Create

func (n *Nerd) Create(log lager.Logger, containerID string, spec *specs.Spec, hostUID, hostGID uint32, pio func() (io.Reader, io.Writer, io.Writer)) error

func (*Nerd) Delete

func (n *Nerd) Delete(log lager.Logger, containerID string) error

func (*Nerd) Exec

func (n *Nerd) Exec(log lager.Logger, containerID, processID string, spec *specs.Process, processIO func() (io.Reader, io.Writer, io.Writer, bool)) (runcontainerd.BackingProcess, error)

func (*Nerd) GetContainerPID

func (n *Nerd) GetContainerPID(log lager.Logger, containerID string) (uint32, error)

func (*Nerd) GetProcess

func (n *Nerd) GetProcess(log lager.Logger, containerID, processID string) (runcontainerd.BackingProcess, error)

func (*Nerd) GetTask

func (n *Nerd) GetTask(log lager.Logger, id string) (runcontainerd.BackingProcess, error)

func (*Nerd) OOMEvents

func (n *Nerd) OOMEvents(log lager.Logger) <-chan *apievents.TaskOOM

func (*Nerd) RemoveBundle

func (n *Nerd) RemoveBundle(log lager.Logger, handle string) error

func (*Nerd) Spec

func (n *Nerd) Spec(log lager.Logger, containerID string) (*specs.Spec, error)

func (*Nerd) State

func (n *Nerd) State(log lager.Logger, containerID string) (int, string, error)

type NerdStopper

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

func NewNerdStopper

func NewNerdStopper(client *containerd.Client) *NerdStopper

func (NerdStopper) Stop

func (s NerdStopper) Stop() error