wasmtime

Documentation

Index

• func GetTopic(e interface{}) string
• func NewPlatform() (rproc.Platform, error)
• type Container
  • func NewContainer(ctx context.Context, platform rproc.Platform, r *task.CreateTaskRequest, ...) (c *Container, err error)
  • func (c *Container) All() (o []rproc.Process)
  • func (c *Container) Cgroup() cgroups.Cgroup
  • func (c *Container) CgroupSet(cg cgroups.Cgroup)
  • func (c *Container) Checkpoint(ctx context.Context, r *task.CheckpointTaskRequest) error
  • func (c *Container) CloseIO(ctx context.Context, r *task.CloseIORequest) error
  • func (c *Container) Delete(ctx context.Context, r *task.DeleteRequest) (rproc.Process, error)
  • func (c *Container) Exec(ctx context.Context, r *task.ExecProcessRequest) (rproc.Process, error)
  • func (c *Container) ExecdProcesses() (o []rproc.Process)
  • func (c *Container) HasPid(pid int) bool
  • func (c *Container) Kill(ctx context.Context, r *task.KillRequest) error
  • func (c *Container) Pause(ctx context.Context) error
  • func (c *Container) Pid() int
  • func (c *Container) Process(id string) (rproc.Process, error)
  • func (c *Container) ProcessAdd(process rproc.Process)
  • func (c *Container) ProcessExists(id string) bool
  • func (c *Container) ProcessRemove(id string)
  • func (c *Container) ResizePty(ctx context.Context, r *task.ResizePtyRequest) error
  • func (c *Container) Resume(ctx context.Context) error
  • func (c *Container) Start(ctx context.Context, r *task.StartRequest) (rproc.Process, error)
  • func (c *Container) Update(ctx context.Context, r *task.UpdateTaskRequest) error
• type Epoller
  • func NewOOMEpoller(publisher shim.Publisher) (*Epoller, error)
  • func (e *Epoller) Add(id string, cg cgroups.Cgroup) error
  • func (e *Epoller) Close() error
  • func (e *Epoller) Run(ctx context.Context)
• type Exit

Functions

func GetTopic

func GetTopic(e interface{}) string

GetTopic converts an event from an interface type to the specific event topic id

func NewPlatform

func NewPlatform() (rproc.Platform, error)

NewPlatform returns a linux platform for use with I/O operations

Types

type Container

type Container struct {

	// ID of the container
	ID string
	// Bundle path
	Bundle string
	// Root Remap
	RootRemap string
	// contains filtered or unexported fields
}

Container for operating on a runc container and its processes

func NewContainer

func NewContainer(ctx context.Context, platform rproc.Platform, r *task.CreateTaskRequest, ec chan<- Exit) (c *Container, err error)

NewContainer returns a new runc container

func (*Container) All

func (c *Container) All() (o []rproc.Process)

All processes in the container

func (*Container) Cgroup

func (c *Container) Cgroup() cgroups.Cgroup

Cgroup of the container

func (*Container) CgroupSet

func (c *Container) CgroupSet(cg cgroups.Cgroup)

CgroupSet sets the cgroup to the container

func (*Container) Checkpoint

func (c *Container) Checkpoint(ctx context.Context, r *task.CheckpointTaskRequest) error

Checkpoint the container

func (*Container) CloseIO

func (c *Container) CloseIO(ctx context.Context, r *task.CloseIORequest) error

CloseIO of a process

func (*Container) Delete

func (c *Container) Delete(ctx context.Context, r *task.DeleteRequest) (rproc.Process, error)

Delete the container or a process by id

func (*Container) Exec

func (c *Container) Exec(ctx context.Context, r *task.ExecProcessRequest) (rproc.Process, error)

Exec an additional process

func (*Container) ExecdProcesses

func (c *Container) ExecdProcesses() (o []rproc.Process)

ExecdProcesses added to the container

func (*Container) HasPid

func (c *Container) HasPid(pid int) bool

HasPid returns true if the container owns a specific pid

func (*Container) Kill

func (c *Container) Kill(ctx context.Context, r *task.KillRequest) error

Kill a process

func (*Container) Pause

func (c *Container) Pause(ctx context.Context) error

Pause the container

func (*Container) Pid

func (c *Container) Pid() int

Pid of the main process of a container

func (*Container) Process

func (c *Container) Process(id string) (rproc.Process, error)

Process returns the process by id

func (*Container) ProcessAdd

func (c *Container) ProcessAdd(process rproc.Process)

ProcessAdd adds a new process to the container

func (*Container) ProcessExists

func (c *Container) ProcessExists(id string) bool

ProcessExists returns true if the process by id exists

func (*Container) ProcessRemove

func (c *Container) ProcessRemove(id string)

ProcessRemove removes the process by id from the container

func (*Container) ResizePty

func (c *Container) ResizePty(ctx context.Context, r *task.ResizePtyRequest) error

ResizePty of a process

func (*Container) Resume

func (c *Container) Resume(ctx context.Context) error

Resume the container

func (*Container) Start

func (c *Container) Start(ctx context.Context, r *task.StartRequest) (rproc.Process, error)

Start a container process

func (*Container) Update

func (c *Container) Update(ctx context.Context, r *task.UpdateTaskRequest) error

Update the resource information of a running container

type Epoller

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

Epoller implementation for handling OOM events from a container's cgroup

func NewOOMEpoller

func NewOOMEpoller(publisher shim.Publisher) (*Epoller, error)

NewOOMEpoller returns an epoll implementation that listens to OOM events from a container's cgroups.

func (*Epoller) Add

func (e *Epoller) Add(id string, cg cgroups.Cgroup) error

Add the cgroup to the epoll monitor

func (*Epoller) Close

func (e *Epoller) Close() error

Close the epoll fd

func (*Epoller) Run

func (e *Epoller) Run(ctx context.Context)

Run the epoll loop

type Exit

type Exit struct {
	Pid    int
	Status int
}