Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

daemon

package

Go to main page

Versions in this module

v0

v0.5.0

Feb 5, 2016

Changes in this version

+ const DEFAULT_DM_DATA_LOOP

+ const DEFAULT_DM_META_LOOP

+ const DEFAULT_DM_POOL

+ const DEFAULT_DM_POOL_SIZE

+ const DEFAULT_DM_VOL_SIZE

+ const DEFAULT_VOL_FS

+ var DefaultResourcePath string = "/var/run/hyper/Pods"

+ var NewDockerImpl = func() (DockerInterface, error)

+ var StorageDrivers map[string]func(*dockertypes.Info) (Storage, error) = map[string]func(*dockertypes.Info) (Storage, error)

+ func ProbeExistingVolume(v *pod.UserVolume, sharedDir string) (*hypervisor.VolumeInfo, error)

+ func ProcessPodBytes(body []byte, podId string) (*pod.UserPod, error)

+ func ServiceDiscoveryContainerName(podName string) string

+ type AufsStorage struct

+ func (*AufsStorage) CleanUp() error

+ func (*AufsStorage) Init() error

+ func (a *AufsStorage) CreateVolume(daemon *Daemon, podId, shortName string) (*hypervisor.VolumeInfo, error)

+ func (a *AufsStorage) InjectFile(src io.Reader, containerId, target, rootDir string, perm, uid, gid int) error

+ func (a *AufsStorage) PrepareContainer(id, sharedDir string) (*hypervisor.ContainerInfo, error)

+ func (a *AufsStorage) RemoveVolume(podId string, record []byte) error

+ func (a *AufsStorage) RootPath() string

+ func (a *AufsStorage) Type() string

type Daemon

+ Bios string

+ Cbfs string

+ DefaultLog *pod.PodLogConfig

+ DockerCli DockerInterface

+ Hypervisor string

+ Initrd string

+ Kernel string

+ PodList *PodList

+ VboxImage string

+ VmList map[string]*hypervisor.Vm

+ func (daemon *Daemon) AddService(job *engine.Job) error

+ func (daemon *Daemon) CleanPod(podId string) (int, string, error)

+ func (daemon *Daemon) CmdAuth(job *engine.Job) error

+ func (daemon *Daemon) CmdBuild(job *engine.Job) error

+ func (daemon *Daemon) CmdCommit(job *engine.Job) error

+ func (daemon *Daemon) CmdContainerInfo(job *engine.Job) error

+ func (daemon *Daemon) CmdExitCode(job *engine.Job) (err error)

+ func (daemon *Daemon) CmdImages(job *engine.Job) error

+ func (daemon *Daemon) CmdImagesRemove(job *engine.Job) error

+ func (daemon *Daemon) CmdLogs(job *engine.Job) (err error)

+ func (daemon *Daemon) CmdPause(job *engine.Job) error

+ func (daemon *Daemon) CmdPodLabels(job *engine.Job) error

+ func (daemon *Daemon) CmdPodStats(job *engine.Job) error

+ func (daemon *Daemon) CmdPush(job *engine.Job) error

+ func (daemon *Daemon) CmdRename(job *engine.Job) error

+ func (daemon *Daemon) CmdUnpause(job *engine.Job) error

+ func (daemon *Daemon) DbGetVmByPod(podId string) (string, error)

+ func (daemon *Daemon) DefaultLogCfg(driver string, cfg map[string]string)

+ func (daemon *Daemon) DeleteService(job *engine.Job) error

+ func (daemon *Daemon) GetExitCode(podId, tag string, callback chan *types.VmResponse) error

+ func (daemon *Daemon) GetPod(podId, podArgs string, autoremove bool) (*Pod, error)

+ func (daemon *Daemon) GetPodByContainerIdOrName(name string) (pod *Pod, idx int, err error)

+ func (daemon *Daemon) GetServiceContainerInfo(podId string) (*hypervisor.Vm, string, error)

+ func (daemon *Daemon) GetServices(job *engine.Job) error

+ func (daemon *Daemon) GetVM(vmId string, resource *pod.UserResource, lazy bool, keep int) (*hypervisor.Vm, error)

+ func (daemon *Daemon) GetVmByPodId(podId string) (string, error)

+ func (daemon *Daemon) InitVmCache(cache_policy string) error

+ func (daemon *Daemon) NewVm(id string, cpu, memory int, lazy bool, keep int) *hypervisor.Vm

+ func (daemon *Daemon) PodStopped(podId string)

+ func (daemon *Daemon) StartVm(vmId string, cpu, mem int, lazy, cache bool, keep int) (*hypervisor.Vm, error)

+ func (daemon *Daemon) UnpauseContainer(container string) error

+ func (daemon *Daemon) UnpausePod(podId string) error

+ func (daemon *Daemon) UpdateService(job *engine.Job) error

+ func (daemon *Daemon) WaitVmStart(vm *hypervisor.Vm) error

+ func (daemon Daemon) PauseContainer(container string) error

+ func (daemon Daemon) PausePod(podId string) error

+ type DevMapperStorage struct

+ CtnPoolName string

+ DevPrefix string

+ DmPoolData *dm.DeviceMapper

+ FsType string

+ VolPoolName string

+ func (dms *DevMapperStorage) CleanUp() error

+ func (dms *DevMapperStorage) CreateVolume(daemon *Daemon, podId, shortName string) (*hypervisor.VolumeInfo, error)

+ func (dms *DevMapperStorage) Init() error

+ func (dms *DevMapperStorage) InjectFile(src io.Reader, containerId, target, rootDir string, perm, uid, gid int) error

+ func (dms *DevMapperStorage) PrepareContainer(id, sharedDir string) (*hypervisor.ContainerInfo, error)

+ func (dms *DevMapperStorage) RemoveVolume(podId string, record []byte) error

+ func (dms *DevMapperStorage) RootPath() string

+ func (dms *DevMapperStorage) Type() string

+ type DockerInterface interface

+ GetContainerInfo func(args ...string) (*dockertypes.ContainerJSON, error)

+ SendCmdAuth func(body io.ReadCloser) (string, error)

+ SendCmdCreate func(name, image string, entripoint, cmds []string, config interface{}) ([]byte, int, error)

+ SendCmdDelete func(arg ...string) ([]byte, int, error)

+ SendCmdImages func(all string) ([]*dockertypes.Image, error)

+ SendCmdInfo func(args ...string) (*dockertypes.Info, error)

+ SendCmdPull func(image string, config *graph.ImagePullConfig) ([]byte, int, error)

+ SendCmdPush func(remote string, ipconfig *graph.ImagePushConfig) error

+ SendContainerCommit func(args ...string) ([]byte, int, error)

+ SendContainerRename func(oName, nName string) error

+ SendImageBuild func(image string, size int, context io.ReadCloser) ([]byte, int, error)

+ SendImageDelete func(args ...string) ([]dockertypes.ImageDelete, error)

+ Setup func() error

+ Shutdown func() error

+ func NewDocker() (DockerInterface, error)

+ type OverlayFsStorage struct

+ func (*OverlayFsStorage) CleanUp() error

+ func (*OverlayFsStorage) Init() error

+ func (o *OverlayFsStorage) CreateVolume(daemon *Daemon, podId, shortName string) (*hypervisor.VolumeInfo, error)

+ func (o *OverlayFsStorage) InjectFile(src io.Reader, containerId, target, rootDir string, perm, uid, gid int) error

+ func (o *OverlayFsStorage) PrepareContainer(id, sharedDir string) (*hypervisor.ContainerInfo, error)

+ func (o *OverlayFsStorage) RemoveVolume(podId string, record []byte) error

+ func (o *OverlayFsStorage) RootPath() string

+ func (o *OverlayFsStorage) Type() string

type Pod

+ func CreatePod(daemon *Daemon, dclient DockerInterface, podId, podArgs string, ...) (*Pod, error)

+ func (p *Pod) AssociateVm(daemon *Daemon, vmId string) error

+ func (p *Pod) AttachTtys(streams []*hypervisor.TtyIO) (err error)

+ func (p *Pod) GetVM(daemon *Daemon, id string, lazy bool, keep int) (err error)

+ func (p *Pod) InitContainers(daemon *Daemon, dclient DockerInterface) (err error)

+ func (p *Pod) KillVM(daemon *Daemon)

+ func (p *Pod) Prepare(daemon *Daemon) (err error)

+ func (p *Pod) PrepareContainers(sd Storage, dclient DockerInterface) (err error)

+ func (p *Pod) PrepareDNS() (err error)

+ func (p *Pod) PrepareEtcHosts() (err error)

+ func (p *Pod) PrepareServices() error

+ func (p *Pod) PrepareVolume(daemon *Daemon, sd Storage) (err error)

+ func (p *Pod) SetVM(id string, vm *hypervisor.Vm)

+ func (p *Pod) Start(daemon *Daemon, vmId string, lazy, autoremove bool, keep int, ...) (*types.VmResponse, error)

+ type PodFilterOp func(*Pod) bool

+ type PodList struct

+ func NewPodList() *PodList

+ func (pl *PodList) CountContainers() (num int64)

+ func (pl *PodList) CountRunning() int64

+ func (pl *PodList) CountStatus(status uint) (num int64)

+ func (pl *PodList) Delete(id string)

+ func (pl *PodList) Find(fn PodFilterOp) *Pod

+ func (pl *PodList) Foreach(fn PodOp) error

+ func (pl *PodList) Get(id string) (*Pod, bool)

+ func (pl *PodList) GetByName(name string) *Pod

+ func (pl *PodList) GetStatus(id string) (*hypervisor.PodStatus, bool)

+ func (pl *PodList) Put(p *Pod)

+ type PodOp func(*Pod) error

+ type Record struct

+ Hosts string

+ IP string

+ func (r Record) WriteTo(w io.Writer) (int64, error)

type Storage

+ func AufsFactory(sysinfo *dockertypes.Info) (Storage, error)

+ func DMFactory(sysinfo *dockertypes.Info) (Storage, error)

+ func OverlayFsFactory(_ *dockertypes.Info) (Storage, error)

+ func StorageFactory(sysinfo *dockertypes.Info) (Storage, error)

+ func VBoxStorageFactory(_ *dockertypes.Info) (Storage, error)

+ CleanUp func() error

+ CreateVolume func(daemon *Daemon, podId, shortName string) (*hypervisor.VolumeInfo, error)

+ Init func() error

+ InjectFile func(src io.Reader, containerId, target, rootDir string, perm, uid, gid int) error

+ PrepareContainer func(id, sharedir string) (*hypervisor.ContainerInfo, error)

+ RemoveVolume func(podId string, record []byte) error

+ Type func() string

+ type VBoxStorage struct

+ func (*VBoxStorage) CleanUp() error

+ func (*VBoxStorage) Init() error

+ func (v *VBoxStorage) CreateVolume(daemon *Daemon, podId, shortName string) (*hypervisor.VolumeInfo, error)

+ func (v *VBoxStorage) InjectFile(src io.Reader, containerId, target, rootDir string, perm, uid, gid int) error

+ func (v *VBoxStorage) PrepareContainer(id, sharedDir string) (*hypervisor.ContainerInfo, error)

+ func (v *VBoxStorage) RemoveVolume(podId string, record []byte) error

+ func (v *VBoxStorage) RootPath() string

+ func (v *VBoxStorage) Type() string

+ type VmCache struct

v0.2.1

Jul 6, 2015

Changes in this version

+ func DriversProbe() hypervisor.HypervisorDriver

+ type Container struct

+ Cmds []string

+ Id string

+ Image string

+ Name string

+ PodId string

+ Status uint

+ type Daemon struct

+ BridgeIP string

+ BridgeIface string

+ Host string

+ ID string

+ Storage *Storage

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

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

+ func (daemon *Daemon) AddPod(pod *Pod)

+ func (daemon *Daemon) AddVm(vm *Vm)

+ func (daemon *Daemon) AssociateAllVms() error

+ func (daemon *Daemon) CleanVolume(stop int) error

+ func (daemon *Daemon) CmdAttach(job *engine.Job) (err error)

+ func (daemon *Daemon) CmdCreate(job *engine.Job) error

+ func (daemon *Daemon) CmdExec(job *engine.Job) (err error)

+ func (daemon *Daemon) CmdInfo(job *engine.Job) error

+ func (daemon *Daemon) CmdList(job *engine.Job) error

+ func (daemon *Daemon) CmdPodCreate(job *engine.Job) error

+ func (daemon *Daemon) CmdPodInfo(job *engine.Job) error

+ func (daemon *Daemon) CmdPodRm(job *engine.Job) (err error)

+ func (daemon *Daemon) CmdPodRun(job *engine.Job) error

+ func (daemon *Daemon) CmdPodStart(job *engine.Job) error

+ func (daemon *Daemon) CmdPodStop(job *engine.Job) error

+ func (daemon *Daemon) CmdPull(job *engine.Job) error

+ func (daemon *Daemon) CmdTty(job *engine.Job) (err error)

+ func (daemon *Daemon) CmdVersion(job *engine.Job) error

+ func (daemon *Daemon) CmdVmCreate(job *engine.Job) (err error)

+ func (daemon *Daemon) CmdVmKill(job *engine.Job) error

+ func (daemon *Daemon) CreatePod(podArgs, podId string, wg *sync.WaitGroup) error

+ func (daemon *Daemon) CreateVolume(podId, volName, dev_id string, restore bool) error

+ func (daemon *Daemon) DeletePodContainerFromDB(podName string) error

+ func (daemon *Daemon) DeletePodFromDB(podName string) error

+ func (daemon *Daemon) DeleteQemuChan(vmid string) error

+ func (daemon *Daemon) DeleteVmByPod(podId string) error

+ func (daemon *Daemon) DeleteVmData(vmId string) error

+ func (daemon *Daemon) DeleteVolumeId(podId string) error

+ func (daemon *Daemon) DestroyAllVm() error

+ func (daemon *Daemon) DestroyAndKeepVm() error

+ func (daemon *Daemon) GetMaxDeviceId() (int, error)

+ func (daemon *Daemon) GetPodByContainer(containerId string) (string, error)

+ func (daemon *Daemon) GetPodByName(podName string) ([]byte, error)

+ func (daemon *Daemon) GetPodContainersByName(podName string) ([]string, error)

+ func (daemon *Daemon) GetPodNum() int64

+ func (daemon *Daemon) GetPodVmByName(podName string) (string, error)

+ func (daemon *Daemon) GetQemuChan(vmid string) (interface{}, interface{}, interface{}, error)

+ func (daemon *Daemon) GetRunningPodNum() int64

+ func (daemon *Daemon) GetVmByPod(podId string) (string, error)

+ func (daemon *Daemon) GetVmData(vmId string) ([]byte, error)

+ func (daemon *Daemon) GetVolumeId(podId, volName string) (int, error)

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

+ func (daemon *Daemon) KillVm(vmId string) (int, string, error)

+ func (daemon *Daemon) ReleaseAllVms() (int, error)

+ func (daemon *Daemon) RemovePod(podId string)

+ func (daemon *Daemon) RemoveVm(vmId string)

+ func (daemon *Daemon) RestartPod(mypod *Pod) error

+ func (daemon *Daemon) Restore() error

+ func (daemon *Daemon) SetContainerStatus(podId string, status uint)

+ func (daemon *Daemon) SetPodByContainer(containerId, podId, name, image string, cmds []string, status uint) error

+ func (daemon *Daemon) SetPodContainerStatus(podId string, data []uint32)

+ func (daemon *Daemon) SetQemuChan(vmid string, qemuchan, qemuclient, subQemuClient interface{}) error

+ func (daemon *Daemon) SetVolumeId(podId, volName, dev_id string) error

+ func (daemon *Daemon) StartPod(podId, vmId, podArgs string) (int, string, error)

+ func (daemon *Daemon) StopPod(podId, stopVm string) (int, string, error)

+ func (daemon *Daemon) UpdateVmByPod(podId, vmId string) error

+ func (daemon *Daemon) UpdateVmData(vmId string, data []byte) error

+ func (daemon *Daemon) WritePodAndContainers(podName string) error

+ func (daemon *Daemon) WritePodToDB(podName string, podData []byte) error

+ type Pod struct

+ Containers []*Container

+ Id string

+ Name string

+ RestartPolicy string

+ Status uint

+ Type string

+ Vm string

+ Wg *sync.WaitGroup

+ type Storage struct

+ DmPoolData *dm.DeviceMapper

+ Fstype string

+ PoolName string

+ RootPath string

+ StorageType string

+ type Vm struct

+ Cpu int

+ Id string

+ Mem int

+ Pod *Pod

+ Status uint