types

type AuthConfig struct {
	Username string `yaml:"username,omitempty" json:"username,omitempty"`
	Password string `yaml:"password,omitempty" json:"password,omitempty"`
}

type Bind struct {
	InContainerPath string `yaml:"bind,omitempty"`
	ReadOnly        bool   `yaml:"ro,omitempty"`
}

type Build struct {
	Base      string            `yaml:"base,omitempty"`
	Repo      string            `yaml:"repo,omitempty"`
	Version   string            `yaml:"version,omitempty"`
	Dir       string            `yaml:"dir,omitempty"`
	Submodule bool              `yaml:"submodule,omitempty"`
	Commands  []string          `yaml:"commands,omitempty,flow"`
	Envs      map[string]string `yaml:"envs,omitempty,flow"`
	Args      map[string]string `yaml:"args,omitempty,flow"`
	Labels    map[string]string `yaml:"labels,omitempty,flow"`
	Artifacts map[string]string `yaml:"artifacts,omitempty,flow"`
	Cache     map[string]string `yaml:"cache,omitempty,flow"`
}

type BuildImageMessage struct {
	ID          string      `json:"id,omitempty"`
	Status      string      `json:"status,omitempty"`
	Progress    string      `json:"progress,omitempty"`
	Error       string      `json:"error,omitempty"`
	Stream      string      `json:"stream,omitempty"`
	ErrorDetail errorDetail `json:"errorDetail,omitempty"`
}

type BuildOptions struct {
	Name   string
	User   string
	UID    int
	Tags   []string
	Builds *Builds
}

type Builds struct {
	Stages []string          `yaml:"stages,omitempty,flow"`
	Builds map[string]*Build `yaml:"builds,omitempty,flow"`
}

type CPUAndMem struct {
	CPUMap CPUMap
	MemCap int64
}

type CPUMap map[string]int

type Config struct {
	LogLevel      string        `yaml:"log_level"`
	Bind          string        `yaml:"bind"`           // HTTP API address
	Statsd        string        `yaml:"statsd"`         // statsd host and port
	Profile       string        `yaml:"profile"`        // profile ip:port
	ImageCache    int           `yaml:"image_cache"`    // cache image count
	LockTimeout   int           `yaml:"lock_timeout"`   // timeout for lock (ttl)
	GlobalTimeout time.Duration `yaml:"global_timeout"` // timeout for remove, run_and_wait and build, in second
	Auth          AuthConfig    `yaml:"auth"`           // grpc auth

	Git       GitConfig    `yaml:"git"`
	Etcd      EtcdConfig   `yaml:"etcd"`
	Docker    DockerConfig `yaml:"docker"`
	Scheduler SchedConfig  `yaml:"scheduler"`
}

type Container struct {
	ID         string            `json:"id"`
	Podname    string            `json:"podname"`
	Nodename   string            `json:"nodename"`
	Name       string            `json:"name"`
	CPU        CPUMap            `json:"cpu"`
	Quota      float64           `json:"quota"`
	Memory     int64             `json:"memory"`
	Hook       *Hook             `json:"hook"`
	Privileged bool              `json:"privileged"`
	SoftLimit  bool              `json:"softlimit"`
	Engine     *engineapi.Client `json:"-"`
	Node       *Node             `json:"-"`
}

type CopyMessage struct {
	ID     string        `json:"id,omitempty"`
	Status string        `json:"status,omitempty"`
	Name   string        `json:"name,omitempty"`
	Path   string        `json:"path,omitempty"`
	Error  error         `json:"error,omitempty"`
	Data   io.ReadCloser `json:"-"`
}

type CopyOptions struct {
	Targets map[string][]string
}

type CreateContainerMessage struct {
	Podname       string
	Nodename      string
	ContainerID   string
	ContainerName string
	Error         error
	Success       bool
	CPU           CPUMap
	Quota         float64
	Memory        int64
	Publish       map[string]string
	Hook          []byte
}

type DeployOptions struct {
	Name         string            // Name of application
	Entrypoint   *Entrypoint       // entrypoint
	Podname      string            // Name of pod to deploy
	Nodename     string            // Specific nodes to deploy, if given, must belong to pod
	Image        string            // Name of image to deploy
	ExtraArgs    string            // Extra arguments to append to command
	CPUQuota     float64           // How many cores needed, e.g. 1.5
	Memory       int64             // Memory for container, in bytes
	Count        int               // How many containers needed, e.g. 4
	Env          []string          // Env for container
	DNS          []string          // DNS for container
	ExtraHosts   []string          // Extra hosts for container
	Volumes      []string          // Volumes for container
	Networks     map[string]string // Network names and specified IPs
	NetworkMode  string            // Network mode
	User         string            // User for container
	Debug        bool              // debug mode, use syslog as log driver
	OpenStdin    bool              // OpenStdin for container
	Meta         map[string]string // Meta for containers
	NodeLabels   map[string]string // NodeLabels for filter node
	DeployMethod string            // Deploy method
	Data         map[string][]byte // For additional file data
	SoftLimit    bool              // softlimit memory
}

type DeployStatus struct {
	Data       string
	Err        error
	Action     string
	Appname    string
	Entrypoint string
	Nodename   string
	ID         string
}

type DockerConfig struct {
	APIVersion  string                `yaml:"version"`      // docker API version
	NetworkMode string                `yaml:"network_mode"` // docker network mode
	CertPath    string                `yaml:"cert_path"`    // docker cert files path
	Hub         string                `yaml:"hub"`          // docker hub address
	Namespace   string                `yaml:"namespace"`    // docker hub prefix, will be set to $Hub/$HubPrefix/$appname
	BuildPod    string                `yaml:"build_pod"`    // podname used to build
	UseLocalDNS bool                  `yaml:"local_dns"`    // use node IP as dns
	Log         LogConfig             `yaml:"log"`          // docker log driver
	AuthConfigs map[string]AuthConfig `yaml:"auths"`        // docker registry credentials
}

type Entrypoint struct {
	Name          string       `yaml:"name,omitempty"`
	Command       string       `yaml:"cmd,omitempty"`
	Privileged    bool         `yaml:"privileged,omitempty"`
	Dir           string       `yaml:"dir,omitempty"`
	Log           *LogConfig   `yaml:"log,omitempty"`
	Publish       []string     `yaml:"publish,omitempty,flow"`
	HealthCheck   *HealthCheck `yaml:"healthcheck,omitempty,flow"`
	Hook          *Hook        `yaml:"hook,omitempty,flow"`
	RestartPolicy string       `yaml:"restart,omitempty"`
}

type EtcdConfig struct {
	Machines   []string `yaml:"machines"`    // etcd cluster addresses
	Prefix     string   `yaml:"prefix"`      // etcd lock prefix, all locks will be created under this dir
	LockPrefix string   `yaml:"lock_prefix"` // etcd lock prefix, all locks will be created under this dir
}

type GitConfig struct {
	SCMType    string `yaml:"scm_type"`    // source code manager type [gitlab/github]
	PublicKey  string `yaml:"public_key"`  // public key to clone code
	PrivateKey string `yaml:"private_key"` // private key to clone code
	Token      string `yaml:"token"`       // Token to call SCM API
}

type HealthCheck struct {
	TCPPorts []string `yaml:"tcp_ports,omitempty,flow"`
	HTTPPort string   `yaml:"http_port"`
	HTTPURL  string   `yaml:"url,omitempty"`
	HTTPCode int      `yaml:"code,omitempty"`
}

type Hook struct {
	AfterStart []string `yaml:"after_start,omitempty"`
	BeforeStop []string `yaml:"before_stop,omitempty"`
	Force      bool     `yaml:"force,omitempty"`
}

type LogConfig struct {
	Type   string            `yaml:"type"`   // Log type, can be "journald", "json-file", "none"
	Config map[string]string `yaml:"config"` // Log configs
}

type Network struct {
	Name    string   `json:"name"`
	Subnets []string `json:"cidr"`
}

type Node struct {
	sync.Mutex

	Name      string            `json:"name"`
	Endpoint  string            `json:"endpoint"`
	Podname   string            `json:"podname"`
	Available bool              `json:"available"`
	CPU       CPUMap            `json:"cpu"`
	MemCap    int64             `json:"memcap"`
	Labels    map[string]string `json:"labels"`
	Engine    *engineapi.Client `json:"-"`
}

type NodeInfo struct {
	CPUAndMem
	Name     string
	CPUs     int
	CPUPlan  []CPUMap
	Capacity int // 可以部署几个
	Count    int // 上面有几个了
	Deploy   int // 最终部署几个

}

type Pod struct {
	Name string `json:"name"`
	Desc string `json:"desc"`
	// scheduler favor, should be CPU or MEM
	Favor string `json:"favor"`
}

type PullImageMessage struct {
	BuildImageMessage
}

type ReallocResourceMessage struct {
	ContainerID string
	Success     bool
}

type RemoveContainerMessage struct {
	ContainerID string
	Success     bool
	Message     string
}

type RemoveImageMessage struct {
	Image    string
	Success  bool
	Messages []string
}

type ReplaceContainerMessage struct {
	Create *CreateContainerMessage
	Remove *RemoveContainerMessage
	Error  error
}

type RunAndWaitMessage struct {
	ContainerID string
	Data        []byte
}

type RunAndWaitOptions struct {
	DeployOptions
	Timeout int
	Cmd     string
}

type SchedConfig struct {
	MaxShare  int `yaml:"maxshare"`  // comlpex scheduler use maxshare
	ShareBase int `yaml:"sharebase"` // how many pieces for one core
}