container

type BcsContainerInfo struct {
	ID                      string                 `json:"ID,omitempty"`          // container ID
	Name                    string                 `json:"Name,omitempty"`        // container name
	Pid                     int                    `json:"Pid,omitempty"`         // container pid
	StartAt                 time.Time              `json:"StartAt,omitempty"`     // startting time
	FinishAt                time.Time              `json:"FinishAt,omitempty"`    // Exit time
	Status                  string                 `json:"Status,omitempty"`      // status string, paused, restarting, running, dead, created, exited
	Healthy                 bool                   `json:"Healthy,omitempty"`     // Container healthy
	IsChecked               bool                   `json:",omitempty"`            // is health check
	ConsecutiveFailureTimes int                    `json:",omitempty"`            // consecutive failure times
	ExitCode                int                    `json:"ExitCode,omitempty"`    // container exit code
	Hostname                string                 `json:"Hostname,omitempty"`    // container host name
	NetworkMode             string                 `json:"NetworkMode,omitempty"` // Network mode for container
	IPAddress               string                 `json:"IPAddress,omitempty"`   // Contaienr IP address
	NodeAddress             string                 `json:"NodeAddress,omitempty"` // node host address
	Ports                   []BcsPort              `json:"Ports,omitempty"`       // ports info for report
	Message                 string                 `json:"Message,omitempty"`     // status message for container
	Resource                *schedTypes.Resource   `json:"Resource,omitempty"`
	BcsMessage              *schedTypes.BcsMessage `json:",omitempty"`
	OOMKilled               bool                   `json:"OOMKilled,omitempty"` // container exited, whether oom
}

type BcsContainerTask struct {
	Name              string                       // container name
	Image             string                       // container image
	HostName          string                       // container hostname
	Hosts             []string                     // host:ip pair for /etc/hosts in container
	Command           string                       // container command
	Args              []string                     // args for command
	Env               []BcsKV                      // environments
	Volums            []BcsVolume                  // host path mount
	NetworkName       string                       // container network name
	NetworkIPAddr     string                       // container ip address request
	ForcePullImage    bool                         // pull image every time
	OOMKillDisabled   bool                         // OOM kill feature, default is true
	AutoRemove        bool                         // remove container when exit, default false
	Ulimits           []BcsKV                      // ulimit for docker parameter
	ShmSize           int64                        // docker hostconfig shm size, 1 = 1B
	Privileged        bool                         // setting container privileged
	PublishAllPorts   bool                         // publish all ports in container
	PortBindings      map[string]BcsPort           // port for container reflection, only useful for docker bridge
	Labels            []BcsKV                      // label for container
	Resource          *bcstypes.Resource           // container resource request
	LimitResource     *bcstypes.Resource           // container resource limit
	ExtendedResources []*comtypes.ExtendedResource // extended resources
	BcsMessages       []*bcstypes.BcsMessage       // bcs define message
	RuntimeConf       *BcsContainerInfo            // container runtime info
	HealthCheck       healthcheck.Checker          // for health check
	KillPolicy        int                          // kill policy timeout, unit is seconds
	// container network flow limit args
	NetLimit *comtypes.NetLimit
	TaskId   string

	Ipc string // IPC namespace to use

}

type BcsImage struct {
	ID         string   // image id
	Repository []string // repository, including tag
	Created    int64    // create time
	Size       int64    // image size
}

type BcsKV struct {
	Key   string
	Value string
}

type BcsPort struct {
	Name          string `json:"name,omitempty"`
	ContainerPort string `json:"containerPort,omitempty"`
	HostPort      string `json:"hostPort,omitempty"`
	Protocol      string `json:"protocol,omitempty"`
	HostIP        string `json:"hostIP,omitempty"` // use for host has multiple ip address
}

type BcsVolume struct {
	ReadOnly      bool
	HostPath      string
	ContainerPath string
}

type ConEventCB func(*BcsContainerTask) error

type Container interface {
	// RunCommand running command in Container
	RunCommand(containerID string, command []string) error
	// UploadToContainer upload file from host to Container
	UploadToContainer(containerID string, source, dest string) error
	// ListContainer list all running containner info
	ListContainer()
	// CreateContainer create Container with info, after container created,
	// return container id & container name in BcsContainerInfo. if we need conntainer
	// running, StartContainer must be call with container id
	CreateContainer(containerName string, containerTask *BcsContainerTask) (*BcsContainerInfo, error)
	// StartContainer starting container with container id return by CreateContainer
	StartContainer(containerID string) error
	// StopContainer with container name. container will be killed when timeout
	StopContainer(containerName string, timeout int) error
	// RemoveContainer remove container by name
	RemoveContainer(containerName string, force bool) error
	// KillContainer kill container by name with designate signal
	KillContainer(containerName string, signal int) error
	// InspectContainer inspect container by name
	InspectContainer(containerName string) (*BcsContainerInfo, error)
	// PullImage pull image from hub
	PullImage(image string) error
	// ListImage list all image from local
	ListImage(filter string) ([]*BcsImage, error)
	// UpdateResources xxx
	// update container resources limit
	// para1: container id
	// para2: resources,cpu mem
	UpdateResources(string, *schedTypes.TaskResources) error
	// CommitImage xxx
	// commit image
	// para1: container id
	// para2: image name
	CommitImage(string, string) error

	// RunCommandV2 xxx
	// exec command
	RunCommandV2(ops *schedTypes.RequestCommandTask) (*schedTypes.ResponseCommandTask, error)
}

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

type Pod interface {
	IsHealthy() bool                                  // check pod is healthy
	Injection() bool                                  // check ip address is injected
	SetIPAddr(ip string)                              // set Pod ip address
	GetIPAddr() string                                // get pod ip address if exist
	SetPodID(ID string)                               // set pod id if needed
	GetNamespace() string                             // get namespace, not used now
	GetNetns() string                                 // get netns path string
	GetNetworkName() string                           // get container network name
	GetNetArgs() [][2]string                          // get cni plugin args
	GetPid() int                                      // get network infrastructure container pid
	GetContainerID() string                           // get network infrastructure container id
	GetPodID() string                                 // get pod id
	GetNetStatus() string                             // get network ip address information
	GetPodStatus() PodStatus                          // pod status, see @PodStatus
	GetMessage() string                               // Get status message
	Init() error                                      // init pod, start network container
	Finit() error                                     // finit pod, release pod resource
	Start() error                                     // start all container
	Stop(graceExit int)                               // stop all container, graceExit
	UploadFile(name, source, dest string) error       // upload source file to container(name)
	Execute(name string, command []string) error      // execute command in container(name)
	GetContainers() []*BcsContainerInfo               // Get all containers info
	GetContainerByName(name string) *BcsContainerInfo // Get container by ID
	// UpdateResources TODO
	// update container resources limit
	// para1: container id
	// para2: resources,cpu mem
	UpdateResources(string, *schedTypes.TaskResources) error
	// CommitImage TODO
	// commit image
	// para1: container id
	// para2: image name
	CommitImage(string, string) error
	GetContainerTasks() map[string]*BcsContainerTask
}

type PodEventCB func(Pod) error

type PodEventHandler struct {
	PreStart  ConEventCB // call before container start
	PostStart ConEventCB // call after container start success
	PreStop   ConEventCB // call before container stop, not including failed stop
	PostStop  ConEventCB // call after container stopped, not including failed stop
}

type PodStatus string