daemon

package

Go to main page

Versions in this module

v1

v1.1.0

Sep 17, 2018

v1.1.0-rc1

Aug 16, 2018

v1.0.0

Nov 1, 2017

Changes in this version

type Daemon

+ func (daemon *Daemon) CmdAddPortMappings(podId string, req []byte) (*engine.Env, error)

+ func (daemon *Daemon) CmdDeletePortMappings(podId string, req []byte) (*engine.Env, error)

+ func (daemon *Daemon) CmdListPortMappings(podId string) (*engine.Env, error)

v0

v0.8.1

May 10, 2017

v0.8.0

Mar 21, 2017

Changes in this version

+ type BtrfsStorage struct

+ func (*BtrfsStorage) CleanUp() error

+ func (*BtrfsStorage) Init() error

+ func (s *BtrfsStorage) CleanupContainer(id, sharedDir string) error

+ func (s *BtrfsStorage) CreateVolume(podId string, spec *apitypes.UserVolume) error

+ func (s *BtrfsStorage) InjectFile(src io.Reader, mountId, target, baseDir string, perm, uid, gid int) error

+ func (s *BtrfsStorage) PrepareContainer(containerId, sharedDir string) (*runv.VolumeDescription, error)

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

+ func (s *BtrfsStorage) RootPath() string

+ func (s *BtrfsStorage) Type() string

type Daemon

+ func (daemon *Daemon) CmdRemoveContainer(name string) (*engine.Env, error)

+ func (daemon *Daemon) CmdStartContainer(containerId string) (*engine.Env, error)

+ func (daemon *Daemon) ExecVM(podID, cmd string, stdin io.ReadCloser, stdout, stderr io.WriteCloser) (int, error)

+ func (daemon *Daemon) ExportImage(names []string, format string, refs map[string]string, outStream io.Writer) error

+ func (daemon *Daemon) KillExec(containerId string, execId string, signal int64) error

+ func (daemon *Daemon) LoadImage(inTar io.ReadCloser, name string, refs map[string]string, outStream io.Writer) error

+ func (daemon *Daemon) RemoveContainer(nameOrId string) error

+ func (daemon *Daemon) StartContainer(containerId string) error

+ func (daemon *Daemon) WaitContainer(cid string, second int) (int, error)

+ type RawBlockStorage struct

+ func (*RawBlockStorage) CleanUp() error

+ func (s *RawBlockStorage) CleanupContainer(id, sharedDir string) error

+ func (s *RawBlockStorage) CreateVolume(podId string, spec *apitypes.UserVolume) error

+ func (s *RawBlockStorage) Init() error

+ func (s *RawBlockStorage) InjectFile(src io.Reader, mountId, target, baseDir string, perm, uid, gid int) error

+ func (s *RawBlockStorage) PrepareContainer(containerId, sharedDir string) (*runv.VolumeDescription, error)

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

+ func (s *RawBlockStorage) RootPath() string

+ func (s *RawBlockStorage) Type() string

type Storage

+ func BtrfsFactory(_ *dockertypes.Info, _ *daemondb.DaemonDB) (Storage, error)

+ func RawBlockFactory(_ *dockertypes.Info, _ *daemondb.DaemonDB) (Storage, error)

v0.7.0

Oct 28, 2016

v0.6.2

Aug 29, 2016

Changes in this version

+ const E_NOT_FOUND

+ const E_OK

+ const E_UNDER_OPERATION

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

type Container

+ ApiContainer *apitypes.Container

+ CreatedAt int64

type Daemon

+ func (daemon *Daemon) CmdImagePull(image, tag string, authConfig *types.AuthConfig, ...) error

+ func (daemon *Daemon) CmdImagePush(repo, tag string, authConfig *types.AuthConfig, ...) error

+ func (daemon *Daemon) CmdStopContainer(name string) (*engine.Env, error)

+ func (daemon *Daemon) CreateContainerInPod(podId string, spec *apitypes.UserContainer) (string, error)

+ func (daemon *Daemon) CreateExec(containerId, cmd string, terminal bool) (string, error)

+ func (daemon *Daemon) GetContainerStatus(state uint32) string

+ func (daemon *Daemon) GetPodStatus(state uint, podType string) string

+ func (daemon *Daemon) GetVMStatus(state uint) string

+ func (daemon *Daemon) ListContainers(podId, vmId string, auxiliary bool) ([]*hypervisor.ContainerStatus, error)

+ func (daemon *Daemon) ListPods(podId, vmId string) ([]*Pod, error)

+ func (daemon *Daemon) ListVMs(podId, vmId string) ([]*hypervisor.Vm, error)

+ func (daemon *Daemon) StartExec(stdin io.ReadCloser, stdout io.WriteCloser, containerId, execId string) error

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

+ func (daemon *Daemon) StopContainerWithinLock(pod *Pod, containerId string) error

+ type GlobalLogConfig struct

+ PathPrefix string

+ PodIdInPath bool

type Pod

+ CreatedAt int64

+ PodStatus *hypervisor.PodStatus

+ Spec *pod.UserPod

+ VM *hypervisor.Vm

+ func (p *Pod) CreateVolumes(daemon *Daemon) error

+ func (p *Pod) ParseContainerJsons(daemon *Daemon, jsons []*dockertypes.ContainerJSON) (err error)

+ func (p *Pod) TryLoadContainers(daemon *Daemon) ([]*dockertypes.ContainerJSON, error)

+ func (p *Pod) UpdateContainerStatus(jsons []*dockertypes.ContainerJSON) error

+ type VmList struct

+ func NewVmList() *VmList

+ func (vl *VmList) Add(vm *hypervisor.Vm)

+ func (vl *VmList) Foreach(fn VmOp) error

+ func (vl *VmList) Get(id string) (*hypervisor.Vm, bool)

+ func (vl *VmList) NewVm(id string, cpu, memory int, lazy bool) *hypervisor.Vm

+ func (vl *VmList) Remove(id string)

+ type VmOp func(*hypervisor.Vm) error

v0.6.0

May 25, 2016

Changes in this version

+ func CleanupExistingVolume(fstype, filepath, sharedDir string) error

+ func GetMountIdByContainer(driver, cid string) (string, error)

+ func InitDockerCfg(mirrors []string, insecureRegistries []string, graphdriver, root string)

+ func ParseServiceDiscovery(id string, spec *pod.UserPod) error

type AufsStorage

+ func (a *AufsStorage) CleanupContainer(id, sharedDir string) error

+ type ContainerLogsConfig struct

+ Follow bool

+ OutStream io.Writer

+ Since time.Time

+ Stop <-chan bool

+ Tail string

+ Timestamps bool

+ UseStderr bool

+ UseStdout bool

type Daemon

+ Factory factory.Factory

+ func (daemon *Daemon) Attach(stdin io.ReadCloser, stdout io.WriteCloser, key, id, tag string) error

+ func (daemon *Daemon) CmdAddService(podId, data string) (*engine.Env, error)

+ func (daemon *Daemon) CmdAuthenticateToRegistry(config *types.AuthConfig) (string, error)

+ func (daemon *Daemon) CmdCleanPod(podId string) (*engine.Env, error)

+ func (daemon *Daemon) CmdCommitImage(name string, cfg *types.ContainerCommitConfig) (*engine.Env, error)

+ func (daemon *Daemon) CmdContainerRename(oldname, newname string) (*engine.Env, error)

+ func (daemon *Daemon) CmdCreateContainer(params types.ContainerCreateConfig) (*engine.Env, error)

+ func (daemon *Daemon) CmdCreatePod(podArgs string, autoremove bool) (*engine.Env, error)

+ func (daemon *Daemon) CmdCreateVm(cpu, mem int, async bool) (*engine.Env, error)

+ func (daemon *Daemon) CmdDeleteService(podId, data string) (*engine.Env, error)

+ func (daemon *Daemon) CmdGetContainerInfo(name string) (interface{}, error)

+ func (daemon *Daemon) CmdGetContainerLogs(container string, config *ContainerLogsConfig) (err error)

+ func (daemon *Daemon) CmdGetPodInfo(podName string) (interface{}, error)

+ func (daemon *Daemon) CmdGetPodStats(podId string) (interface{}, error)

+ func (daemon *Daemon) CmdGetServices(podId string) ([]pod.UserService, error)

+ func (daemon *Daemon) CmdImageDelete(name string, force, prune bool) (*engine.Env, error)

+ func (daemon *Daemon) CmdKillContainer(name string, sig int64) (*engine.Env, error)

+ func (daemon *Daemon) CmdKillPod(podId, container string, sig int64) (*engine.Env, error)

+ func (daemon *Daemon) CmdKillVm(vmId string) (*engine.Env, error)

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

+ func (daemon *Daemon) CmdSetPodLabels(podId string, override bool, labels map[string]string) (*engine.Env, error)

+ func (daemon *Daemon) CmdStartPod(stdin io.ReadCloser, stdout io.WriteCloser, podId, vmId, tag string) (*engine.Env, error)

+ func (daemon *Daemon) CmdStopPod(podId, stopVm string) (*engine.Env, error)

+ func (daemon *Daemon) CmdSystemInfo() (*engine.Env, error)

+ func (daemon *Daemon) CmdSystemVersion() *engine.Env

+ func (daemon *Daemon) CmdTtyResize(podId, tag string, h, w int) error

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

+ func (daemon *Daemon) CmdUpdateService(podId, data string) (*engine.Env, error)

+ func (daemon *Daemon) ContainerRename(oldname, newname string) error

+ func (daemon *Daemon) CreateVm(cpu, mem int, async bool) (*hypervisor.Vm, error)

+ func (daemon *Daemon) Exec(stdin io.ReadCloser, stdout io.WriteCloser, key, id, cmd, tag string, ...) error

+ func (daemon *Daemon) ExitCode(container, tag string) (int, error)

+ func (daemon *Daemon) GetContainerInfo(name string) (types.ContainerInfo, error)

+ func (daemon *Daemon) GetContainerLogs(container string, config *ContainerLogsConfig) (err error)

+ func (daemon *Daemon) GetPodInfo(podName string) (types.PodInfo, error)

+ func (daemon *Daemon) GetPodStats(podId string) (interface{}, error)

+ func (daemon *Daemon) KillContainer(name string, sig int64) error

+ func (daemon *Daemon) KillPodContainers(podName, container string, sig int64) error

+ func (daemon *Daemon) List(item, podId, vmId string, auxiliary bool) (map[string][]string, error)

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

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

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

+ func (daemon *Daemon) SetPodLabels(podId string, override bool, labels map[string]string) error

+ func (daemon *Daemon) Shutdown() error

+ func (daemon *Daemon) StartInternal(p *Pod, vmId string, config interface{}, lazy bool, ...) (int, string, error)

+ func (daemon *Daemon) StopPodWithinLock(pod *Pod) (int, string, error)

+ func (daemon *Daemon) TtyResize(podId, tag string, h, w int) error

type DevMapperStorage

+ func (dms *DevMapperStorage) CleanupContainer(id, sharedDir string) error

type OverlayFsStorage

+ func (o *OverlayFsStorage) CleanupContainer(id, sharedDir string) error

type Pod

+ func NewPod(podSpec *apitypes.UserPod, id string, data interface{}) (*Pod, error)

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

+ func (p *Pod) DoCreate(daemon *Daemon) error

+ func (p *Pod) InitializeFinished(daemon *Daemon) error

+ func (p *Pod) ShouldWaitCleanUp() bool

+ func (p *Pod) TransitionLock(label string) bool

+ func (p *Pod) TransitionUnlock(label string)

type PodList

+ func (pl *PodList) CountAll() int64

+ func (pl *PodList) GetByContainerId(cid string) (*Pod, bool)

+ func (pl *PodList) GetByContainerIdOrName(cid string) (*Pod, int, bool)

type Storage

+ CleanupContainer func(id, sharedDir string) error

type VBoxStorage

+ func (v *VBoxStorage) CleanupContainer(id, sharedDir string) error

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

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