supervisor

package

Go to main page

Versions in this module

v0

v0.2.8

Mar 29, 2017

v0.2.7

Mar 15, 2017

v0.2.6

Mar 15, 2017

Changes in this version

type AddProcessTask

+ Ctx context.Context

type StartResponse

+ ExecPid int

type StartTask

+ Ctx context.Context

v0.2.5

Dec 5, 2016

v0.2.4

Sep 24, 2016

v0.2.3

Aug 10, 2016

Changes in this version

+ const StateExit

+ const StateLive

+ const StateOOM

+ const StatePause

+ const StateResume

+ const StateStart

+ const StateStartProcess

type CreateCheckpointTask — darwin/amd64, js/wasm, linux/amd64

+ CheckpointDir string

type DeleteCheckpointTask — darwin/amd64, js/wasm, linux/amd64

+ CheckpointDir string

type DeleteTask

+ Process runtime.Process

type GetContainersTask

+ GetState func(c runtime.Container) (interface{}, error)

+ States []interface{}

type Machine — darwin/amd64, js/wasm

+ func CollectMachineInformation() (Machine, error)

type StartTask

+ Checkpoint *runtime.Checkpoint

+ CheckpointDir string

+ Runtime string

+ RuntimeArgs []string

v0.2.2

May 24, 2016

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

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