linux

Documentation

Index

• func New(ic *plugin.InitContext) (interface{}, error)
• func ShimConnect() shimOpt
• func ShimLocal(exchange *events.Exchange) shimOpt
• func ShimRemote(shim, daemonAddress, cgroup string, debug bool, exitHandler func()) shimOpt
• type Config
• type Process
  • func (p *Process) CloseIO(ctx context.Context) error
  • func (p *Process) ID() string
  • func (p *Process) Kill(ctx context.Context, signal uint32, _ bool) error
  • func (p *Process) ResizePty(ctx context.Context, size runtime.ConsoleSize) error
  • func (p *Process) Start(ctx context.Context) error
  • func (p *Process) State(ctx context.Context) (runtime.State, error)
  • func (p *Process) Wait(ctx context.Context) (*runtime.Exit, error)
• type Runtime
  • func (r *Runtime) Create(ctx context.Context, id string, opts runtime.CreateOpts) (_ runtime.Task, err error)
  • func (r *Runtime) Delete(ctx context.Context, c runtime.Task) (*runtime.Exit, error)
  • func (r *Runtime) Get(ctx context.Context, id string) (runtime.Task, error)
  • func (r *Runtime) ID() string
  • func (r *Runtime) Tasks(ctx context.Context) ([]runtime.Task, error)
• type Task
  • func (t *Task) Cgroup() cgroups.Cgroup
  • func (t *Task) Checkpoint(ctx context.Context, path string, options *types.Any) error
  • func (t *Task) CloseIO(ctx context.Context) error
  • func (t *Task) DeleteProcess(ctx context.Context, id string) (*runtime.Exit, error)
  • func (t *Task) Exec(ctx context.Context, id string, opts runtime.ExecOpts) (runtime.Process, error)
  • func (t *Task) ID() string
  • func (t *Task) Info() runtime.TaskInfo
  • func (t *Task) Kill(ctx context.Context, signal uint32, all bool) error
  • func (t *Task) Metrics(ctx context.Context) (interface{}, error)
  • func (t *Task) Pause(ctx context.Context) error
  • func (t *Task) Pids(ctx context.Context) ([]uint32, error)
  • func (t *Task) Process(ctx context.Context, id string) (runtime.Process, error)
  • func (t *Task) ResizePty(ctx context.Context, size runtime.ConsoleSize) error
  • func (t *Task) Resume(ctx context.Context) error
  • func (t *Task) Start(ctx context.Context) error
  • func (t *Task) State(ctx context.Context) (runtime.State, error)
  • func (t *Task) Update(ctx context.Context, resources *types.Any) error
  • func (t *Task) Wait(ctx context.Context) (*runtime.Exit, error)

Functions

func New

func New(ic *plugin.InitContext) (interface{}, error)

func ShimConnect

func ShimConnect() shimOpt

func ShimLocal

func ShimLocal(exchange *events.Exchange) shimOpt

func ShimRemote

func ShimRemote(shim, daemonAddress, cgroup string, debug bool, exitHandler func()) shimOpt

Types

type Config

type Config struct {
	// Shim is a path or name of binary implementing the Shim GRPC API
	Shim string `toml:"shim"`
	// Runtime is a path or name of an OCI runtime used by the shim
	Runtime string `toml:"runtime"`
	// RuntimeRoot is the path that shall be used by the OCI runtime for its data
	RuntimeRoot string `toml:"runtime_root"`
	// NoShim calls runc directly from within the pkg
	NoShim bool `toml:"no_shim"`
	// Debug enable debug on the shim
	ShimDebug bool `toml:"shim_debug"`
}

type Process

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

func (*Process) CloseIO

func (p *Process) CloseIO(ctx context.Context) error

func (*Process) ID

func (p *Process) ID() string

func (*Process) Kill

func (p *Process) Kill(ctx context.Context, signal uint32, _ bool) error

func (*Process) ResizePty

func (p *Process) ResizePty(ctx context.Context, size runtime.ConsoleSize) error

func (*Process) Start

func (p *Process) Start(ctx context.Context) error

func (*Process) State

func (p *Process) State(ctx context.Context) (runtime.State, error)

func (*Process) Wait

func (p *Process) Wait(ctx context.Context) (*runtime.Exit, error)

type Runtime

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

func (*Runtime) Create

func (r *Runtime) Create(ctx context.Context, id string, opts runtime.CreateOpts) (_ runtime.Task, err error)

func (*Runtime) Delete

func (r *Runtime) Delete(ctx context.Context, c runtime.Task) (*runtime.Exit, error)

func (*Runtime) Get

func (r *Runtime) Get(ctx context.Context, id string) (runtime.Task, error)

func (*Runtime) ID

func (r *Runtime) ID() string

func (*Runtime) Tasks

func (r *Runtime) Tasks(ctx context.Context) ([]runtime.Task, error)

type Task

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

func (*Task) Cgroup

func (t *Task) Cgroup() cgroups.Cgroup

func (*Task) Checkpoint

func (t *Task) Checkpoint(ctx context.Context, path string, options *types.Any) error

func (*Task) CloseIO

func (t *Task) CloseIO(ctx context.Context) error

func (*Task) DeleteProcess

func (t *Task) DeleteProcess(ctx context.Context, id string) (*runtime.Exit, error)

func (*Task) Exec

func (t *Task) Exec(ctx context.Context, id string, opts runtime.ExecOpts) (runtime.Process, error)

func (*Task) ID

func (t *Task) ID() string

func (*Task) Info

func (t *Task) Info() runtime.TaskInfo

func (*Task) Kill

func (t *Task) Kill(ctx context.Context, signal uint32, all bool) error

func (*Task) Metrics

func (t *Task) Metrics(ctx context.Context) (interface{}, error)

func (*Task) Pause

func (t *Task) Pause(ctx context.Context) error

func (*Task) Pids

func (t *Task) Pids(ctx context.Context) ([]uint32, error)

func (*Task) Process

func (t *Task) Process(ctx context.Context, id string) (runtime.Process, error)

func (*Task) ResizePty

func (t *Task) ResizePty(ctx context.Context, size runtime.ConsoleSize) error

func (*Task) Resume

func (t *Task) Resume(ctx context.Context) error

func (*Task) Start

func (t *Task) Start(ctx context.Context) error

func (*Task) State

func (t *Task) State(ctx context.Context) (runtime.State, error)

func (*Task) Update

func (t *Task) Update(ctx context.Context, resources *types.Any) error

func (*Task) Wait

func (t *Task) Wait(ctx context.Context) (*runtime.Exit, error)