docker – github.com/docker/docker Index | Files | Directories

package docker

import "github.com/docker/docker"

Index

Constants 

const (
	APIVERSION        = 1.6
	DEFAULTHTTPHOST   = "127.0.0.1"
	DEFAULTHTTPPORT   = 4243
	DEFAULTUNIXSOCKET = "/var/run/docker.sock"
)
const (
	ChangeModify = iota
	ChangeAdd
	ChangeDelete
)
const (
	DefaultNetworkBridge = "docker0"
	DisableNetworkBridge = "none"
)
const DEFAULTTAG = "latest"
const LxcHostConfigTemplate = `
{{if .LxcConf}}
{{range $pair := .LxcConf}}
{{$pair.Key}} = {{$pair.Value}}
{{end}}
{{end}}
`
const LxcTemplate = "" /* 3994 byte string literal not displayed */

Variables 

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

Functions 

func BtrfsReflink(fd_out, fd_in uintptr) error

func CmdStream 

func CmdStream(cmd *exec.Cmd, input *string, atEnd func()) (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 CopyFile 

func CopyFile(dstFile, srcFile *os.File) error

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(config *DaemonConfig) 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 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 RootIsShared 

func RootIsShared() bool

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, recursive bool, createFiles []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 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
	Names      []string
}

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 APILink struct {
	Path        string
	ContainerID string
	Image       string
}

type APIPort 

type APIPort struct {
	PrivatePort int64
	PublicPort  int64
	Type        string
	IP          string
}

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 ChangesDirs 

func ChangesDirs(newDir, oldDir string) ([]Change, error)

func ChangesLayers 

func ChangesLayers(newDir string, layers []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 // Deprecated - Can be in the format of 8080/tcp
	ExposedPorts    map[Port]struct{}
	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) EnsureUnmounted 

func (container *Container) EnsureUnmounted() error

func (*Container) Export 

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

func (*Container) ExportRw 

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

func (*Container) Exposes 

func (container *Container) Exposes(p Port) bool

Returns true if the container exposes a certain port

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 DaemonConfig 

type DaemonConfig struct {
	Pidfile        string
	GraphPath      string
	ProtoAddresses []string
	AutoRestart    bool
	EnableCors     bool
	Dns            []string
	EnableIptables bool
	BridgeIface    string
	DefaultIp      net.IP
	DeviceSet      DeviceSet
}

type DeviceSet 

type DeviceSet interface {
	AddDevice(hash, baseHash string) error
	SetInitialized(hash string) error
	DeactivateDevice(hash string) error
	RemoveDevice(hash string) error
	MountDevice(hash, path string) error
	UnmountDevice(hash, path string, deactivate bool) error
	HasDevice(hash string) bool
	HasInitializedDevice(hash string) bool
	HasActivatedDevice(hash string) bool
	Shutdown() error
}

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 (cli *DockerCli) CmdLink(args ...string) error

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) CmdLs 

func (cli *DockerCli) CmdLs(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 FileInfo 

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

func (*FileInfo) Changes 

func (info *FileInfo) Changes(oldInfo *FileInfo) []Change

func (*FileInfo) LookUp 

func (root *FileInfo) LookUp(path string) *FileInfo

func (*FileInfo) Remove 

func (info *FileInfo) Remove(path string) bool

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
	PortBindings    map[Port][]PortBinding
	Links           []string
}

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(runtime *Runtime, root, rw, id string) ([]Change, error)

func (*Image) ExportChanges 

func (image *Image) ExportChanges(runtime *Runtime, root, rw, id string) (Archive, 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(runtime *Runtime, root, rw string, id string) error

func (*Image) Mounted 

func (image *Image) Mounted(runtime *Runtime, root, rw string) (bool, 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) Unmount 

func (image *Image) Unmount(runtime *Runtime, root string, id string) error

func (*Image) WalkHistory 

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

type KeyValuePair 

type KeyValuePair struct {
	Key   string
	Value string
}
type Link struct {
	ParentIP         string
	ChildIP          string
	Name             string
	BridgeInterface  string
	ChildEnvironment []string
	Ports            []Port
	IsEnabled        bool
}
func NewLink(parent, child *Container, name, bridgeInterface string) (*Link, error)

func (*Link) Alias 

func (l *Link) Alias() string

func (*Link) Disable 

func (l *Link) Disable()

func (*Link) Enable 

func (l *Link) Enable() error

func (*Link) ToEnv 

func (l *Link) ToEnv() []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 {
	Port    Port
	Binding PortBinding
}

func (*Nat) String 

func (n *Nat) String() string

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(port Port, binding PortBinding) (*Nat, error)

Allocate an external 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 // Deprecated
	Ports       map[Port][]PortBinding
}

func (*NetworkSettings) PortMappingAPI 

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

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 Port 

type Port string

80/tcp

func NewPort 

func NewPort(proto, port string) Port

func (Port) Int 

func (p Port) Int() int

func (Port) Port 

func (p Port) Port() string

func (Port) Proto 

func (p Port) Proto() 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 PortBinding 

type PortBinding struct {
	HostIp   string
	HostPort string
}

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(ip net.IP, port int, backendAddr net.Addr) error

func (*PortMapper) Unmap 

func (mapper *PortMapper) Unmap(ip net.IP, port int, proto string) error

type PortMapping 

type PortMapping map[string]string // Deprecated

type Repository 

type Repository map[string]string

type Runtime 

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

func NewRuntime 

func NewRuntime(config *DaemonConfig) (*Runtime, error)

FIXME: harmonize with NewGraph()

func NewRuntimeFromDirectory 

func NewRuntimeFromDirectory(config *DaemonConfig) (*Runtime, error)

func (*Runtime) Children 

func (runtime *Runtime) Children(name string) (map[string]*Container, 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, []string, error)

Create creates a new container from the given configuration.

func (*Runtime) DeleteImage 

func (runtime *Runtime) DeleteImage(id string) error

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) GetByName 

func (runtime *Runtime) GetByName(name string) (*Container, error)

func (*Runtime) GetDeviceSet 

func (runtime *Runtime) GetDeviceSet() (DeviceSet, error)
func (runtime *Runtime) Link(parentName, childName, alias string) error

func (*Runtime) List 

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

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

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 *Runtime) RenameLink(oldName, newName string) error

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(config *DaemonConfig) (*Server, error)

func (*Server) ContainerAttach 

func (srv *Server) ContainerAttach(name string, logs, stream, stdin, stdout, stderr bool, inStream io.ReadCloser, outStream, errStream 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, []string, error)

func (*Server) ContainerDestroy 

func (srv *Server) ContainerDestroy(name string, removeVolume, removeLink 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 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 TimeUpdate 

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

Source Files

api.go api_params.go archive.go buildfile.go changes.go commands.go config.go container.go deviceset.go graph.go image.go links.go lxc_template.go mount.go network.go runtime.go server.go sorter.go state.go sysinit.go tags.go utils.go

Directories

PathSynopsis
auth
contrib
devmapper
devmapper/docker-device-tool
docker
docker-init
gograph
iptables
proxy
registry
term
utils
Version
v0.7.0-rc3
Published
Oct 9, 2013
Platform
js/wasm
Imports
47 packages
Last checked
1 second ago –

Tools for package owners.