Documentation ¶
Index ¶
- Constants
- Variables
- func CmdStream(cmd *exec.Cmd) (io.Reader, error)
- func Debugf(format string, a ...interface{})
- func Download(url string, stderr io.Writer) (*http.Response, error)
- func GenerateId() string
- func Go(f func() error) chan error
- func HumanDuration(d time.Duration) string
- func MountAUFS(ro []string, rw string, target string) error
- func Mounted(mountpoint string) (bool, error)
- func NopWriteCloser(w io.Writer) io.WriteCloser
- func ProgressReader(r io.ReadCloser, size int, output io.Writer) *progressReader
- func SelfPath() string
- func StoreImage(img *Image, layerData Archive, root string) error
- func SysInit()
- func Tar(path string, compression Compression) (io.Reader, error)
- func Trunc(s string, maxlen int) string
- func TruncateId(id string) string
- func Unmount(target string) error
- func Untar(archive io.Reader, path string) error
- func ValidateId(id string) error
- type Archive
- type AttachOpts
- type Change
- type ChangeType
- type Compression
- type Config
- type Container
- func (container *Container) Attach(stdin io.Reader, stdout io.Writer, stderr io.Writer) chan error
- func (container *Container) Changes() ([]Change, error)
- func (container *Container) Cmd() *exec.Cmd
- func (container *Container) EnsureMounted() error
- func (container *Container) Export() (Archive, error)
- func (container *Container) ExportRw() (Archive, error)
- func (container *Container) FromDisk() error
- func (container *Container) GetImage() (*Image, error)
- func (container *Container) Kill() error
- func (container *Container) Mount() error
- func (container *Container) Mounted() (bool, error)
- func (container *Container) Output() (output []byte, err error)
- func (container *Container) ReadLog(name string) (io.Reader, error)
- func (container *Container) Restart() error
- func (container *Container) RootfsPath() string
- func (container *Container) Run() error
- func (container *Container) ShortId() string
- func (container *Container) Start() error
- func (container *Container) StderrPipe() (io.ReadCloser, error)
- func (container *Container) StdinPipe() (io.WriteCloser, error)
- func (container *Container) StdoutPipe() (io.ReadCloser, error)
- func (container *Container) Stop() error
- func (container *Container) ToDisk() (err error)
- func (container *Container) Unmount() error
- func (container *Container) Wait() int
- func (container *Container) WaitTimeout(timeout time.Duration) error
- func (container *Container) When() time.Time
- type Graph
- func (graph *Graph) All() ([]*Image, error)
- func (graph *Graph) ByParent() (map[string][]*Image, error)
- func (graph *Graph) Create(layerData Archive, container *Container, comment string) (*Image, error)
- func (graph *Graph) Delete(name string) error
- func (graph *Graph) Exists(id string) bool
- func (graph *Graph) Garbage() (*Graph, error)
- func (graph *Graph) GarbageCollect() error
- func (graph *Graph) Get(name string) (*Image, error)
- func (graph *Graph) Heads() (map[string]*Image, error)
- func (graph *Graph) IsNotExist(err error) bool
- func (graph *Graph) LookupRemoteImage(imgId string, authConfig *auth.AuthConfig) bool
- func (graph *Graph) LookupRemoteRepository(remote string, authConfig *auth.AuthConfig) bool
- func (graph *Graph) Map() (map[string]*Image, error)
- func (graph *Graph) Mktemp(id string) (string, error)
- func (graph *Graph) PullImage(stdout io.Writer, imgId string, authConfig *auth.AuthConfig) error
- func (graph *Graph) PullRepository(stdout io.Writer, remote, askedTag string, repositories *TagStore, ...) error
- func (graph *Graph) PushImage(stdout io.Writer, imgOrig *Image, authConfig *auth.AuthConfig) error
- func (graph *Graph) PushRepository(stdout io.Writer, remote string, localRepo Repository, ...) error
- func (graph *Graph) Register(layerData Archive, img *Image) error
- func (graph *Graph) Undelete(id string) error
- func (graph *Graph) WalkAll(handler func(*Image)) error
- type History
- type IPAllocator
- type Image
- func (image *Image) Changes(rw string) ([]Change, error)
- func (img *Image) GetParent() (*Image, error)
- func (img *Image) History() ([]*Image, error)
- func (image *Image) Mount(root, rw string) error
- func (image *Image) ShortId() string
- func (img *Image) WalkHistory(handler func(*Image) error) (err error)
- type ListOpts
- type NetworkInterface
- type NetworkManager
- type NetworkSettings
- type PortAllocator
- type PortMapper
- type Repository
- type Runtime
- func (runtime *Runtime) Commit(id, repository, tag, comment string) (*Image, error)
- func (runtime *Runtime) Create(config *Config) (*Container, error)
- func (runtime *Runtime) Destroy(container *Container) error
- func (runtime *Runtime) Exists(id string) bool
- func (runtime *Runtime) Get(name string) *Container
- func (runtime *Runtime) List() []*Container
- func (runtime *Runtime) Load(id string) (*Container, error)
- func (runtime *Runtime) LogToDisk(src *writeBroadcaster, dst string) error
- func (runtime *Runtime) Register(container *Container) error
- type Server
- func (srv *Server) CmdAttach(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdCommit(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdDiff(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdExport(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdHistory(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdImages(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdImport(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdInfo(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdInspect(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdKill(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdLogin(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdLogs(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdPort(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdPs(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdPull(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdPush(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdRestart(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdRm(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdRmi(stdin io.ReadCloser, stdout io.Writer, args ...string) (err error)
- func (srv *Server) CmdRun(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdStart(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdStop(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdTag(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdVersion(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) CmdWait(stdin io.ReadCloser, stdout io.Writer, args ...string) error
- func (srv *Server) Help() string
- func (srv *Server) Name() string
- type State
- type TagStore
- func (store *TagStore) ById() map[string][]string
- func (store *TagStore) Get(repoName string) (Repository, error)
- func (store *TagStore) GetImage(repoName, tag string) (*Image, error)
- func (store *TagStore) ImageName(id string) string
- func (store *TagStore) LookupImage(name string) (*Image, error)
- func (store *TagStore) Reload() error
- func (store *TagStore) Save() error
- func (store *TagStore) Set(repoName, tag, imageName string, force bool) error
- type TruncIndex
Constants ¶
const ( ChangeModify = iota ChangeAdd ChangeDelete )
const DEFAULT_TAG = "latest"
const LxcTemplate = `` /* 2658-byte string literal not displayed */
const REGISTRY_ENDPOINT = auth.REGISTRY_SERVER + "/v1"
FIXME: Set the endpoint in a conf file or via commandline const REGISTRY_ENDPOINT = "http://registry-creack.dotcloud.com/v1"
const VERSION = "0.1.2"
Variables ¶
var GIT_COMMIT string
var LxcTemplateCompiled *template.Template
Functions ¶
func CmdStream ¶
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 Debugf ¶
func Debugf(format string, a ...interface{})
Debug function, if the debug flag is set, then display. Do nothing otherwise If Docker is in damon mode, also send the debug info on the socket
func GenerateId ¶
func GenerateId() string
func Go ¶
Go is a basic promise implementation: it wraps calls a function in a goroutine, and returns a channel which will later return the function's return value.
func HumanDuration ¶
HumanDuration returns a human-readable approximation of a duration (eg. "About a minute", "4 hours ago", etc.)
func NopWriteCloser ¶
func NopWriteCloser(w io.Writer) io.WriteCloser
func ProgressReader ¶
func ProgressReader(r io.ReadCloser, size int, output io.Writer) *progressReader
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 TruncateId ¶ added in v0.1.2
TruncateId returns a shorthand version of a string identifier for convenience. A collision with other shorthands is very unlikely, but possible. In case of a collision a lookup with TruncIndex.Get() will fail, and the caller will need to use a langer prefix, or the full-length Id.
func ValidateId ¶
Types ¶
type AttachOpts ¶ added in v0.1.2
AttachOpts stores arguments to 'docker run -a', eg. which streams to attach to
func NewAttachOpts ¶ added in v0.1.2
func NewAttachOpts() *AttachOpts
func (*AttachOpts) Get ¶ added in v0.1.2
func (opts *AttachOpts) Get(val string) bool
func (*AttachOpts) Set ¶ added in v0.1.2
func (opts *AttachOpts) Set(val string) error
func (*AttachOpts) String ¶ added in v0.1.2
func (opts *AttachOpts) String() string
type Change ¶
type Change struct { Path string Kind ChangeType }
type ChangeType ¶
type ChangeType int
type Compression ¶
type Compression uint32
const ( Uncompressed Compression = iota Bzip2 Gzip Xz )
func (*Compression) Flag ¶
func (compression *Compression) Flag() string
type Config ¶
type Config struct { Hostname string User string Memory int64 // Memory limit (in bytes) MemorySwap int64 // Total memory usage (memory + swap); set `-1' to disable swap AttachStdin bool AttachStdout bool AttachStderr bool Ports []int 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 Image string // Name of the image as it was passed by the operator (eg. could be symbolic) }
type Container ¶
type Container struct { Id string Created time.Time Path string Args []string Config *Config State State Image string NetworkSettings *NetworkSettings SysInitPath string // contains filtered or unexported fields }
func (*Container) EnsureMounted ¶
func (*Container) RootfsPath ¶
This method must be exported to be used from the lxc template
func (*Container) ShortId ¶ added in v0.1.1
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) 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) WaitTimeout ¶
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 ¶
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 ¶
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) Exists ¶
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) Garbage ¶
Garbage returns the "garbage", a staging area for deleted images. This allows images to be deleted atomically by os.Rename(), instead of os.RemoveAll() which is prone to race conditions.
func (*Graph) GarbageCollect ¶
GarbageCollect definitely deletes all images moved to the garbage.
func (*Graph) Get ¶
Get returns the image with the given id, or an error if the image doesn't exist.
func (*Graph) Heads ¶
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 ¶ added in v0.1.1
FIXME: Implement error subclass instead of looking at the error text Note: This is the way golang implements os.IsNotExists on Plan9
func (*Graph) LookupRemoteImage ¶
func (graph *Graph) LookupRemoteImage(imgId string, authConfig *auth.AuthConfig) bool
Check if an image exists in the Registry
func (*Graph) LookupRemoteRepository ¶
func (graph *Graph) LookupRemoteRepository(remote string, authConfig *auth.AuthConfig) bool
func (*Graph) PullRepository ¶
func (graph *Graph) PullRepository(stdout io.Writer, remote, askedTag string, repositories *TagStore, authConfig *auth.AuthConfig) error
FIXME: Handle the askedTag parameter
func (*Graph) PushRepository ¶
func (graph *Graph) PushRepository(stdout io.Writer, remote string, localRepo Repository, authConfig *auth.AuthConfig) error
Push a repository to the registry. Remote has the format '<user>/<repo>
func (*Graph) Register ¶
Register imports a pre-existing image into the graph. FIXME: pass img as first argument
type IPAllocator ¶
type IPAllocator struct {
// contains filtered or unexported fields
}
IP allocator: Atomatically allocate and release networking ports
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"` // contains filtered or unexported fields }
func NewImgJson ¶
Build an Image object from raw json data
func NewMultipleImgJson ¶
Build an Image object list from a raw json data FIXME: Do this in "stream" mode
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 int) (int, 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 PortAllocator ¶
type PortAllocator struct {
// contains filtered or unexported fields
}
Port allocator: Atomatically allocate and release networking ports
func (*PortAllocator) Acquire ¶
func (alloc *PortAllocator) Acquire() (int, error)
func (*PortAllocator) Release ¶
func (alloc *PortAllocator) Release(port int) error
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) Unmap ¶
func (mapper *PortMapper) Unmap(port int) error
type Repository ¶
type Runtime ¶
type Runtime struct {
// contains filtered or unexported fields
}
func NewRuntimeFromDirectory ¶
func (*Runtime) Commit ¶
Commit creates a new filesystem image from the current state of a container. The image can optionally be tagged into a repository
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) CmdHistory ¶
func (*Server) CmdInspect ¶
func (*Server) CmdRestart ¶
func (*Server) CmdVersion ¶
'docker version': show version information
type State ¶
type TagStore ¶
type TagStore struct { Repositories map[string]Repository // contains filtered or unexported fields }
type TruncIndex ¶ added in v0.1.1
type TruncIndex struct {
// contains filtered or unexported fields
}
TruncIndex allows the retrieval of string identifiers by any of their unique prefixes. This is used to retrieve image and container IDs by more convenient shorthand prefixes.
func NewTruncIndex ¶ added in v0.1.1
func NewTruncIndex() *TruncIndex
func (*TruncIndex) Add ¶ added in v0.1.1
func (idx *TruncIndex) Add(id string) error
func (*TruncIndex) Delete ¶ added in v0.1.1
func (idx *TruncIndex) Delete(id string) error