Documentation
¶
Index ¶
- func GetTopic(e interface{}) string
- func NewPlatform() (rproc.Platform, error)
- func ReadRuntime(path string) (string, error)
- func WriteRuntime(path, runtime string) error
- type Container
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetTopic ¶
func GetTopic(e interface{}) string
GetTopic converts an event from an interface type to the specific event topic id
func NewPlatform ¶
NewPlatform returns a linux platform for use with I/O operations
func ReadRuntime ¶
ReadRuntime reads the runtime information from the path
func WriteRuntime ¶
WriteRuntime writes the runtime information into the path
Types ¶
type Container ¶
type Container struct {
// ID of the container
ID string
// Bundle path
Bundle 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) (*Container, error)
NewContainer returns a new runc container
func (*Container) Checkpoint ¶
Checkpoint the container
func (*Container) ExecdProcesses ¶
ExecdProcesses added to the container
func (*Container) ProcessAdd ¶
ProcessAdd adds a new process to the container
func (*Container) ProcessExists ¶
ProcessExists returns true if the process by id exists
func (*Container) ProcessRemove ¶
ProcessRemove removes the process by id from the container
type Epoller ¶
type Epoller struct {
// contains filtered or unexported fields
}
Epoller implementation for handling OOM events from a container's cgroup
func NewOOMEpoller ¶
NewOOMEpoller returns an epoll implementation that listens to OOM events from a container's cgroups.
Source Files
Directories