provision

type Cluster struct {
	Name        string            `json:"name"`
	Addresses   []string          `json:"addresses"`
	Provisioner string            `json:"provisioner"`
	CaCert      []byte            `json:"cacert"`
	ClientCert  []byte            `json:"clientcert"`
	ClientKey   []byte            `json:"clientkey"`
	Pools       []string          `json:"pools"`
	CustomData  map[string]string `json:"custom_data"`
	Local       bool              `json:"local"`
	Default     bool              `json:"default"`
	KubeConfig  *KubeConfig       `json:"kubeConfig,omitempty"`
	HTTPProxy   string            `json:"httpProxy,omitempty"`

	Writer io.Writer `json:"-"`
}

type ClusterHelpInfo struct {
	ProvisionerHelp string            `json:"provisioner_help"`
	CustomDataHelp  map[string]string `json:"custom_data_help"`
}

type ClusterService interface {
	Create(context.Context, Cluster) error
	Update(context.Context, Cluster) error
	List(context.Context) ([]Cluster, error)
	FindByName(context.Context, string) (*Cluster, error)
	FindByProvisioner(context.Context, string) ([]Cluster, error)
	FindByPool(ctx context.Context, provisioner, pool string) (*Cluster, error)
	FindByPools(ctx context.Context, provisioner string, pools []string) (map[string]Cluster, error)
	Delete(context.Context, Cluster) error
}

type ClusterStorage interface {
	Upsert(context.Context, Cluster) error
	FindAll(context.Context) ([]Cluster, error)
	FindByName(context.Context, string) (*Cluster, error)
	FindByProvisioner(context.Context, string) ([]Cluster, error)
	FindByPool(context.Context, string, string) (*Cluster, error)
	Delete(context.Context, Cluster) error
}

type DeployKind string

type DeployOptions interface {
	GetKind() (kind DeployKind)
}

type KubeConfig struct {
	Cluster  clientcmdapi.Cluster  `json:"cluster"`
	AuthInfo clientcmdapi.AuthInfo `json:"user"`
}

type MockClusterService struct {
	OnCreate            func(Cluster) error
	OnUpdate            func(Cluster) error
	OnList              func() ([]Cluster, error)
	OnFindByName        func(string) (*Cluster, error)
	OnFindByProvisioner func(string) ([]Cluster, error)
	OnFindByPool        func(string, string) (*Cluster, error)
	OnFindByPools       func(string, []string) (map[string]Cluster, error)
	OnDelete            func(Cluster) error
}

type MockClusterStorage struct {
	OnUpsert            func(Cluster) error
	OnFindAll           func() ([]Cluster, error)
	OnFindByName        func(string) (*Cluster, error)
	OnFindByProvisioner func(string) ([]Cluster, error)
	OnFindByPool        func(string, string) (*Cluster, error)
	OnDelete            func(Cluster) error
}

type MockPoolService struct {
	OnList       func() ([]Pool, error)
	OnFindByName func(string) (*Pool, error)
	OnServices   func(pool string) ([]string, error)
}

type MockPoolStorage struct {
	OnFindAll    func() ([]Pool, error)
	OnFindByName func(string) (*Pool, error)
}

type Pool struct {
	Name        string `bson:"_id"`
	Provisioner string
	Default     bool
}

type PoolService interface {
	List(ctx context.Context) ([]Pool, error)
	FindByName(ctx context.Context, name string) (*Pool, error)
	Services(ctx context.Context, pool string) ([]string, error)
}

type PoolStorage interface {
	FindAll(ctx context.Context) ([]Pool, error)
	FindByName(ctx context.Context, name string) (*Pool, error)
}

type TsuruYamlData struct {
	Hooks       *TsuruYamlHooks            `json:"hooks,omitempty" bson:",omitempty"`
	Healthcheck *TsuruYamlHealthcheck      `json:"healthcheck,omitempty" bson:",omitempty"`
	Kubernetes  *TsuruYamlKubernetesConfig `json:"kubernetes,omitempty" bson:",omitempty"`
}

type TsuruYamlHealthcheck struct {
	Path                 string            `json:"path"`
	Method               string            `json:"method"`
	Status               int               `json:"status"`
	Scheme               string            `json:"scheme"`
	Command              []string          `json:"command,omitempty" bson:",omitempty"`
	Headers              map[string]string `json:"headers,omitempty" bson:",omitempty"`
	Match                string            `json:"match,omitempty" bson:",omitempty"`
	RouterBody           string            `json:"router_body,omitempty" yaml:"router_body" bson:"router_body,omitempty"`
	UseInRouter          bool              `json:"use_in_router,omitempty" yaml:"use_in_router" bson:"use_in_router,omitempty"`
	ForceRestart         bool              `json:"force_restart,omitempty" yaml:"force_restart" bson:"force_restart,omitempty"`
	AllowedFailures      int               `json:"allowed_failures,omitempty" yaml:"allowed_failures" bson:"allowed_failures,omitempty"`
	IntervalSeconds      int               `json:"interval_seconds,omitempty" yaml:"interval_seconds" bson:"interval_seconds,omitempty"`
	TimeoutSeconds       int               `json:"timeout_seconds,omitempty" yaml:"timeout_seconds" bson:"timeout_seconds,omitempty"`
	DeployTimeoutSeconds int               `json:"deploy_timeout_seconds,omitempty" yaml:"deploy_timeout_seconds" bson:"deploy_timeout_seconds,omitempty"`
}

type TsuruYamlHooks struct {
	Restart TsuruYamlRestartHooks `json:"restart" bson:",omitempty"`
	Build   []string              `json:"build" bson:",omitempty"`
}

type TsuruYamlKubernetesConfig struct {
	Groups map[string]TsuruYamlKubernetesGroup `json:"groups,omitempty"`
}

type TsuruYamlKubernetesGroup map[string]TsuruYamlKubernetesProcessConfig

type TsuruYamlKubernetesProcessConfig struct {
	Ports []TsuruYamlKubernetesProcessPortConfig `json:"ports"`
}

type TsuruYamlKubernetesProcessPortConfig struct {
	Name       string `json:"name,omitempty"`
	Protocol   string `json:"protocol,omitempty"`
	Port       int    `json:"port,omitempty"`
	TargetPort int    `json:"target_port,omitempty"`
}

type TsuruYamlRestartHooks struct {
	Before []string `json:"before" bson:",omitempty"`
	After  []string `json:"after" bson:",omitempty"`
}