daemon

package
v0.0.0-...-2d83eec Latest Latest
Warning

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

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

README

This directory contains code pertaining to running containers and storing images

Code pertaining to running containers:

  • execdriver
  • networkdriver

Code pertaining to storing images:

  • graphdriver

Documentation

Index

Constants

View Source 
const DefaultPathEnv = "/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin"
View Source 
const WatchStateEvent = "WatchState"

Variables

View Source 
var (
	MonitorSockDir  = "/var/run/docker"
	MonitorBuiltin  = "builtin"
	MonitorExternal = "external"
)
View Source 
var (
	ErrNotATTY               = errors.New("The PTY is not a file")
	ErrNoTTY                 = errors.New("No PTY found")
	ErrContainerStart        = errors.New("The container failed to start. Unknown error")
	ErrContainerStartTimeout = errors.New("The container failed to start due to timed out.")
)
View Source 
var (
	DefaultDns = []string{"8.8.8.8", "8.8.4.4"}
)

Functions

func CallURL 

func CallURL(method, URL, path string, data interface{}) ([]byte, int, error)

func GetDefaultNetworkMtu 

func GetDefaultNetworkMtu() int

func GetFullContainerName 

func GetFullContainerName(name string) (string, error)

Types

type Config 

type Config struct {
	Pidfile                     string
	Root                        string
	AutoRestart                 bool
	Dns                         []string
	DnsSearch                   []string
	Mirrors                     []string
	EnableIptables              bool
	EnableIpForward             bool
	EnableIpMasq                bool
	DefaultIp                   net.IP
	BridgeIface                 string
	BridgeIP                    string
	FixedCIDR                   string
	InsecureRegistries          []string
	InterContainerCommunication bool
	GraphDriver                 string
	GraphOptions                []string
	ExecDriver                  string
	Mtu                         int
	DisableNetwork              bool
	EnableSelinuxSupport        bool
	Context                     map[string][]string
}

Config define the configuration of a docker daemon These are the configuration settings that you pass to the docker daemon when you launch it with say: `docker -d -e lxc` FIXME: separate runtime configuration from http api configuration

func (*Config) InstallFlags 

func (config *Config) InstallFlags()

InstallFlags adds command-line options to the top-level flag parser for the current process. Subsequent calls to `flag.Parse` will populate config with values parsed from the command-line.

type Container 

type Container struct {
	*State `json:"State"` // Needed for remote api version <= 1.11

	ID string

	Created time.Time

	Path string
	Args []string

	Config *runconfig.Config
	Image  string

	NetworkSettings *NetworkSettings

	ResolvConfPath string
	HostnamePath   string
	HostsPath      string
	Name           string
	Driver         string
	ExecDriver     string

	StreamConfig

	MountLabel, ProcessLabel string
	AppArmorProfile          string
	RestartCount             int

	// Maps container paths to volume paths.  The key in this is the path to which
	// the volume is being mounted inside the container.  Value is the path of the
	// volume on disk
	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

	//MonitorDriver builtin or external
	MonitorDriver string
	// contains filtered or unexported fields
}

func (*Container) AllocateNetwork 

func (container *Container) AllocateNetwork() error

func (*Container) Changes 

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

func (*Container) Copy 

func (container *Container) Copy(resource string) (io.ReadCloser, error)
func (container *Container) DisableLink(name string)

func (*Container) Exec 

func (container *Container) Exec(execConfig *execConfig) error

func (*Container) Export 

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

func (*Container) ExportRw 

func (container *Container) ExportRw(options *archive.ChangeOptions) (archive.Archive, error)

func (*Container) Exposes 

func (container *Container) Exposes(p nat.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.Image, error)

func (*Container) GetMountLabel 

func (container *Container) GetMountLabel() string

func (*Container) GetProcessLabel 

func (container *Container) GetProcessLabel() string

func (*Container) GetPtyMaster 

func (container *Container) GetPtyMaster() (*os.File, error)

func (*Container) GetSize 

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

GetSize, return real size, virtual size

func (*Container) HostConfig 

func (container *Container) HostConfig() *runconfig.HostConfig

func (*Container) Kill 

func (container *Container) Kill() error

func (*Container) KillSig 

func (container *Container) KillSig(sig int) error

func (*Container) LogEvent 

func (container *Container) LogEvent(action string)

func (*Container) Mount 

func (container *Container) Mount() error

func (*Container) Output 

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

func (*Container) Pause 

func (container *Container) Pause() error

func (*Container) ReadCommandConfig 

func (container *Container) ReadCommandConfig() error

func (*Container) ReadLog 

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

func (*Container) ReadMonitorState 

func (container *Container) ReadMonitorState() error

func (*Container) ReleaseNetwork 

func (container *Container) ReleaseNetwork()

func (*Container) Resize 

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

func (*Container) Restart 

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

func (*Container) RestoreNetwork 

func (container *Container) RestoreNetwork() error

func (*Container) RootfsPath 

func (container *Container) RootfsPath() string

This method must be exported to be used from the lxc template This directory is only usable when the container is running

func (*Container) Run 

func (container *Container) Run() error

func (*Container) SetHostConfig 

func (container *Container) SetHostConfig(hostConfig *runconfig.HostConfig)

func (*Container) Start 

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

func (*Container) Stop 

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

func (*Container) ToDisk 

func (container *Container) ToDisk() error

func (*Container) Unmount 

func (container *Container) Unmount() error

func (*Container) Unpause 

func (container *Container) Unpause() error

func (*Container) VolumeMounts 

func (container *Container) VolumeMounts() map[string]*Mount

func (*Container) VolumePaths 

func (container *Container) VolumePaths() map[string]struct{}

func (*Container) WriteCommandConfig 

func (container *Container) WriteCommandConfig() error

func (*Container) WriteHostConfig 

func (container *Container) WriteHostConfig() error

func (*Container) WriteMonitorState 

func (container *Container) WriteMonitorState() error

type Daemon 

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

func NewDaemon 

func NewDaemon(config *Config, eng *engine.Engine) (*Daemon, error)

FIXME: harmonize with NewGraph()

func NewDaemonFromDirectory 

func NewDaemonFromDirectory(config *Config, eng *engine.Engine) (*Daemon, error)

func (*Daemon) Attach 

func (daemon *Daemon) Attach(streamConfig *StreamConfig, openStdin, stdinOnce, tty bool, stdin io.ReadCloser, stdinCloser io.Closer, stdout io.Writer, stderr io.Writer) chan error

FIXME: this should be private, and every outside subsystem should go through the "container_attach" job. But that would require that job to be properly documented, as well as the relationship between Attach and ContainerAttach.

This method is in use by builder/builder.go.

func (*Daemon) Changes 

func (daemon *Daemon) Changes(container *Container) ([]archive.Change, error)

func (*Daemon) Children 

func (daemon *Daemon) Children(name string) (map[string]*Container, error)

func (*Daemon) CmdInfo 

func (daemon *Daemon) CmdInfo(job *engine.Job) engine.Status

func (*Daemon) Commit 

func (daemon *Daemon) Commit(container *Container, repository, tag, comment, author string, pause bool, options *archive.ChangeOptions, config *runconfig.Config) (*image.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 (*Daemon) Config 

func (daemon *Daemon) Config() *Config

func (*Daemon) ContainerAttach 

func (daemon *Daemon) ContainerAttach(job *engine.Job) engine.Status

func (*Daemon) ContainerCgroup 

func (daemon *Daemon) ContainerCgroup(job *engine.Job) engine.Status

func (*Daemon) ContainerChanges 

func (daemon *Daemon) ContainerChanges(job *engine.Job) engine.Status

func (*Daemon) ContainerCommit 

func (daemon *Daemon) ContainerCommit(job *engine.Job) engine.Status

func (*Daemon) ContainerCopy 

func (daemon *Daemon) ContainerCopy(job *engine.Job) engine.Status

func (*Daemon) ContainerCreate 

func (daemon *Daemon) ContainerCreate(job *engine.Job) engine.Status

func (*Daemon) ContainerExecCreate 

func (d *Daemon) ContainerExecCreate(job *engine.Job) engine.Status

func (*Daemon) ContainerExecResize 

func (daemon *Daemon) ContainerExecResize(job *engine.Job) engine.Status

func (*Daemon) ContainerExecStart 

func (d *Daemon) ContainerExecStart(job *engine.Job) engine.Status

func (*Daemon) ContainerExport 

func (daemon *Daemon) ContainerExport(job *engine.Job) engine.Status

func (*Daemon) ContainerGraph 

func (daemon *Daemon) ContainerGraph() *graphdb.Database

func (*Daemon) ContainerInspect 

func (daemon *Daemon) ContainerInspect(job *engine.Job) engine.Status

func (*Daemon) ContainerKill 

func (daemon *Daemon) ContainerKill(job *engine.Job) engine.Status

ContainerKill send signal to the container If no signal is given (sig 0), then Kill with SIGKILL and wait for the container to exit. If a signal is given, then just send it to the container and return.

func (*Daemon) ContainerLogs 

func (daemon *Daemon) ContainerLogs(job *engine.Job) engine.Status

func (*Daemon) ContainerMonitorOp 

func (daemon *Daemon) ContainerMonitorOp(job *engine.Job) engine.Status

ContainerMonitorOp only called at attach mode by docker client to stop monitor server

func (*Daemon) ContainerPause 

func (daemon *Daemon) ContainerPause(job *engine.Job) engine.Status

func (*Daemon) ContainerResize 

func (daemon *Daemon) ContainerResize(job *engine.Job) engine.Status

func (*Daemon) ContainerRestart 

func (daemon *Daemon) ContainerRestart(job *engine.Job) engine.Status

func (*Daemon) ContainerRm 

func (daemon *Daemon) ContainerRm(job *engine.Job) engine.Status

func (*Daemon) ContainerSet 

func (daemon *Daemon) ContainerSet(job *engine.Job) engine.Status

func (*Daemon) ContainerStart 

func (daemon *Daemon) ContainerStart(job *engine.Job) engine.Status

func (*Daemon) ContainerStop 

func (daemon *Daemon) ContainerStop(job *engine.Job) engine.Status

func (*Daemon) ContainerTop 

func (daemon *Daemon) ContainerTop(job *engine.Job) engine.Status

func (*Daemon) ContainerUnpause 

func (daemon *Daemon) ContainerUnpause(job *engine.Job) engine.Status

func (*Daemon) ContainerWait 

func (daemon *Daemon) ContainerWait(job *engine.Job) engine.Status

func (*Daemon) Containers 

func (daemon *Daemon) Containers(job *engine.Job) engine.Status

func (*Daemon) Create 

func (daemon *Daemon) Create(config *runconfig.Config, hostConfig *runconfig.HostConfig, name string) (*Container, []string, error)

Create creates a new container from the given configuration with a given name.

func (*Daemon) DeleteImage 

func (daemon *Daemon) DeleteImage(eng *engine.Engine, name string, imgs *engine.Table, first, force, noprune bool) error

FIXME: make this private and use the job instead

func (*Daemon) DeleteVolumes 

func (daemon *Daemon) DeleteVolumes(volumeIDs map[string]struct{})

func (*Daemon) Destroy 

func (daemon *Daemon) Destroy(container *Container) error

Destroy unregisters a container from the daemon and cleanly removes its contents from the filesystem. FIXME: rename to Rm for consistency with the CLI command

func (*Daemon) Diff 

func (daemon *Daemon) Diff(container *Container) (archive.Archive, error)

func (*Daemon) Exec 

func (d *Daemon) Exec(c *Container, execConfig *execConfig, pipes *execdriver.Pipes, startCallback execdriver.StartCallback) (int, error)

func (*Daemon) ExecutionDriver 

func (daemon *Daemon) ExecutionDriver() execdriver.Driver

func (*Daemon) Exists 

func (daemon *Daemon) Exists(id string) bool

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

func (*Daemon) Get 

func (daemon *Daemon) 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 (*Daemon) GetByName 

func (daemon *Daemon) GetByName(name string) (*Container, error)

func (*Daemon) Graph 

func (daemon *Daemon) Graph() *graph.Graph

FIXME: this is a convenience function for integration tests which need direct access to daemon.graph. Once the tests switch to using engine and jobs, this method can go away.

func (*Daemon) GraphDriver 

func (daemon *Daemon) GraphDriver() graphdriver.Driver

func (*Daemon) ImageDelete 

func (daemon *Daemon) ImageDelete(job *engine.Job) engine.Status

func (*Daemon) ImageGetCached 

func (daemon *Daemon) ImageGetCached(imgID string, config *runconfig.Config) (*image.Image, error)

func (*Daemon) Install 

func (daemon *Daemon) Install(eng *engine.Engine) error

Install installs daemon capabilities to eng.

func (*Daemon) Kill 

func (daemon *Daemon) Kill(c *Container, sig int) error

func (*Daemon) List 

func (daemon *Daemon) List() []*Container

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

func (*Daemon) LogToDisk 

func (daemon *Daemon) LogToDisk(src *broadcastwriter.BroadcastWriter, dst, stream string) error

func (*Daemon) Mount 

func (daemon *Daemon) Mount(container *Container) error

func (*Daemon) Nuke 

func (daemon *Daemon) Nuke() error

Nuke kills all containers then removes all content from the content root, including images, volumes and container filesystems. Again: this will remove your entire docker daemon! FIXME: this is deprecated, and only used in legacy tests. Please remove.

func (*Daemon) Parents 

func (daemon *Daemon) Parents(name string) ([]string, error)

func (*Daemon) Pause 

func (daemon *Daemon) Pause(c *Container) error

func (*Daemon) Register 

func (daemon *Daemon) Register(container *Container) error

Register makes a container object usable by the daemon as <container.ID> This is a wrapper for register 

func (daemon *Daemon) RegisterLink(parent, child *Container, alias string) error
func (daemon *Daemon) RegisterLinks(container *Container, hostConfig *runconfig.HostConfig) error

func (*Daemon) Repositories 

func (daemon *Daemon) Repositories() *graph.TagStore

func (*Daemon) Run 

func (daemon *Daemon) Run(c *Container, pipes *execdriver.Pipes, startCallback execdriver.StartCallback) (int, error)

func (*Daemon) SystemConfig 

func (daemon *Daemon) SystemConfig() *sysinfo.SysInfo

func (*Daemon) SystemInitPath 

func (daemon *Daemon) SystemInitPath() string

func (*Daemon) Unmount 

func (daemon *Daemon) Unmount(container *Container) error

func (*Daemon) Unpause 

func (daemon *Daemon) Unpause(c *Container) error

type DockerMonitor 

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

func InitDockerMonitor 

func InitDockerMonitor(cfg *MonitorConfig, w *StateWatcher) *DockerMonitor

func (*DockerMonitor) Container 

func (dm *DockerMonitor) Container() *Container

func (*DockerMonitor) ContainerState 

func (dm *DockerMonitor) ContainerState() *WatchState

func (*DockerMonitor) KillSig 

func (dm *DockerMonitor) KillSig(sig int) error

func (*DockerMonitor) RestartWatching 

func (dm *DockerMonitor) RestartWatching()

func (*DockerMonitor) Start 

func (dm *DockerMonitor) Start() error

func (*DockerMonitor) Stop 

func (dm *DockerMonitor) Stop() (error, int)

func (*DockerMonitor) WaitStop 

func (dm *DockerMonitor) WaitStop() error

type HTTPClient 

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
	Close() error
}

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

func (history *History) Sort()

func (*History) Swap 

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

type MonitorConfig 

type MonitorConfig struct {
	Pidfile     string
	Root        string
	SocketGroup string
	ID          string
}

type MonitorProxy 

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

MonitorProxy monitor proxy

func NewMonitorProxy 

func NewMonitorProxy(c *Container, createCmd bool) *MonitorProxy

NewMonitorProxy return proxy for extern monitor

func (*MonitorProxy) RunStatePoller 

func (m *MonitorProxy) RunStatePoller() error

func (*MonitorProxy) Start 

func (m *MonitorProxy) Start() error

func (*MonitorProxy) Stop 

func (m *MonitorProxy) Stop() error

Stop closes the container's resources such as networking allocations and unmounts the contatiner's root filesystem

func (*MonitorProxy) StopStatePoller 

func (m *MonitorProxy) StopStatePoller()

type MonitorState 

type MonitorState struct {
	sync.Mutex
	Running    bool
	Pid        int
	ExitCode   int
	StartedAt  time.Time
	FinishedAt time.Time
}

func NewMonitorState 

func NewMonitorState() *MonitorState

func (*MonitorState) IsRunning 

func (ms *MonitorState) IsRunning() bool

func (*MonitorState) SetRunning 

func (ms *MonitorState) SetRunning(pid int)

func (*MonitorState) SetStopped 

func (ms *MonitorState) SetStopped(exitCode int)

type Mount 

type Mount struct {
	MountToPath string

	Writable bool
	// contains filtered or unexported fields
}

type NetworkSettings 

type NetworkSettings struct {
	IPAddress   string
	IPPrefixLen int
	MacAddress  string
	Gateway     string
	Bridge      string
	PortMapping map[string]PortMapping // Deprecated
	Ports       nat.PortMap
}

func (*NetworkSettings) PortMappingAPI 

func (settings *NetworkSettings) PortMappingAPI() *engine.Table

type PortMapping 

type PortMapping map[string]string // Deprecated

FIXME: move deprecated port stuff to nat to clean up the core.

type State 

type State struct {
	sync.Mutex
	Running    bool
	Paused     bool
	Restarting bool
	Pid        int
	ExitCode   int
	StartedAt  time.Time
	FinishedAt time.Time
	// contains filtered or unexported fields
}

func NewState 

func NewState() *State

func (*State) GetExitCode 

func (s *State) GetExitCode() int

func (*State) GetPid 

func (s *State) GetPid() int

func (*State) IsPaused 

func (s *State) IsPaused() bool

func (*State) IsRestarting 

func (s *State) IsRestarting() bool

func (*State) IsRunning 

func (s *State) IsRunning() bool

func (*State) SetPaused 

func (s *State) SetPaused()

func (*State) SetRestarting 

func (s *State) SetRestarting(exitCode int)

SetRestarting is when docker hanldes the auto restart of containers when they are in the middle of a stop and being restarted again

func (*State) SetRunning 

func (s *State) SetRunning(pid int)

func (*State) SetStopped 

func (s *State) SetStopped(exitCode int)

func (*State) SetUnpaused 

func (s *State) SetUnpaused()

func (*State) StateString 

func (s *State) StateString() string

StateString returns a single string to describe state

func (*State) String 

func (s *State) String() string

String returns a human-readable description of the state

func (*State) ToWatchState 

func (s *State) ToWatchState() *WatchState

func (*State) WaitRunning 

func (s *State) WaitRunning(timeout time.Duration) (int, error)

WaitRunning waits until state is running. If state already running it returns immediately. If you want wait forever you must supply negative timeout. Returns pid, that was passed to SetRunning

func (*State) WaitStop 

func (s *State) WaitStop(timeout time.Duration) (int, error)

WaitStop waits until state is stopped. If state already stopped it returns immediately. If you want wait forever you must supply negative timeout. Returns exit code, that was passed to SetStopped

type StatePoller 

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

func (*StatePoller) Run 

func (p *StatePoller) Run() error

Run begins polling. It starts a goroutine and returns immediately.

func (*StatePoller) Stop 

func (p *StatePoller) Stop()

func (*StatePoller) Watch 

func (p *StatePoller) Watch() (watch.Interface, error)

Watch should begin a watch at the specified version.

type StateWatcher 

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

func NewStateWatcher 

func NewStateWatcher() *StateWatcher

func (*StateWatcher) Emit 

func (sw *StateWatcher) Emit(obj watch.Object)

Emit sends a watch event.

func (*StateWatcher) ResultChan 

func (sw *StateWatcher) ResultChan() <-chan watch.Event

func (*StateWatcher) Start 

func (sw *StateWatcher) Start()

func (*StateWatcher) Stop 

func (sw *StateWatcher) Stop()

type StreamConfig 

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

func (*StreamConfig) StderrLogPipe 

func (streamConfig *StreamConfig) StderrLogPipe() io.ReadCloser

func (*StreamConfig) StderrPipe 

func (streamConfig *StreamConfig) StderrPipe() (io.ReadCloser, error)

func (*StreamConfig) StdinPipe 

func (streamConfig *StreamConfig) StdinPipe() (io.WriteCloser, error)

func (*StreamConfig) StdoutLogPipe 

func (streamConfig *StreamConfig) StdoutLogPipe() io.ReadCloser

func (*StreamConfig) StdoutPipe 

func (streamConfig *StreamConfig) StdoutPipe() (io.ReadCloser, error)

type WatchState 

type WatchState struct {
	Running    bool
	Paused     bool
	Restarting bool
	Pid        int
	ExitCode   int
	StartedAt  time.Time
	FinishedAt time.Time
}

Source Files

View all Source files

Directories

Path Synopsis
execdrivers
lxc
native
native/template
aufs
btrfs
devmapper
graphtest
vfs
bridge
ipallocator
portallocator
portmapper

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.