docker

package module
v0.6.4-0...-c9b916b Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2013 License: Apache-2.0 Imports: 43 Imported by: 0

README

Docker: the Linux container engine

Docker is an open source project to pack, ship and run any application as a lightweight container

Docker containers are both hardware-agnostic and platform-agnostic. This means that they can run anywhere, from your laptop to the largest EC2 compute instance and everything in between - and they don't require that you use a particular language, framework or packaging system. That makes them great building blocks for deploying and scaling web apps, databases and backend services without depending on a particular stack or provider.

Docker is an open-source implementation of the deployment engine which powers dotCloud, a popular Platform-as-a-Service. It benefits directly from the experience accumulated over several years of large-scale operation and support of hundreds of thousands of applications and databases.

Docker L

Better than VMs

A common method for distributing applications and sandbox their execution is to use virtual machines, or VMs. Typical VM formats are VMWare's vmdk, Oracle Virtualbox's vdi, and Amazon EC2's ami. In theory these formats should allow every developer to automatically package their application into a "machine" for easy distribution and deployment. In practice, that almost never happens, for a few reasons:

  • Size: VMs are very large which makes them impractical to store and transfer.
  • Performance: running VMs consumes significant CPU and memory, which makes them impractical in many scenarios, for example local development of multi-tier applications, and large-scale deployment of cpu and memory-intensive applications on large numbers of machines.
  • Portability: competing VM environments don't play well with each other. Although conversion tools do exist, they are limited and add even more overhead.
  • Hardware-centric: VMs were designed with machine operators in mind, not software developers. As a result, they offer very limited tooling for what developers need most: building, testing and running their software. For example, VMs offer no facilities for application versioning, monitoring, configuration, logging or service discovery.

By contrast, Docker relies on a different sandboxing method known as containerization. Unlike traditional virtualization, containerization takes place at the kernel level. Most modern operating system kernels now support the primitives necessary for containerization, including Linux with openvz, vserver and more recently lxc, Solaris with zones and FreeBSD with Jails.

Docker builds on top of these low-level primitives to offer developers a portable format and runtime environment that solves all 4 problems. Docker containers are small (and their transfer can be optimized with layers), they have basically zero memory and cpu overhead, they are completely portable and are designed from the ground up with an application-centric design.

The best part: because docker operates at the OS level, it can still be run inside a VM!

Plays well with others

Docker does not require that you buy into a particular programming language, framework, packaging system or configuration language.

Is your application a Unix process? Does it use files, tcp connections, environment variables, standard Unix streams and command-line arguments as inputs and outputs? Then docker can run it.

Can your application's build be expressed as a sequence of such commands? Then docker can build it.

Escape dependency hell

A common problem for developers is the difficulty of managing all their application's dependencies in a simple and automated way.

This is usually difficult for several reasons:

  • Cross-platform dependencies. Modern applications often depend on a combination of system libraries and binaries, language-specific packages, framework-specific modules, internal components developed for another project, etc. These dependencies live in different "worlds" and require different tools - these tools typically don't work well with each other, requiring awkward custom integrations.

  • Conflicting dependencies. Different applications may depend on different versions of the same dependency. Packaging tools handle these situations with various degrees of ease - but they all handle them in different and incompatible ways, which again forces the developer to do extra work.

  • Custom dependencies. A developer may need to prepare a custom version of their application's dependency. Some packaging systems can handle custom versions of a dependency, others can't - and all of them handle it differently.

Docker solves dependency hell by giving the developer a simple way to express all their application's dependencies in one place, and streamline the process of assembling them. If this makes you think of XKCD 927, don't worry. Docker doesn't replace your favorite packaging systems. It simply orchestrates their use in a simple and repeatable way. How does it do that? With layers.

Docker defines a build as running a sequence of Unix commands, one after the other, in the same container. Build commands modify the contents of the container (usually by installing new files on the filesystem), the next command modifies it some more, etc. Since each build command inherits the result of the previous commands, the order in which the commands are executed expresses dependencies.

Here's a typical Docker build process:

from ubuntu:12.10
run apt-get update
run DEBIAN_FRONTEND=noninteractive apt-get install -q -y python
run DEBIAN_FRONTEND=noninteractive apt-get install -q -y python-pip
run pip install django
run DEBIAN_FRONTEND=noninteractive apt-get install -q -y curl
run curl -L https://github.com/shykes/helloflask/archive/master.tar.gz | tar -xzv
run cd helloflask-master && pip install -r requirements.txt

Note that Docker doesn't care how dependencies are built - as long as they can be built by running a Unix command in a container.

Getting started

Docker can be installed on your local machine as well as servers - both bare metal and virtualized. It is available as a binary on most modern Linux systems, or as a VM on Windows, Mac and other systems.

We also offer an interactive tutorial for quickly learning the basics of using Docker.

For up-to-date install instructions and online tutorials, see the Getting Started page.

Usage examples

Docker can be used to run short-lived commands, long-running daemons (app servers, databases etc.), interactive shell sessions, etc.

You can find a list of real-world examples in the documentation.

Under the hood

Under the hood, Docker is built on the following components:

  • The cgroup and namespacing capabilities of the Linux kernel;
  • AUFS, a powerful union filesystem with copy-on-write capabilities;
  • The Go programming language;
  • lxc, a set of convenience scripts to simplify the creation of Linux containers.

Contributing to Docker

Want to hack on Docker? Awesome! There are instructions to get you started here.

They are probably not perfect, please let us know if anything feels wrong or incomplete.

Transfers of Docker shall be in accordance with applicable export controls of any country and all other applicable legal requirements. Docker shall not be distributed or downloaded to or in Cuba, Iran, North Korea, Sudan or Syria and shall not be distributed or downloaded to any person on the Denied Persons List administered by the U.S. Department of Commerce.

Documentation

Index

Constants

View Source
const (
	ChangeModify = iota
	ChangeAdd
	ChangeDelete
)
View Source
const (
	DefaultNetworkBridge = "docker0"
	DisableNetworkBridge = "none"
)
View Source
const (
	UDPConnTrackTimeout = 90 * time.Second
	UDPBufSize          = 2048
)
View Source
const APIVERSION = 1.5
View Source
const DEFAULTHTTPHOST = "127.0.0.1"
View Source
const DEFAULTHTTPPORT = 4243
View Source
const DEFAULTTAG = "latest"
View Source
const DEFAULTUNIXSOCKET = "/var/run/docker.sock"
View Source
const LxcHostConfigTemplate = `
{{if .LxcConf}}
{{range $pair := .LxcConf}}
{{$pair.Key}} = {{$pair.Value}}
{{end}}
{{end}}
`
View Source
const LxcTemplate = `` /* 4000-byte string literal not displayed */

Variables

View Source
var (
	GITCOMMIT string
	VERSION   string
)
View Source
var (
	ErrConnectionRefused = errors.New("Can't connect to docker daemon. Is 'docker -d' running on this host?")
)
View Source
var ErrImageReferenced = errors.New("Image referenced by a repository")
View Source
var (
	ErrInvaidWorikingDirectory = errors.New("The working directory is invalid. It needs to be an absolute path.")
)
View Source
var LxcHostConfigTemplateCompiled *template.Template
View Source
var LxcTemplateCompiled *template.Template
View Source
var NetworkBridgeIface string

Functions

func CmdStream

func CmdStream(cmd *exec.Cmd) (io.Reader, error)

CmdStream executes a command, and returns its stdout as a stream. If the command fails to run or doesn't complete successfully, an error will be returned, including anything written on stderr.

func CompareConfig

func CompareConfig(a, b *Config) bool

Compare two Config struct. Do not compare the "Image" nor "Hostname" fields If OpenStdin is set, then it differs

func CopyFileWithTar

func CopyFileWithTar(src, dst string) error

CopyFileWithTar emulates the behavior of the 'cp' command-line for a single file. It copies a regular file from path `src` to path `dst`, and preserves all its metadata.

If `dst` ends with a trailing slash '/', the final destination path will be `dst/base(src)`.

func CopyWithTar

func CopyWithTar(src, dst string) error

CopyWithTar creates a tar archive of filesystem path `src`, and unpacks it at filesystem path `dst`. The archive is streamed directly with fixed buffering and no intermediary disk IO.

func CreateBridgeIface

func CreateBridgeIface(ifaceName string) error

CreateBridgeIface creates a network bridge interface on the host system with the name `ifaceName`, and attempts to configure it with an address which doesn't conflict with any other interface on the host. If it can't find an address which doesn't conflict, it will return an error.

func GenerateID

func GenerateID() string

func ListenAndServe

func ListenAndServe(proto, addr string, srv *Server, logging bool) error

func MergeConfig

func MergeConfig(userConf, imageConf *Config)

func MountAUFS

func MountAUFS(ro []string, rw string, target string) error

func Mounted

func Mounted(mountpoint string) (bool, error)

func ParseCommands

func ParseCommands(proto, addr string, args ...string) error

func ParseRun

func ParseRun(args []string, capabilities *Capabilities) (*Config, *HostConfig, *flag.FlagSet, error)

func StoreImage

func StoreImage(img *Image, jsonData []byte, layerData Archive, root string) error

func StoreSize

func StoreSize(img *Image, root string) error

func Subcmd

func Subcmd(name, signature, description string) *flag.FlagSet

func SysInit

func SysInit()

Sys Init code This code is run INSIDE the container and is responsible for setting up the environment before running the actual process

func Tar

func Tar(path string, compression Compression) (io.Reader, error)

Tar creates an archive from the directory at `path`, and returns it as a stream of bytes.

func TarFilter

func TarFilter(path string, compression Compression, filter []string) (io.Reader, error)

Tar creates an archive from the directory at `path`, only including files whose relative paths are included in `filter`. If `filter` is nil, then all files are included.

func TarUntar

func TarUntar(src string, filter []string, dst string) error

TarUntar is a convenience function which calls Tar and Untar, with the output of one piped into the other. If either Tar or Untar fails, TarUntar aborts and returns the error.

func Unmount

func Unmount(target string) error

func Untar

func Untar(archive io.Reader, path string) error

Untar reads a stream of bytes from `archive`, parses it as a tar archive, and unpacks it into the directory at `path`. The archive may be compressed with one of the following algorithms:

identity (uncompressed), gzip, bzip2, xz.

FIXME: specify behavior when target path exists vs. doesn't exist.

func UntarPath

func UntarPath(src, dst string) error

UntarPath is a convenience function which looks for an archive at filesystem path `src`, and unpacks it at `dst`.

func ValidateID

func ValidateID(id string) error

Types

type APIAuth

type APIAuth struct {
	Status string
}

type APIContainers

type APIContainers struct {
	ID         string `json:"Id"`
	Image      string
	Command    string
	Created    int64
	Status     string
	Ports      []APIPort
	SizeRw     int64
	SizeRootFs int64
}

func (*APIContainers) ToLegacy

func (self *APIContainers) ToLegacy() APIContainersOld

type APIContainersOld

type APIContainersOld struct {
	ID         string `json:"Id"`
	Image      string
	Command    string
	Created    int64
	Status     string
	Ports      string
	SizeRw     int64
	SizeRootFs int64
}

type APICopy

type APICopy struct {
	Resource string
	HostPath string
}

type APIHistory

type APIHistory struct {
	ID        string   `json:"Id"`
	Tags      []string `json:",omitempty"`
	Created   int64
	CreatedBy string `json:",omitempty"`
}

type APIID

type APIID struct {
	ID string `json:"Id"`
}

type APIImageConfig

type APIImageConfig struct {
	ID string `json:"Id"`
	*Config
}

type APIImages

type APIImages struct {
	Repository  string `json:",omitempty"`
	Tag         string `json:",omitempty"`
	ID          string `json:"Id"`
	Created     int64
	Size        int64
	VirtualSize int64
}

type APIInfo

type APIInfo struct {
	Debug              bool
	Containers         int
	Images             int
	NFd                int    `json:",omitempty"`
	NGoroutines        int    `json:",omitempty"`
	MemoryLimit        bool   `json:",omitempty"`
	SwapLimit          bool   `json:",omitempty"`
	IPv4Forwarding     bool   `json:",omitempty"`
	LXCVersion         string `json:",omitempty"`
	NEventsListener    int    `json:",omitempty"`
	KernelVersion      string `json:",omitempty"`
	IndexServerAddress string `json:",omitempty"`
}

type APIPort

type APIPort struct {
	PrivatePort int64
	PublicPort  int64
	Type        string
}

func (*APIPort) MarshalJSON

func (port *APIPort) MarshalJSON() ([]byte, error)

type APIRmi

type APIRmi struct {
	Deleted  string `json:",omitempty"`
	Untagged string `json:",omitempty"`
}

type APIRun

type APIRun struct {
	ID       string   `json:"Id"`
	Warnings []string `json:",omitempty"`
}

type APISearch

type APISearch struct {
	Name        string
	Description string
}

type APITop

type APITop struct {
	Titles    []string
	Processes [][]string
}

type APIVersion

type APIVersion struct {
	Version   string
	GitCommit string `json:",omitempty"`
	GoVersion string `json:",omitempty"`
}

type APIWait

type APIWait struct {
	StatusCode int
}

type Archive

type Archive io.Reader

type AttachOpts

type AttachOpts map[string]bool

AttachOpts stores arguments to 'docker run -a', eg. which streams to attach to

func NewAttachOpts

func NewAttachOpts() AttachOpts

func (AttachOpts) Get

func (opts AttachOpts) Get(val string) bool

func (AttachOpts) Set

func (opts AttachOpts) Set(val string) error

func (AttachOpts) String

func (opts AttachOpts) String() string

type BindMap

type BindMap struct {
	SrcPath string
	DstPath string
	Mode    string
}

type BuildFile

type BuildFile interface {
	Build(io.Reader) (string, error)
	CmdFrom(string) error
	CmdRun(string) error
}

func NewBuildFile

func NewBuildFile(srv *Server, out io.Writer, verbose, utilizeCache, rm bool) BuildFile

type Capabilities

type Capabilities struct {
	MemoryLimit            bool
	SwapLimit              bool
	IPv4ForwardingDisabled bool
}

type Change

type Change struct {
	Path string
	Kind ChangeType
}

func Changes

func Changes(layers []string, rw string) ([]Change, error)

func (*Change) String

func (change *Change) String() string

type ChangeType

type ChangeType int

type Compression

type Compression uint32
const (
	Uncompressed Compression = iota
	Bzip2
	Gzip
	Xz
)

func DetectCompression

func DetectCompression(source []byte) Compression

func (*Compression) Extension

func (compression *Compression) Extension() string

func (*Compression) Flag

func (compression *Compression) Flag() string

type Config

type Config struct {
	Hostname        string
	Domainname      string
	User            string
	Memory          int64 // Memory limit (in bytes)
	MemorySwap      int64 // Total memory usage (memory + swap); set `-1' to disable swap
	CpuShares       int64 // CPU shares (relative weight vs. other containers)
	AttachStdin     bool
	AttachStdout    bool
	AttachStderr    bool
	PortSpecs       []string
	Tty             bool // Attach standard streams to a tty, including stdin if it is not closed.
	OpenStdin       bool // Open stdin
	StdinOnce       bool // If true, close stdin after the 1 attached client disconnects.
	Env             []string
	Cmd             []string
	Dns             []string
	Image           string // Name of the image as it was passed by the operator (eg. could be symbolic)
	Volumes         map[string]struct{}
	VolumesFrom     string
	WorkingDir      string
	Entrypoint      []string
	NetworkDisabled bool
	Privileged      bool
}

type Container

type Container struct {
	ID string

	Created time.Time

	Path string
	Args []string

	Config *Config
	State  State
	Image  string

	NetworkSettings *NetworkSettings

	SysInitPath    string
	ResolvConfPath string
	HostnamePath   string
	HostsPath      string

	Volumes map[string]string
	// Store rw/ro in a separate structure to preserve reverse-compatibility on-disk.
	// Easier than migrating older container configs :)
	VolumesRW map[string]bool
	// contains filtered or unexported fields
}

func (*Container) Attach

func (container *Container) Attach(stdin io.ReadCloser, stdinCloser io.Closer, stdout io.Writer, stderr io.Writer) chan error

func (*Container) Changes

func (container *Container) Changes() ([]Change, error)

func (*Container) Cmd

func (container *Container) Cmd() *exec.Cmd

func (*Container) Copy

func (container *Container) Copy(resource string) (Archive, error)

func (*Container) EnsureMounted

func (container *Container) EnsureMounted() error

func (*Container) Export

func (container *Container) Export() (Archive, error)

func (*Container) ExportRw

func (container *Container) ExportRw() (Archive, error)

func (*Container) FromDisk

func (container *Container) FromDisk() error

func (*Container) GetImage

func (container *Container) GetImage() (*Image, error)

func (*Container) GetSize

func (container *Container) GetSize() (int64, int64)

GetSize, return real size, virtual size

func (*Container) Inject

func (container *Container) Inject(file io.Reader, pth string) error

Inject the io.Reader at the given path. Note: do not close the reader

func (*Container) Kill

func (container *Container) Kill() error

func (*Container) Mount

func (container *Container) Mount() error

func (*Container) Mounted

func (container *Container) Mounted() (bool, error)

func (*Container) Output

func (container *Container) Output() (output []byte, err error)

func (*Container) ReadHostConfig

func (container *Container) ReadHostConfig() (*HostConfig, error)

func (*Container) ReadLog

func (container *Container) ReadLog(name string) (io.Reader, error)

func (*Container) Resize

func (container *Container) Resize(h, w int) error

func (*Container) Restart

func (container *Container) Restart(seconds int) error

func (*Container) RootfsPath

func (container *Container) RootfsPath() string

This method must be exported to be used from the lxc template

func (*Container) Run

func (container *Container) Run() error

func (*Container) RwChecksum

func (container *Container) RwChecksum() (string, error)

func (*Container) SaveHostConfig

func (container *Container) SaveHostConfig(hostConfig *HostConfig) (err error)

func (*Container) ShortID

func (container *Container) ShortID() string

ShortID returns a shorthand version of the container's id for convenience. A collision with other container shorthands is very unlikely, but possible. In case of a collision a lookup with Runtime.Get() will fail, and the caller will need to use a langer prefix, or the full-length container Id.

func (*Container) Start

func (container *Container) Start(hostConfig *HostConfig) error

func (*Container) StderrPipe

func (container *Container) StderrPipe() (io.ReadCloser, error)

func (*Container) StdinPipe

func (container *Container) StdinPipe() (io.WriteCloser, error)

StdinPipe() returns a pipe connected to the standard input of the container's active process.

func (*Container) StdoutPipe

func (container *Container) StdoutPipe() (io.ReadCloser, error)

func (*Container) Stop

func (container *Container) Stop(seconds int) error

func (*Container) ToDisk

func (container *Container) ToDisk() (err error)

func (*Container) Unmount

func (container *Container) Unmount() error

func (*Container) Wait

func (container *Container) Wait() int

Wait blocks until the container stops running, then returns its exit code.

func (*Container) WaitTimeout

func (container *Container) WaitTimeout(timeout time.Duration) error

func (*Container) When

func (container *Container) When() time.Time

type DockerCli

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

func NewDockerCli

func NewDockerCli(in io.ReadCloser, out, err io.Writer, proto, addr string) *DockerCli

func (*DockerCli) CmdAttach

func (cli *DockerCli) CmdAttach(args ...string) error

func (*DockerCli) CmdBuild

func (cli *DockerCli) CmdBuild(args ...string) error

func (*DockerCli) CmdCommit

func (cli *DockerCli) CmdCommit(args ...string) error

func (*DockerCli) CmdCp

func (cli *DockerCli) CmdCp(args ...string) error

func (*DockerCli) CmdDiff

func (cli *DockerCli) CmdDiff(args ...string) error

func (*DockerCli) CmdEvents

func (cli *DockerCli) CmdEvents(args ...string) error

func (*DockerCli) CmdExport

func (cli *DockerCli) CmdExport(args ...string) error

func (*DockerCli) CmdHelp

func (cli *DockerCli) CmdHelp(args ...string) error

func (*DockerCli) CmdHistory

func (cli *DockerCli) CmdHistory(args ...string) error

func (*DockerCli) CmdImages

func (cli *DockerCli) CmdImages(args ...string) error

func (*DockerCli) CmdImport

func (cli *DockerCli) CmdImport(args ...string) error

func (*DockerCli) CmdInfo

func (cli *DockerCli) CmdInfo(args ...string) error

'docker info': display system-wide information.

func (*DockerCli) CmdInsert

func (cli *DockerCli) CmdInsert(args ...string) error

func (*DockerCli) CmdInspect

func (cli *DockerCli) CmdInspect(args ...string) error

func (*DockerCli) CmdKill

func (cli *DockerCli) CmdKill(args ...string) error

'docker kill NAME' kills a running container

func (*DockerCli) CmdLogin

func (cli *DockerCli) CmdLogin(args ...string) error

'docker login': login / register a user to registry service.

func (*DockerCli) CmdLogs

func (cli *DockerCli) CmdLogs(args ...string) error

func (*DockerCli) CmdPort

func (cli *DockerCli) CmdPort(args ...string) error

func (*DockerCli) CmdPs

func (cli *DockerCli) CmdPs(args ...string) error

func (*DockerCli) CmdPull

func (cli *DockerCli) CmdPull(args ...string) error

func (*DockerCli) CmdPush

func (cli *DockerCli) CmdPush(args ...string) error

func (*DockerCli) CmdRestart

func (cli *DockerCli) CmdRestart(args ...string) error

func (*DockerCli) CmdRm

func (cli *DockerCli) CmdRm(args ...string) error

func (*DockerCli) CmdRmi

func (cli *DockerCli) CmdRmi(args ...string) error

'docker rmi IMAGE' removes all images with the name IMAGE

func (*DockerCli) CmdRun

func (cli *DockerCli) CmdRun(args ...string) error

func (*DockerCli) CmdSearch

func (cli *DockerCli) CmdSearch(args ...string) error

func (*DockerCli) CmdStart

func (cli *DockerCli) CmdStart(args ...string) error

func (*DockerCli) CmdStop

func (cli *DockerCli) CmdStop(args ...string) error

func (*DockerCli) CmdTag

func (cli *DockerCli) CmdTag(args ...string) error

func (*DockerCli) CmdTop

func (cli *DockerCli) CmdTop(args ...string) error

func (*DockerCli) CmdVersion

func (cli *DockerCli) CmdVersion(args ...string) error

'docker version': show version information

func (*DockerCli) CmdWait

func (cli *DockerCli) CmdWait(args ...string) error

'docker wait': block until a container stops

func (*DockerCli) LoadConfigFile

func (cli *DockerCli) LoadConfigFile() (err error)

type Graph

type Graph struct {
	Root string
	// contains filtered or unexported fields
}

A Graph is a store for versioned filesystem images and the relationship between them.

func NewGraph

func NewGraph(root string) (*Graph, error)

NewGraph instantiates a new graph at the given root path in the filesystem. `root` will be created if it doesn't exist.

func (*Graph) ByParent

func (graph *Graph) ByParent() (map[string][]*Image, error)

ByParent returns a lookup table of images by their parent. If an image of id ID has 3 children images, then the value for key ID will be a list of 3 images. If an image has no children, it will not have an entry in the table.

func (*Graph) Create

func (graph *Graph) Create(layerData Archive, container *Container, comment, author string, config *Config) (*Image, error)

Create creates a new image and registers it in the graph.

func (*Graph) Delete

func (graph *Graph) Delete(name string) error

Delete atomically removes an image from the graph.

func (*Graph) Exists

func (graph *Graph) Exists(id string) bool

Exists returns true if an image is registered at the given id. If the image doesn't exist or if an error is encountered, false is returned.

func (*Graph) Get

func (graph *Graph) Get(name string) (*Image, error)

Get returns the image with the given id, or an error if the image doesn't exist.

func (*Graph) Heads

func (graph *Graph) Heads() (map[string]*Image, error)

Heads returns all heads in the graph, keyed by id. A head is an image which is not the parent of another image in the graph.

func (*Graph) IsNotExist

func (graph *Graph) IsNotExist(err error) bool

FIXME: Implement error subclass instead of looking at the error text Note: This is the way golang implements os.IsNotExists on Plan9

func (*Graph) Map

func (graph *Graph) Map() (map[string]*Image, error)

Map returns a list of all images in the graph, addressable by ID.

func (*Graph) Mktemp

func (graph *Graph) Mktemp(id string) (string, error)

Mktemp creates a temporary sub-directory inside the graph's filesystem.

func (*Graph) Register

func (graph *Graph) Register(jsonData []byte, layerData Archive, img *Image) error

Register imports a pre-existing image into the graph. FIXME: pass img as first argument

func (*Graph) TempLayerArchive

func (graph *Graph) TempLayerArchive(id string, compression Compression, sf *utils.StreamFormatter, output io.Writer) (*TempArchive, error)

TempLayerArchive creates a temporary archive of the given image's filesystem layer.

The archive is stored on disk and will be automatically deleted as soon as has been read.
If output is not nil, a human-readable progress bar will be written to it.
FIXME: does this belong in Graph? How about MktempFile, let the caller use it for archives?

type History

type History []*Container

History is a convenience type for storing a list of containers, ordered by creation date.

func (*History) Add

func (history *History) Add(container *Container)

func (*History) Len

func (history *History) Len() int

func (*History) Less

func (history *History) Less(i, j int) bool

func (*History) Swap

func (history *History) Swap(i, j int)

type HostConfig

type HostConfig struct {
	Binds           []string
	ContainerIDFile string
	LxcConf         []KeyValuePair
}

type HttpApiFunc

type HttpApiFunc func(srv *Server, version float64, w http.ResponseWriter, r *http.Request, vars map[string]string) error

type IPAllocator

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

IP allocator: Automatically allocate and release networking ports

func (*IPAllocator) Acquire

func (alloc *IPAllocator) Acquire() (net.IP, error)

func (*IPAllocator) Release

func (alloc *IPAllocator) Release(ip net.IP)

type Image

type Image struct {
	ID              string    `json:"id"`
	Parent          string    `json:"parent,omitempty"`
	Comment         string    `json:"comment,omitempty"`
	Created         time.Time `json:"created"`
	Container       string    `json:"container,omitempty"`
	ContainerConfig Config    `json:"container_config,omitempty"`
	DockerVersion   string    `json:"docker_version,omitempty"`
	Author          string    `json:"author,omitempty"`
	Config          *Config   `json:"config,omitempty"`
	Architecture    string    `json:"architecture,omitempty"`

	Size int64
	// contains filtered or unexported fields
}

func LoadImage

func LoadImage(root string) (*Image, error)

func NewImgJSON

func NewImgJSON(src []byte) (*Image, error)

Build an Image object from raw json data

func (*Image) Changes

func (image *Image) Changes(rw string) ([]Change, error)

func (*Image) GetParent

func (img *Image) GetParent() (*Image, error)

func (*Image) History

func (img *Image) History() ([]*Image, error)

Image includes convenience proxy functions to its graph These functions will return an error if the image is not registered (ie. if image.graph == nil)

func (*Image) Mount

func (image *Image) Mount(root, rw string) error

func (*Image) ShortID

func (image *Image) ShortID() string

func (*Image) TarLayer

func (image *Image) TarLayer(compression Compression) (Archive, error)

TarLayer returns a tar archive of the image's filesystem layer.

func (*Image) WalkHistory

func (img *Image) WalkHistory(handler func(*Image) error) (err error)

type KeyValuePair

type KeyValuePair struct {
	Key   string
	Value string
}

type ListOpts

type ListOpts []string

ListOpts type

func (*ListOpts) Set

func (opts *ListOpts) Set(value string) error

func (*ListOpts) String

func (opts *ListOpts) String() string

type Nat

type Nat struct {
	Proto    string
	Frontend int
	Backend  int
}

type NetworkInterface

type NetworkInterface struct {
	IPNet   net.IPNet
	Gateway net.IP
	// contains filtered or unexported fields
}

Network interface represents the networking stack of a container

func (*NetworkInterface) AllocatePort

func (iface *NetworkInterface) AllocatePort(spec string) (*Nat, error)

Allocate an external TCP port and map it to the interface

func (*NetworkInterface) Release

func (iface *NetworkInterface) Release()

Release: Network cleanup - release all resources

type NetworkManager

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

Network Manager manages a set of network interfaces Only *one* manager per host machine should be used

func (*NetworkManager) Allocate

func (manager *NetworkManager) Allocate() (*NetworkInterface, error)

Allocate a network interface

type NetworkSettings

type NetworkSettings struct {
	IPAddress   string
	IPPrefixLen int
	Gateway     string
	Bridge      string
	PortMapping map[string]PortMapping
}

func (*NetworkSettings) PortMappingAPI

func (settings *NetworkSettings) PortMappingAPI() []APIPort

returns a more easy to process description of the port mapping defined in the settings

type PathOpts

type PathOpts map[string]struct{}

PathOpts stores a unique set of absolute paths

func NewPathOpts

func NewPathOpts() PathOpts

func (PathOpts) Set

func (opts PathOpts) Set(val string) error

func (PathOpts) String

func (opts PathOpts) String() string

type PortAllocator

type PortAllocator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Port allocator: Automatically allocate and release networking ports

func (*PortAllocator) Acquire

func (alloc *PortAllocator) Acquire(port int) (int, error)

func (*PortAllocator) Release

func (alloc *PortAllocator) Release(port int) error

FIXME: Release can no longer fail, change its prototype to reflect that.

type PortMapper

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

Port mapper takes care of mapping external ports to containers by setting up iptables rules. It keeps track of all mappings and is able to unmap at will

func (*PortMapper) Map

func (mapper *PortMapper) Map(port int, backendAddr net.Addr) error

func (*PortMapper) Unmap

func (mapper *PortMapper) Unmap(port int, proto string) error

type PortMapping

type PortMapping map[string]string

type Proxy

type Proxy interface {
	// Start forwarding traffic back and forth the front and back-end
	// addresses.
	Run()
	// Stop forwarding traffic and close both ends of the Proxy.
	Close()
	// Return the address on which the proxy is listening.
	FrontendAddr() net.Addr
	// Return the proxied address.
	BackendAddr() net.Addr
}

func NewProxy

func NewProxy(frontendAddr, backendAddr net.Addr) (Proxy, error)

type Repository

type Repository map[string]string

type Runtime

type Runtime struct {
	Dns []string
	// contains filtered or unexported fields
}

func NewRuntime

func NewRuntime(flGraphPath string, autoRestart bool, dns []string) (*Runtime, error)

FIXME: harmonize with NewGraph()

func NewRuntimeFromDirectory

func NewRuntimeFromDirectory(root string, autoRestart bool) (*Runtime, error)

func (*Runtime) Commit

func (runtime *Runtime) Commit(container *Container, repository, tag, comment, author string, config *Config) (*Image, error)

Commit creates a new filesystem image from the current state of a container. The image can optionally be tagged into a repository

func (*Runtime) Create

func (runtime *Runtime) Create(config *Config) (*Container, error)

Create creates a new container from the given configuration.

func (*Runtime) Destroy

func (runtime *Runtime) Destroy(container *Container) error

Destroy unregisters a container from the runtime and cleanly removes its contents from the filesystem.

func (*Runtime) Exists

func (runtime *Runtime) Exists(id string) bool

Exists returns a true if a container of the specified ID or name exists, false otherwise.

func (*Runtime) Get

func (runtime *Runtime) Get(name string) *Container

Get looks for a container by the specified ID or name, and returns it. If the container is not found, or if an error occurs, nil is returned.

func (*Runtime) List

func (runtime *Runtime) List() []*Container

List returns an array of all containers registered in the runtime.

func (*Runtime) Load

func (runtime *Runtime) Load(id string) (*Container, error)

Load reads the contents of a container from disk and registers it with Register. This is typically done at startup.

func (*Runtime) LogToDisk

func (runtime *Runtime) LogToDisk(src *utils.WriteBroadcaster, dst, stream string) error

func (*Runtime) Register

func (runtime *Runtime) Register(container *Container) error

Register makes a container object usable by the runtime as <container.ID>

func (*Runtime) UpdateCapabilities

func (runtime *Runtime) UpdateCapabilities(quiet bool)

FIXME: comment please!

type Server

type Server struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(flGraphPath string, autoRestart, enableCors bool, dns ListOpts) (*Server, error)

func (*Server) ContainerAttach

func (srv *Server) ContainerAttach(name string, logs, stream, stdin, stdout, stderr bool, in io.ReadCloser, out io.Writer) error

func (*Server) ContainerChanges

func (srv *Server) ContainerChanges(name string) ([]Change, error)

func (*Server) ContainerCommit

func (srv *Server) ContainerCommit(name, repo, tag, author, comment string, config *Config) (string, error)

func (*Server) ContainerCopy

func (srv *Server) ContainerCopy(name string, resource string, out io.Writer) error

func (*Server) ContainerCreate

func (srv *Server) ContainerCreate(config *Config) (string, error)

func (*Server) ContainerDestroy

func (srv *Server) ContainerDestroy(name string, removeVolume bool) error

func (*Server) ContainerExport

func (srv *Server) ContainerExport(name string, out io.Writer) error

func (*Server) ContainerInspect

func (srv *Server) ContainerInspect(name string) (*Container, error)

func (*Server) ContainerKill

func (srv *Server) ContainerKill(name string) error

func (*Server) ContainerResize

func (srv *Server) ContainerResize(name string, h, w int) error

func (*Server) ContainerRestart

func (srv *Server) ContainerRestart(name string, t int) error

func (*Server) ContainerStart

func (srv *Server) ContainerStart(name string, hostConfig *HostConfig) error

func (*Server) ContainerStop

func (srv *Server) ContainerStop(name string, t int) error

func (*Server) ContainerTag

func (srv *Server) ContainerTag(name, repo, tag string, force bool) error

func (*Server) ContainerTop

func (srv *Server) ContainerTop(name, ps_args string) (*APITop, error)

func (*Server) ContainerWait

func (srv *Server) ContainerWait(name string) (int, error)

func (*Server) Containers

func (srv *Server) Containers(all, size bool, n int, since, before string) []APIContainers

func (*Server) DockerInfo

func (srv *Server) DockerInfo() *APIInfo

func (*Server) DockerVersion

func (srv *Server) DockerVersion() APIVersion

func (*Server) HTTPRequestFactory

func (srv *Server) HTTPRequestFactory(metaHeaders map[string][]string) *utils.HTTPRequestFactory

func (*Server) ImageDelete

func (srv *Server) ImageDelete(name string, autoPrune bool) ([]APIRmi, error)

func (*Server) ImageGetCached

func (srv *Server) ImageGetCached(imgID string, config *Config) (*Image, error)

func (*Server) ImageHistory

func (srv *Server) ImageHistory(name string) ([]APIHistory, error)

func (*Server) ImageImport

func (srv *Server) ImageImport(src, repo, tag string, in io.Reader, out io.Writer, sf *utils.StreamFormatter) error

func (*Server) ImageInsert

func (srv *Server) ImageInsert(name, url, path string, out io.Writer, sf *utils.StreamFormatter) (string, error)

func (*Server) ImageInspect

func (srv *Server) ImageInspect(name string) (*Image, error)

func (*Server) ImagePull

func (srv *Server) ImagePull(localName string, tag string, out io.Writer, sf *utils.StreamFormatter, authConfig *auth.AuthConfig, metaHeaders map[string][]string, parallel bool) error

func (*Server) ImagePush

func (srv *Server) ImagePush(localName string, out io.Writer, sf *utils.StreamFormatter, authConfig *auth.AuthConfig, metaHeaders map[string][]string) error

FIXME: Allow to interrupt current push when new push of same image is done.

func (*Server) Images

func (srv *Server) Images(all bool, filter string) ([]APIImages, error)

func (*Server) ImagesSearch

func (srv *Server) ImagesSearch(term string) ([]APISearch, error)

func (*Server) ImagesViz

func (srv *Server) ImagesViz(out io.Writer) error

func (*Server) LogEvent

func (srv *Server) LogEvent(action, id, from string)

type State

type State struct {
	sync.Mutex
	Running   bool
	Pid       int
	ExitCode  int
	StartedAt time.Time
	Ghost     bool
}

func (*State) String

func (s *State) String() string

String returns a human-readable description of the state

type TCPProxy

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

func NewTCPProxy

func NewTCPProxy(frontendAddr, backendAddr *net.TCPAddr) (*TCPProxy, error)

func (*TCPProxy) BackendAddr

func (proxy *TCPProxy) BackendAddr() net.Addr

func (*TCPProxy) Close

func (proxy *TCPProxy) Close()

func (*TCPProxy) FrontendAddr

func (proxy *TCPProxy) FrontendAddr() net.Addr

func (*TCPProxy) Run

func (proxy *TCPProxy) Run()

type TagStore

type TagStore struct {
	Repositories map[string]Repository
	// contains filtered or unexported fields
}

func NewTagStore

func NewTagStore(path string, graph *Graph) (*TagStore, error)

func (*TagStore) ByID

func (store *TagStore) ByID() map[string][]string

Return a reverse-lookup table of all the names which refer to each image Eg. {"43b5f19b10584": {"base:latest", "base:v1"}}

func (*TagStore) Delete

func (store *TagStore) Delete(repoName, tag string) (bool, error)

func (*TagStore) DeleteAll

func (store *TagStore) DeleteAll(id string) error

func (*TagStore) Get

func (store *TagStore) Get(repoName string) (Repository, error)

func (*TagStore) GetImage

func (store *TagStore) GetImage(repoName, tagOrID string) (*Image, error)

func (*TagStore) ImageName

func (store *TagStore) ImageName(id string) string

func (*TagStore) LookupImage

func (store *TagStore) LookupImage(name string) (*Image, error)

func (*TagStore) Reload

func (store *TagStore) Reload() error

func (*TagStore) Save

func (store *TagStore) Save() error

func (*TagStore) Set

func (store *TagStore) Set(repoName, tag, imageName string, force bool) error

type TempArchive

type TempArchive struct {
	*os.File
	Size int64 // Pre-computed from Stat().Size() as a convenience
}

func NewTempArchive

func NewTempArchive(src Archive, dir string) (*TempArchive, error)

NewTempArchive reads the content of src into a temporary file, and returns the contents of that file as an archive. The archive can only be read once - as soon as reading completes, the file will be deleted.

func (*TempArchive) Read

func (archive *TempArchive) Read(data []byte) (int, error)

type UDPProxy

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

func NewUDPProxy

func NewUDPProxy(frontendAddr, backendAddr *net.UDPAddr) (*UDPProxy, error)

func (*UDPProxy) BackendAddr

func (proxy *UDPProxy) BackendAddr() net.Addr

func (*UDPProxy) Close

func (proxy *UDPProxy) Close()

func (*UDPProxy) FrontendAddr

func (proxy *UDPProxy) FrontendAddr() net.Addr

func (*UDPProxy) Run

func (proxy *UDPProxy) Run()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL