supervisor

package

Go to main page

Versions in this module

v0

v0.2.9

May 30, 2017

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