k8s

type ContainerSimple struct {
	Name string
	Envs map[string]string
}

type FabricateResult struct {
	Url string
	Env map[string]string
}

type K8Fabricator struct {
	KubernetesClient KubernetesClientCreator
	ConsulApi        consul.ConsulService
	Domain           string
}

type K8sClusterCredential struct {
	CLusterName    string `json:"cluster_name"`
	Server         string `json:"api_server"`
	Username       string `json:"username"`
	Password       string `json:"password"`
	ConsulEndpoint string `json:"consul_http_api"`
}

type K8sCreatorConnector struct {
	ApiVersion       string
	Server           string
	Username         string
	Password         string
	Client           *http.Client
	OrgQuota         int
	KubernetesClient KubernetesClientCreator
}

type K8sCreatorRest interface {
	DeleteCluster(org string) error
	GetCluster(org string) (int, K8sClusterCredential, error)
	GetOrCreateCluster(org string) (K8sClusterCredential, error)
	PostCluster(org string) (int, error)
	GetClusters() ([]K8sClusterCredential, error)
}

type K8sServiceInfo struct {
	ServiceId string   `json:"serviceId"`
	Org       string   `json:"org"`
	Space     string   `json:"space"`
	Name      string   `json:"name"`
	TapPublic bool     `json:"tapPublic"`
	Uri       []string `json:"uri"`
}

type KubernetesApi interface {
	FabricateService(creds K8sClusterCredential, space, cf_service_id, parameters string, ss state.StateService,
		component *catalog.KubernetesComponent) (FabricateResult, error)
	CheckKubernetesServiceHealthByServiceInstanceId(creds K8sClusterCredential, space, instance_id string) (bool, error)
	DeleteAllByServiceId(creds K8sClusterCredential, service_id string) error
	DeleteAllPersistentVolumeClaims(creds K8sClusterCredential) error
	GetAllPersistentVolumes(creds K8sClusterCredential) ([]api.PersistentVolume, error)
	GetAllPodsEnvsByServiceId(creds K8sClusterCredential, space, service_id string) ([]PodEnvs, error)
	GetServiceVisibility(creds K8sClusterCredential, org, space, service_id string) ([]K8sServiceInfo, error)
	GetServicesVisibility(creds K8sClusterCredential, org, space string) ([]K8sServiceInfo, error)
	GetServiceCredentials(creds K8sClusterCredential, space, service_id string) ([]ServiceCredential, error)
	GetServices(creds K8sClusterCredential, org string) ([]api.Service, error)
	GetQuota(creds K8sClusterCredential, space string) (*api.ResourceQuotaList, error)
	GetClusterWorkers(creds K8sClusterCredential) ([]string, error)
	GetPodsStateByServiceId(creds K8sClusterCredential, service_id string) ([]PodStatus, error)
	GetPodsStateForAllServices(creds K8sClusterCredential) (map[string][]PodStatus, error)
	SetServicePublicVisibilityByServiceId(creds K8sClusterCredential, org, space, service_id string, shouldBePublic bool) ([]K8sServiceInfo, error)
	ListReplicationControllers(creds K8sClusterCredential) (*api.ReplicationControllerList, error)
	GetSecret(creds K8sClusterCredential, key string) (*api.Secret, error)
	CreateSecret(creds K8sClusterCredential, secret api.Secret) error
	DeleteSecret(creds K8sClusterCredential, key string) error
	UpdateSecret(creds K8sClusterCredential, secret api.Secret) error
}

type KubernetesClient interface {
	ReplicationControllers(namespace string) k8sClient.ReplicationControllerInterface
	Nodes() k8sClient.NodeInterface
	Events(namespace string) k8sClient.EventInterface
	Endpoints(namespace string) k8sClient.EndpointsInterface
	Pods(namespace string) k8sClient.PodInterface
	PodTemplates(namespace string) k8sClient.PodTemplateInterface
	Services(namespace string) k8sClient.ServiceInterface
	LimitRanges(namespace string) k8sClient.LimitRangeInterface
	ResourceQuotas(namespace string) k8sClient.ResourceQuotaInterface
	ServiceAccounts(namespace string) k8sClient.ServiceAccountsInterface
	Secrets(namespace string) k8sClient.SecretsInterface
	Namespaces() k8sClient.NamespaceInterface
	PersistentVolumes() k8sClient.PersistentVolumeInterface
	PersistentVolumeClaims(namespace string) k8sClient.PersistentVolumeClaimInterface
	ComponentStatuses() k8sClient.ComponentStatusInterface
	ConfigMaps(namespace string) k8sClient.ConfigMapsInterface
}

type KubernetesClientCreator interface {
	GetNewClient(creds K8sClusterCredential) (KubernetesClient, error)
}

type KubernetesRestCreator struct {
}

type KubernetesTestAdvancedParams struct {
	Verb            string
	Resource        string
	ResponceObjects []runtime.Object
}

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

type PodEnvs struct {
	RcName     string
	Containers []ContainerSimple
}

type PodStatus struct {
	PodName       string
	ServiceId     string
	Status        api.PodPhase
	StatusMessage string
}

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

type ReplicationControllerManager interface {
	DeleteAll(selector labels.Selector) error
	UpdateReplicasNumber(name string, count int) error
	Create(replicationController *api.ReplicationController) (*api.ReplicationController, error)
	List(selector labels.Selector) (*api.ReplicationControllerList, error)
}

type ServiceCredential struct {
	Name  string
	Host  string
	Ports []api.ServicePort
}