models

type Cluster struct {
	Namespace              string
	Username               string
	AppDeployments         []*Deployment
	SvcDeployments         []*Deployment
	K8sServices            map[*Deployment]*Service
	Job, PostJob           *Job
	PersistentVolumeClaims []*PersistentVolumeClaim
	DeploymentReadiness    Readiness
	JobReadiness           Readiness
}

type ClusterAppConfig struct {
	Image           string       `yaml:"image"`
	ImagePullPolicy string       `yaml:"imagePullPolicy"`
	Command         []string     `yaml:"command"`
	Ports           []string     `yaml:"ports"`
	Environment     []*EnvVar    `yaml:"env,flow"`
	ReadinessProbe  *Probe       `yaml:"readinessProbe"`
	VolumeMount     *VolumeMount `yaml:"volumeMount"`
	Links           []string     `yaml:"links"`
	Resources       *Resources   `yaml:"resources"`
	IsSocket        bool         `yaml:"isSocket"`
}

type ClusterConfig struct {
	Setup     *Setup                       `yaml:"setup"`
	PostSetup *Setup                       `yaml:"postSetup"`
	Volumes   []*PersistentVolumeClaim     `yaml:"volumes"`
	Services  map[string]*ClusterAppConfig `yaml:"services"`
	Apps      map[string]*ClusterAppConfig `yaml:"apps"`
}

type Credentials interface {
	GetID() string
	GetSecret() string
}

type DB interface {
	NamedExec(query string, arg interface{}) (sql.Result, error)
	Get(dest interface{}, query string, args ...interface{}) error
	Select(dest interface{}, query string, args ...interface{}) error
}

type Deployment struct {
	Name            string
	Namespace       string
	Username        string
	Command         []string
	Image           string
	ImagePullPolicy string
	Ports           []int
	Environment     []*EnvVar
	ReadinessProbe  *Probe
	Volume          *VolumeMount
	Links           []*Deployment
	Resources       *Resources
}

type DeploymentReadiness struct{}

type EnvVar struct {
	Name  string `yaml:"name"`
	Value string `yaml:"value"`
}

type Job struct {
	Name        string
	Namespace   string
	Username    string
	Environment []*EnvVar
	Setup       *Setup
}

type JobReadiness struct{}

type MemoryAndCPUResource struct {
	CPU    string `yaml:"cpu"`
	Memory string `yaml:"memory"`
}

type MockCredentials struct {
	ID  string
	Key string
}

type OSCredentials struct{}

type PersistentVolumeClaim struct {
	Name      string `yaml:"name"`
	Storage   string `yaml:"storage"`
	Namespace string
}

type PortMap struct {
	Port       int
	TargetPort int
	Name       string
}

type Probe struct {
	Command       []string `yaml:"command"`
	PeriodSeconds int      `yaml:"periodSeconds"`
	//This timeout is different from the kubernetes object api timeoutSecond.
	//This timeout represents the total wait time until stop deployment initiation and rollback
	TimeoutSeconds int `yaml:"startDeploymentTimeoutSeconds"`
}

type Readiness interface {
	WaitForCompletion(kubernetes.Interface, interface{}) error
}

type Resources struct {
	Limits   *MemoryAndCPUResource `yaml:"limits"`
	Requests *MemoryAndCPUResource `yaml:"requests"`
}

type Service struct {
	Name         string
	Namespace    string
	Ports        []*PortMap
	IsMystackSvc bool
	SocketPorts  string
	IsSocket     bool
}

type Setup struct {
	Image           string    `yaml:"image"`
	ImagePullPolicy string    `yaml:"imagePullPolicy"`
	Command         []string  `yaml:"command"`
	PeriodSeconds   int       `yaml:"periodSeconds"`
	Environment     []*EnvVar `yaml:"env"`
	TimeoutSeconds  int       `yaml:"timeoutSeconds"`
}

type VolumeMount struct {
	Name      string `yaml:"name"`
	MountPath string `yaml:"mountPath"`
}