Versions in this module Expand all Collapse all v0 v0.2.1 Apr 22, 2016 v0.2.0 Apr 14, 2016 Changes in this version type StartTask + NoPivotRoot bool v0.1.0 Mar 21, 2016 Changes in this version + var ContainerCreateTimer = metrics.NewTimer() + var ContainerDeleteTimer = metrics.NewTimer() + var ContainerStartTimer = metrics.NewTimer() + var ContainerStatsTimer = metrics.NewTimer() + var ContainersCounter = metrics.NewCounter() + var EpollFdCounter = metrics.NewCounter() + var ErrBundleNotFound = errors.New("containerd: bundle not found") + var ErrContainerExists = errors.New("containerd: container already exists") + var ErrContainerNotFound = errors.New("containerd: container not found") + var ErrProcessNotFound = errors.New("containerd: processs not found for container") + var ErrTaskChanNil = errors.New("containerd: task channel is nil") + var ErrUnknownContainerStatus = errors.New("containerd: unknown container status ") + var ErrUnknownTask = errors.New("containerd: unknown task type") + var EventSubscriberCounter = metrics.NewCounter() + var ExecProcessTimer = metrics.NewTimer() + var ExitProcessTimer = metrics.NewTimer() + var TasksCounter = metrics.NewCounter() + func Metrics() map[string]interface + type AddProcessTask struct + ID string + PID string + ProcessSpec *specs.ProcessSpec + StartResponse chan StartResponse + Stderr string + Stdin string + Stdout string + func (t *AddProcessTask) ErrorCh() chan error + type CreateCheckpointTask struct — darwin/amd64, js/wasm, linux/amd64 + Checkpoint *runtime.Checkpoint + ID string + func (t *CreateCheckpointTask) ErrorCh() chan error + type DeleteCheckpointTask struct — darwin/amd64, js/wasm, linux/amd64 + Checkpoint *runtime.Checkpoint + ID string + func (t *DeleteCheckpointTask) ErrorCh() chan error + type DeleteTask struct + ID string + NoEvent bool + PID string + Status int + func (t *DeleteTask) ErrorCh() chan error + type Event struct + ID string + PID string + Status int + Timestamp time.Time + Type string + type ExecExitTask struct + ID string + PID string + Process runtime.Process + Status int + func (t *ExecExitTask) ErrorCh() chan error + type ExitTask struct + Process runtime.Process + func (t *ExitTask) ErrorCh() chan error + type GetContainersTask struct + Containers []runtime.Container + ID string + func (t *GetContainersTask) ErrorCh() chan error + type Machine struct + Cpus int + Memory int64 + func CollectMachineInformation() (Machine, error) + type Monitor struct — linux/amd64, windows/amd64 + func NewMonitor() (*Monitor, error) + func (m *Monitor) Close() error + func (m *Monitor) Exits() chan runtime.Process + func (m *Monitor) Monitor(p runtime.Process) error + func (m *Monitor) MonitorOOM(c runtime.Container) error + func (m *Monitor) OOMs() chan string + type OOMTask struct + ID string + func (t *OOMTask) ErrorCh() chan error + type SignalTask struct + ID string + PID string + Signal os.Signal + func (t *SignalTask) ErrorCh() chan error + type StartResponse struct + Container runtime.Container + type StartTask struct + BundlePath string + ID string + Labels []string + StartResponse chan StartResponse + Stderr string + Stdin string + Stdout string + func (t *StartTask) ErrorCh() chan error + type StatsTask struct + ID string + Stat chan *runtime.Stat + func (t *StatsTask) ErrorCh() chan error + type Supervisor struct + func New(stateDir string, runtimeName string) (*Supervisor, error) + func (s *Supervisor) Close() error + func (s *Supervisor) Events(from time.Time) chan Event + func (s *Supervisor) Machine() Machine + func (s *Supervisor) SendTask(evt Task) + func (s *Supervisor) Start() error + func (s *Supervisor) Stop() + func (s *Supervisor) Unsubscribe(sub chan Event) + type Task interface + ErrorCh func() chan error + type UpdateProcessTask struct + CloseStdin bool + Height int + ID string + PID string + Width int + func (t *UpdateProcessTask) ErrorCh() chan error + type UpdateTask struct + ID string + Resources *runtime.Resource + State runtime.State + func (t *UpdateTask) ErrorCh() chan error + type Worker interface + Start func() + func NewWorker(s *Supervisor, wg *sync.WaitGroup) Worker
Go to main page