var (
	// External errors
	ErrTaskChanNil            = errors.New("containerd: task channel is nil")
	ErrBundleNotFound         = errors.New("containerd: bundle not found")
	ErrContainerNotFound      = errors.New("containerd: container not found")
	ErrContainerExists        = errors.New("containerd: container already exists")
	ErrProcessNotFound        = errors.New("containerd: processs not found for container")
	ErrUnknownContainerStatus = errors.New("containerd: unknown container status ")
	ErrUnknownTask            = errors.New("containerd: unknown task type")
)

var (
	ContainerCreateTimer   = metrics.NewTimer()
	ContainerDeleteTimer   = metrics.NewTimer()
	ContainerStartTimer    = metrics.NewTimer()
	ContainerStatsTimer    = metrics.NewTimer()
	ContainersCounter      = metrics.NewCounter()
	EventSubscriberCounter = metrics.NewCounter()
	TasksCounter           = metrics.NewCounter()
	ExecProcessTimer       = metrics.NewTimer()
	ExitProcessTimer       = metrics.NewTimer()
	EpollFdCounter         = metrics.NewCounter()
)

type AddProcessTask struct {
	ID            string
	PID           string
	Stdout        string
	Stderr        string
	Stdin         string
	ProcessSpec   *specs.ProcessSpec
	StartResponse chan StartResponse
	// contains filtered or unexported fields
}

type CreateCheckpointTask struct {
	ID         string
	Checkpoint *runtime.Checkpoint
	// contains filtered or unexported fields
}

type DeleteCheckpointTask struct {
	ID         string
	Checkpoint *runtime.Checkpoint
	// contains filtered or unexported fields
}

type DeleteTask struct {
	ID      string
	Status  int
	PID     string
	NoEvent bool
	// contains filtered or unexported fields
}

type Event struct {
	ID        string    `json:"id"`
	Type      string    `json:"type"`
	Timestamp time.Time `json:"timestamp"`
	PID       string    `json:"pid,omitempty"`
	Status    int       `json:"status,omitempty"`
}

type ExecExitTask struct {
	ID      string
	PID     string
	Status  int
	Process runtime.Process
	// contains filtered or unexported fields
}

type ExitTask struct {
	Process runtime.Process
	// contains filtered or unexported fields
}

type GetContainersTask struct {
	ID         string
	Containers []runtime.Container
	// contains filtered or unexported fields
}

type Machine struct {
	Cpus   int
	Memory int64
}

type Monitor struct {
	// contains filtered or unexported fields
}

type OOMTask struct {
	ID string
	// contains filtered or unexported fields
}

type SignalTask struct {
	ID     string
	PID    string
	Signal os.Signal
	// contains filtered or unexported fields
}

type StartResponse struct {
	Container runtime.Container
}

type StartTask struct {
	ID            string
	BundlePath    string
	Stdout        string
	Stderr        string
	Stdin         string
	StartResponse chan StartResponse
	Labels        []string
	NoPivotRoot   bool
	// contains filtered or unexported fields
}

type StatsTask struct {
	ID   string
	Stat chan *runtime.Stat
	// contains filtered or unexported fields
}

type Supervisor struct {
	// contains filtered or unexported fields
}

type Task interface {
	// ErrorCh returns a channel used to report and error from an async task
	ErrorCh() chan error
}

type UpdateProcessTask struct {
	ID         string
	PID        string
	CloseStdin bool
	Width      int
	Height     int
	// contains filtered or unexported fields
}

type UpdateTask struct {
	ID        string
	State     runtime.State
	Resources *runtime.Resource
	// contains filtered or unexported fields
}

type Worker interface {
	Start()
}