rundmc

package
v0.0.0-...-53a29fe Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 17, 2015 License: Apache-2.0 Imports: 18 Imported by: 0

README

RunDMC - Diminuatively Managed RunC Containers

RunDMC is a small wrapper around runC.

High Level Architecture

Each container is stored as a subdirectory of a directory called 'the depot'. The depot is the source of truth for RunDMC, when a container is created, this amounts to creating an Open Container Spec compliant container as a subdirectory of the depot directory. The subdirectory is named after the container's handle. Looking up a container amounts to checking for the presence of a subdirectory with the right name.

To execute processes in a container, we launch the runc binary inside the container directory and pass it a custom process spec. Since we want to control the container lifecycle via the API without the restriction that the container dies when its first process dies, the containers are always created with a no-op initial process that never exits. User processes are all executed using runc exec.

The process_tracker allows reattaching to running containers when RunDMC is restarted. It holds on to process input/output streams and allows reconnecting to them later.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BundleRunner

type BundleRunner interface {
	Start(log lager.Logger, bundlePath, id string, io garden.ProcessIO) (garden.Process, error)
	Exec(log lager.Logger, id string, spec garden.ProcessSpec, io garden.ProcessIO) (garden.Process, error)
	Kill(log lager.Logger, bundlePath string) error
}

type BundleTemplate

type BundleTemplate struct {
	*goci.Bndl
}

func (BundleTemplate) Bundle

type Bundler

type Bundler interface {
	Bundle(spec gardener.DesiredContainerSpec) *goci.Bndl
}

type CgroupStarter

type CgroupStarter struct {
	CgroupPath    string
	CommandRunner command_runner.CommandRunner

	ProcCgroups io.ReadCloser
	Logger      lager.Logger
}

func (*CgroupStarter) Start

func (s *CgroupStarter) Start() error

type Checker

type Checker interface {
	Check(log lager.Logger, output io.Reader) error
}

type ContainerStater

type ContainerStater interface {
	State(log lager.Logger, id string) (State, error)
}

type Containerizer

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

Containerizer knows how to manage a depot of container bundles

func New

func New(depot Depot, bundler Bundler, runner BundleRunner, startChecker Checker, stateChecker ContainerStater, nstarRunner NstarRunner) *Containerizer

func (*Containerizer) Create

Create creates a bundle in the depot and starts its init process

func (*Containerizer) Destroy

func (c *Containerizer) Destroy(log lager.Logger, handle string) error

Destroy kills any container processes and deletes the bundle directory

func (*Containerizer) Handles

func (c *Containerizer) Handles() ([]string, error)

Handles returns a list of all container handles

func (*Containerizer) Run

Run runs a process inside a running container

func (*Containerizer) StreamIn

func (c *Containerizer) StreamIn(log lager.Logger, handle string, spec garden.StreamInSpec) error

StreamIn streams files in to the container

type Depot

type Depot interface {
	Create(log lager.Logger, handle string, bundle depot.BundleSaver) error
	Lookup(log lager.Logger, handle string) (path string, err error)
	Destroy(log lager.Logger, handle string) error
	Handles() ([]string, error)
}

type NstarRunner

type NstarRunner interface {
	StreamIn(log lager.Logger, pid int, path string, user string, tarStream io.Reader) error
}

func NewNstarRunner

func NewNstarRunner(nstarPath, tarPath string, runner command_runner.CommandRunner) NstarRunner

type StartChecker

type StartChecker struct {
	Expect  string
	Timeout time.Duration
}

func (StartChecker) Check

func (s StartChecker) Check(log lager.Logger, output io.Reader) error

type Starter

type Starter struct {
	*CgroupStarter
}

func NewStarter

func NewStarter(logger lager.Logger, procCgroupReader io.ReadCloser, cgroupMountpoint string, runner command_runner.CommandRunner) *Starter

type State

type State struct {
	Pid int `json:"init_process_pid"`
}

type StateChecker

type StateChecker struct {
	StateFileDir string
	Timeout      time.Duration
}

func (StateChecker) State

func (s StateChecker) State(log lager.Logger, id string) (State, error)

Directories

Path Synopsis
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
This file was generated by counterfeiter
This file was generated by counterfeiter
fake_process_tracker
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳