k8s

type Cluster interface {
	// UpdateCluster update the RedisCluster
	UpdateCluster(namespace string, cluster *redisv1beta1.RedisCluster) error
}

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

type ConfigMap interface {
	// GetConfigMap get ConfigMap from kubernetes with namespace and name
	GetConfigMap(namespace string, name string) (*corev1.ConfigMap, error)
	// CreateConfigMap create the given ConfigMap
	CreateConfigMap(namespace string, configMap *corev1.ConfigMap) error
	// UpdateConfigMap update the given ConfigMap
	UpdateConfigMap(namespace string, configMap *corev1.ConfigMap) error
	// CreateOrUpdateConfigMap if the ConfigMap Already exists, create it, otherwise update it
	CreateOrUpdateConfigMap(namespace string, np *corev1.ConfigMap) error
	// DeleteConfigMap delete ConfigMap from kubernetes with namespace and name
	DeleteConfigMap(namespace string, name string) error
	// ListConfigMaps get set of ConfigMaps on a given namespace
	ListConfigMaps(namespace string) (*corev1.ConfigMapList, error)
	CreateIfNotExistsConfigMap(namespace string, configMap *corev1.ConfigMap) error
}

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

type Deployment interface {
	// GetDeployment get deployment from kubernetes with namespace and name
	GetDeployment(namespace, name string) (*appsv1.Deployment, error)
	// GetDeploymentPods will retrieve the pods managed by a given deployment
	GetDeploymentPods(namespace, name string) (*corev1.PodList, error)
	// CreateDeployment will create the given deployment
	CreateDeployment(namespace string, deployment *appsv1.Deployment) error
	// UpdateDeployment will update the given deployment
	UpdateDeployment(namespace string, deployment *appsv1.Deployment) error
	// CreateOrUpdateDeployment will update the given deployment or create it if does not exist
	CreateOrUpdateDeployment(namespace string, deployment *appsv1.Deployment) error
	// DeleteDeployment will delete the given deployment
	DeleteDeployment(namespace string, name string) error
	// ListDeployments get set of deployment on a given namespace
	ListDeployments(namespace string) (*appsv1.DeploymentList, error)
}

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

type Event interface {
	// NewSlaveAdd event ClusterScaling
	NewSlaveAdd(object runtime.Object, message string)
	// SlaveRemove event ClusterScalingDown
	SlaveRemove(object runtime.Object, message string)
	// CreateCluster event ClusterCreating
	CreateCluster(object runtime.Object)
	// UpdateCluster event ClusterUpdating
	UpdateCluster(object runtime.Object, message string)
	// UpgradedCluster event ClusterUpgrading
	UpgradedCluster(object runtime.Object, message string)
	// EnsureCluster event Ensure
	EnsureCluster(object runtime.Object)
	// CheckCluster event CheckAndHeal
	CheckCluster(object runtime.Object)
	// FailedCluster event ClusterFailed
	FailedCluster(object runtime.Object, message string)
	// HealthCluster event ClusterHealthy
	HealthCluster(object runtime.Object)
}

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

type NameSpaces interface {
	// GetNameSpace get namespace info form kubernetes
	GetNameSpace(namespace string) (*corev1.Namespace, error)
}

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

type Pod interface {
	// GetPod get pod from kubernetes with namespace and name
	GetPod(namespace string, name string) (*corev1.Pod, error)
	// CreatePod will create the given pod
	CreatePod(namespace string, pod *corev1.Pod) error
	// UpdatePod will update the given pod
	UpdatePod(namespace string, pod *corev1.Pod) error
	// CreateOrUpdatePod will update the given pod or create it if does not exist
	CreateOrUpdatePod(namespace string, pod *corev1.Pod) error
	// DeletePod will delete the given pod
	DeletePod(namespace string, name string) error
	// ListPods get set of pod on a given namespace
	ListPods(namespace string) (*corev1.PodList, error)
}

type PodDisruptionBudget interface {
	// GetPodDisruptionBudget get podDisruptionBudget from kubernetes with namespace and name
	GetPodDisruptionBudget(namespace string, name string) (*policyv1beta1.PodDisruptionBudget, error)
	// CreatePodDisruptionBudget will create the given podDisruptionBudget
	CreatePodDisruptionBudget(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error
	// UpdatePodDisruptionBudget will update the given podDisruptionBudget
	UpdatePodDisruptionBudget(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error
	// CreateOrUpdatePodDisruptionBudget will update the given podDisruptionBudget or create it if does not exist
	CreateOrUpdatePodDisruptionBudget(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error
	// DeletePodDisruptionBudget will delete the given podDisruptionBudget
	DeletePodDisruptionBudget(namespace string, name string) error
	CreateIfNotExistsPodDisruptionBudget(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error
}

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

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

type Service interface {
	// GetService get service from kubernetes with namespace and name
	GetService(namespace string, name string) (*corev1.Service, error)
	// CreateService will create the given service
	CreateService(namespace string, service *corev1.Service) error
	//CreateIfNotExistsService create service if it does not exist
	CreateIfNotExistsService(namespace string, service *corev1.Service) error
	// UpdateService will update the given service
	UpdateService(namespace string, service *corev1.Service) error
	// CreateOrUpdateService will update the given service or create it if does not exist
	CreateOrUpdateService(namespace string, service *corev1.Service) error
	// DeleteService will delete the given service
	DeleteService(namespace string, name string) error
	// ListServices get set of service on a given namespace
	ListServices(namespace string) (*corev1.ServiceList, error)
}

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

type Services interface {
	ConfigMap
	Pod
	PodDisruptionBudget
	Service
	NameSpaces
	Deployment
	StatefulSet
	Cluster
}

type StatefulSet interface {
	// GetStatefulSet get StatefulSet from kubernetes with namespace and name
	GetStatefulSet(namespace, name string) (*appsv1.StatefulSet, error)
	// GetStatefulSetPods will retrieve the pods managed by a given StatefulSet
	GetStatefulSetPods(namespace, name string) (*corev1.PodList, error)
	// CreateStatefulSet will create the given StatefulSet
	CreateStatefulSet(namespace string, statefulSet *appsv1.StatefulSet) error
	// UpdateStatefulSet will update the given StatefulSet
	UpdateStatefulSet(namespace string, statefulSet *appsv1.StatefulSet) error
	// CreateOrUpdateStatefulSet will update the given StatefulSet or create it if does not exist
	CreateOrUpdateStatefulSet(namespace string, StatefulSet *appsv1.StatefulSet) error
	// DeleteStatefulSet will delete the given StatefulSet
	DeleteStatefulSet(namespace string, name string) error
	// ListStatefulSets get set of StatefulSet on a given namespace
	ListStatefulSets(namespace string) (*appsv1.StatefulSetList, error)
	CreateIfNotExistsStatefulSet(namespace string, statefulSet *appsv1.StatefulSet) error
}

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