pod

package

Go to main page

Versions in this module

v1

v1.1.0

Sep 17, 2018

Changes in this version

type XPod

+ func (p *XPod) SandboxNameLocked() string

v1.1.0-rc1

Aug 16, 2018

v1.0.0

Nov 1, 2017

Changes in this version

+ const PMAP_KEY_FMT

+ const PMETA_KEY_FMT

type XPod

+ func (p *XPod) AddPortMapping(spec []*apitypes.PortMapping) error

+ func (p *XPod) ListPortMappings() []*apitypes.PortMapping

+ func (p *XPod) RemovePortMappingByDest(spec []*apitypes.PortMapping) error

+ func (p *XPod) RemovePortMappingStricted(spec []*apitypes.PortMapping) error

v0

v0.8.1

May 10, 2017

Changes in this version

+ type StreamCloser struct

+ func (sc *StreamCloser) Close() error

type XPod

+ func (p *XPod) IsStopped() bool

v0.8.0

Mar 21, 2017

Changes in this version

+ const CX_KEY_FMT

+ const DEBUG

+ const DEFAULT_INTERFACE_NAME

+ const DEFAULT_MODE

+ const DEFAULT_SCHEDULER

+ const DEFAULT_WEITHT

+ const ERROR

+ const IF_KEY_FMT

+ const INFO

+ const LAYOUT_KEY_FMT

+ const LAYOUT_KEY_PREFIX

+ const PM_KEY_FMT

+ const PS_KEY_FMT

+ const SB_KEY_FMT

+ const TRACE

+ const VX_KEY_FMT

+ const WARNING

+ var DetachError error = fmt.Errorf("DetachError")

+ var DetachKeys = "ctrl-p,ctrl-q"

+ var ProvisionTimeout = 5 * time.Minute

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

+ func HostsCreator(pod string) *utils.Initializer

+ func HostsPath(pod string) (hostsDir, hostsPath string)

+ func ListAllPods(db *daemondb.DaemonDB) ([][]byte, error)

+ func LoadAllPods(db *daemondb.DaemonDB) chan *types.PersistPodLayout

+ func MigrateLagecyPersistentData(db *daemondb.DaemonDB, podFactory func() *PodFactory) (err error)

+ func ProbeExistingVolume(v *apitypes.UserVolume, sharedDir string) (*runv.VolumeDescription, error)

+ func UmountExistingVolume(fstype, target, sharedDir string) error

+ type Container struct

+ func (c *Container) Add() error

+ func (c *Container) AttachStreams(streamConfig *StreamConfig, openStdin, stdinOnce, tty bool, ...) error

+ func (c *Container) BriefStatus() (s *apitypes.ContainerListResult)

+ func (c *Container) CreatedAt() time.Time

+ func (c *Container) CurrentState() ContainerState

+ func (c *Container) GetExitCode() (uint8, error)

+ func (c *Container) HasTty() bool

+ func (c *Container) Id() string

+ func (c *Container) Info() *apitypes.Container

+ func (c *Container) InfoStatus() *apitypes.ContainerStatus

+ func (c *Container) IsAlive() bool

+ func (c *Container) IsRunning() bool

+ func (c *Container) IsStopped() bool

+ func (c *Container) Log(level hlog.LogLevel, args ...interface{})

+ func (c *Container) LogPrefix() string

+ func (c *Container) Remove() error

+ func (c *Container) RuntimeName() string

+ func (c *Container) SpecName() string

+ func (c *Container) StatusString() string

+ type ContainerEngine interface

+ ContainerCreate func(params dockertypes.ContainerCreateConfig) (dockertypes.ContainerCreateResponse, error)

+ ContainerInspect func(id string, size bool, version version.Version) (interface{}, error)

+ ContainerRename func(oldName, newName string) error

+ ContainerRm func(name string, config *dockertypes.ContainerRmConfig) error

+ type ContainerState int32

+ const S_CONTAINER_CREATED

+ const S_CONTAINER_CREATING

+ const S_CONTAINER_NONE

+ const S_CONTAINER_RUNNING

+ const S_CONTAINER_STOPPING

+ type ContainerStatus struct

+ CreatedAt time.Time

+ ExitCode int

+ FinishedAt time.Time

+ Killed bool

+ StartedAt time.Time

+ State ContainerState

+ func (cs *ContainerStatus) Create() error

+ func (cs *ContainerStatus) Created(t time.Time) error

+ func (cs *ContainerStatus) IsRunning() bool

+ func (cs *ContainerStatus) IsStopped() bool

+ func (cs *ContainerStatus) Running(t time.Time) error

+ func (cs *ContainerStatus) SetKilled()

+ func (cs *ContainerStatus) Start() error

+ func (cs *ContainerStatus) Stop() error

+ func (cs *ContainerStatus) Stopped(t time.Time, exitCode int) bool

+ func (cs *ContainerStatus) UnexpectedStopped() bool

+ type Exec struct

+ Cmds []string

+ Container string

+ ExitCode uint8

+ Id string

+ Terminal bool

+ func (e *Exec) Log(level hlog.LogLevel, args ...interface{})

+ func (e *Exec) LogPrefix() string

+ type GlobalLogConfig struct

+ PathPrefix string

+ PodIdInPath bool

+ type Interface struct

+ func (inf *Interface) Log(level hlog.LogLevel, args ...interface{})

+ func (inf *Interface) LogPrefix() string

+ type LogStatus struct

+ Copier *logger.Copier

+ Driver logger.Logger

+ LogPath string

+ type PodFactory struct

+ func NewPodFactory(vmFactory factory.Factory, registry *PodList, db *daemondb.DaemonDB, ...) *PodFactory

+ type PodFilterOp func(*XPod) bool

+ type PodList struct

+ func NewPodList() *PodList

+ func (pl *PodList) CountAll() int64

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

+ func (pl *PodList) CountRunning() int64

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

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

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

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

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

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

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

+ func (pl *PodList) ReleaseContainer(id, name string)

+ func (pl *PodList) ReleaseContainerName(name string)

+ func (pl *PodList) ReserveContainer(id, name, pod string) error

+ func (pl *PodList) ReserveContainerID(id, pod string) error

+ func (pl *PodList) ReserveContainerName(name, pod string) error

+ func (pl *PodList) ReservePod(p *XPod) error

+ type PodOp func(*XPod) error

+ type PodState int32

+ const S_POD_ERROR

+ const S_POD_NONE

+ const S_POD_PAUSED

+ const S_POD_RUNNING

+ const S_POD_STARTING

+ const S_POD_STOPPED

+ const S_POD_STOPPING

+ type PodStorage interface

+ CleanupContainer func(id, sharedDir string) error

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

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

+ PrepareContainer func(mountId, sharedDir string) (*runv.VolumeDescription, error)

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

+ Type func() string

+ type Record struct

+ Hosts string

+ IP string

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

+ type Services struct

+ func (s *Services) Log(level hlog.LogLevel, args ...interface{})

+ func (s *Services) LogPrefix() string

+ type StreamConfig struct

+ func NewStreamConfig() *StreamConfig

+ func (streamConfig *StreamConfig) CloseStreams() error

+ func (streamConfig *StreamConfig) NewInputPipes()

+ func (streamConfig *StreamConfig) NewNopInputPipe()

+ func (streamConfig *StreamConfig) Stderr() *broadcaster.Unbuffered

+ func (streamConfig *StreamConfig) StderrPipe() io.ReadCloser

+ func (streamConfig *StreamConfig) Stdin() io.ReadCloser

+ func (streamConfig *StreamConfig) StdinPipe() io.WriteCloser

+ func (streamConfig *StreamConfig) Stdout() *broadcaster.Unbuffered

+ func (streamConfig *StreamConfig) StdoutPipe() io.ReadCloser

+ type Volume struct

+ func (v *Volume) Info() *apitypes.PodVolume

+ func (v *Volume) Log(level hlog.LogLevel, args ...interface{})

+ func (v *Volume) LogPrefix() string

+ type VolumeState int32

+ const S_VOLUME_CREATED

+ const S_VOLUME_ERROR

+ const S_VOLUME_INSERTED

+ const S_VOLUME_INSERTING

+ type XPod struct

+ func CreateXPod(factory *PodFactory, spec *apitypes.UserPod) (*XPod, error)

+ func LoadXPod(factory *PodFactory, layout *types.PersistPodLayout) (*XPod, error)

+ func (p *XPod) AddService(srvs []*apitypes.UserService) error

+ func (p *XPod) Attach(cid string, stdin io.ReadCloser, stdout io.WriteCloser, rsp chan<- error) error

+ func (p *XPod) BriefStatus() (s *apitypes.PodListResult)

+ func (p *XPod) CleanupExecs()

+ func (p *XPod) ContainerBriefStatus(cid string) *apitypes.ContainerListResult

+ func (p *XPod) ContainerCreate(c *apitypes.UserContainer) (string, error)

+ func (p *XPod) ContainerHasTty(cid string) bool

+ func (p *XPod) ContainerId2Name(id string) string

+ func (p *XPod) ContainerIds() []string

+ func (p *XPod) ContainerInfo(cid string) (*apitypes.ContainerInfo, error)

+ func (p *XPod) ContainerLogger(id string) logger.Logger

+ func (p *XPod) ContainerName2Id(name string) (string, bool)

+ func (p *XPod) ContainerNames() []string

+ func (p *XPod) ContainerStart(cid string) error

+ func (p *XPod) ContainerStatusString(cid string) string

+ func (p *XPod) CreateExec(containerId, cmds string, terminal bool) (string, error)

+ func (p *XPod) DelayDeleteOn() bool

+ func (p *XPod) DeleteExec(containerId, execId string)

+ func (p *XPod) DeleteService(srvs []*apitypes.UserService) error

+ func (p *XPod) Dissociate() error

+ func (p *XPod) ExecVM(cmd string, stdin io.ReadCloser, stdout, stderr io.WriteCloser) (int, error)

+ func (p *XPod) ForceQuit()

+ func (p *XPod) GetExecExitCode(containerId, execId string) (uint8, error)

+ func (p *XPod) GetExitCode(cid, execId string) (uint8, error)

+ func (p *XPod) GetServices() ([]*apitypes.UserService, error)

+ func (p *XPod) Id() string

+ func (p *XPod) Info() (*apitypes.PodInfo, error)

+ func (p *XPod) IsAlive() bool

+ func (p *XPod) IsContainerAlive(cid string) bool

+ func (p *XPod) IsContainerRunning(cid string) bool

+ func (p *XPod) IsNone() bool

+ func (p *XPod) IsRunning() bool

+ func (p *XPod) KillContainer(id string, sig int64) error

+ func (p *XPod) KillExec(execId string, sig int64) error

+ func (p *XPod) Log(level hlog.LogLevel, args ...interface{})

+ func (p *XPod) LogPrefix() string

+ func (p *XPod) Name() string

+ func (p *XPod) Pause() error

+ func (p *XPod) Remove(force bool) error

+ func (p *XPod) RemoveContainer(id string) error

+ func (p *XPod) RenameContainer(cid, name string) error

+ func (p *XPod) SandboxBriefStatus() (s *apitypes.VMListResult)

+ func (p *XPod) SandboxName() string

+ func (p *XPod) SandboxStatusString() string

+ func (p *XPod) SetLabel(labels map[string]string, update bool) error

+ func (p *XPod) Start() error

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

+ func (p *XPod) Stats() *runvtypes.PodStats

+ func (p *XPod) StatusString() string

+ func (p *XPod) Stop(graceful int) error

+ func (p *XPod) StopContainer(id string, graceful int) error

+ func (p *XPod) TtyResize(cid, execId string, h, w int) error

+ func (p *XPod) UnPause() error

+ func (p *XPod) UpdateService(srvs []*apitypes.UserService) error

+ func (p *XPod) WaitContainer(cid string, second int) (int, error)

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