Versions in this module Expand all Collapse all v0 v0.0.2 Mar 15, 2023 Changes in this version + func CreateSecret(client client.Client, secret *corev1.Secret, logger logr.Logger) error + func IsRequestRetryable(err error) bool + type ConfigMapController struct + func (s *ConfigMapController) CreateConfigMap(cm *corev1.ConfigMap) error + func (s *ConfigMapController) DeleteConfigMap(cm *corev1.ConfigMap) error + func (s *ConfigMapController) GetConfigMap(namespace, name string) (*corev1.ConfigMap, error) + func (s *ConfigMapController) UpdateConfigMap(cm *corev1.ConfigMap) error + type IConfigMapControl interface + CreateConfigMap func(*corev1.ConfigMap) error + DeleteConfigMap func(*corev1.ConfigMap) error + GetConfigMap func(namespace, name string) (*corev1.ConfigMap, error) + UpdateConfigMap func(*corev1.ConfigMap) error + func NewConfigMapController(client client.Client) IConfigMapControl + type ICustomResource interface + GetDistributedRedisCluster func(namespace, name string) (*redisv1alpha1.DistributedRedisCluster, error) + GetRedisClusterBackup func(namespace, name string) (*redisv1alpha1.RedisClusterBackup, error) + UpdateCR func(runtime.Object) error + UpdateCRStatus func(runtime.Object) error + func NewCRControl(client client.Client) ICustomResource + type IJobControl interface + CreateJob func(*batchv1.Job) error + DeleteJob func(*batchv1.Job) error + GetJob func(namespace, name string) (*batchv1.Job, error) + ListJobByLabels func(namespace string, labs client.MatchingLabels) (*batchv1.JobList, error) + UpdateJob func(*batchv1.Job) error + func NewJobController(client client.Client) IJobControl + type IPodControl interface + CreatePod func(*corev1.Pod) error + DeletePod func(*corev1.Pod) error + DeletePodByName func(namespace, name string) error + GetPod func(namespace, name string) (*corev1.Pod, error) + UpdatePod func(*corev1.Pod) error + func NewPodController(client client.Client) IPodControl + type IPodDisruptionBudgetControl interface + CreatePodDisruptionBudget func(*policyv1beta1.PodDisruptionBudget) error + DeletePodDisruptionBudget func(*policyv1beta1.PodDisruptionBudget) error + DeletePodDisruptionBudgetByName func(namespace, name string) error + GetPodDisruptionBudget func(namespace, name string) (*policyv1beta1.PodDisruptionBudget, error) + UpdatePodDisruptionBudget func(*policyv1beta1.PodDisruptionBudget) error + func NewPodDisruptionBudgetController(client client.Client) IPodDisruptionBudgetControl + type IPvcControl interface + DeletePvc func(claim *corev1.PersistentVolumeClaim) error + DeletePvcByLabels func(namespace string, labels map[string]string) error + GetPvc func(namespace, name string) (*corev1.PersistentVolumeClaim, error) + func NewPvcController(client client.Client) IPvcControl + type IServiceControl interface + CreateService func(*corev1.Service) error + DeleteService func(*corev1.Service) error + DeleteServiceByName func(namespace, name string) error + GetService func(namespace, name string) (*corev1.Service, error) + UpdateService func(*corev1.Service) error + func NewServiceController(client client.Client) IServiceControl + type IStatefulSetControl interface + CreateStatefulSet func(*appsv1.StatefulSet) error + DeleteStatefulSet func(*appsv1.StatefulSet) error + DeleteStatefulSetByName func(namespace, name string) error + GetStatefulSet func(namespace, name string) (*appsv1.StatefulSet, error) + GetStatefulSetPods func(namespace, name string) (*corev1.PodList, error) + GetStatefulSetPodsByLabels func(namespace string, labels map[string]string) (*corev1.PodList, error) + ListStatefulSetByLabels func(namespace string, labels map[string]string) (*appsv1.StatefulSetList, error) + UpdateStatefulSet func(*appsv1.StatefulSet) error + func NewStatefulSetController(client client.Client) IStatefulSetControl + type JobController struct + func (j *JobController) CreateJob(job *batchv1.Job) error + func (j *JobController) DeleteJob(job *batchv1.Job) error + func (j *JobController) GetJob(namespace, name string) (*batchv1.Job, error) + func (j *JobController) ListJobByLabels(namespace string, labs client.MatchingLabels) (*batchv1.JobList, error) + func (j *JobController) UpdateJob(job *batchv1.Job) error + type PodController struct + func (p *PodController) CreatePod(pod *corev1.Pod) error + func (p *PodController) DeletePod(pod *corev1.Pod) error + func (p *PodController) DeletePodByName(namespace, name string) error + func (p *PodController) GetPod(namespace, name string) (*corev1.Pod, error) + func (p *PodController) UpdatePod(pod *corev1.Pod) error + type PodDisruptionBudgetController struct + func (s *PodDisruptionBudgetController) CreatePodDisruptionBudget(pb *policyv1beta1.PodDisruptionBudget) error + func (s *PodDisruptionBudgetController) DeletePodDisruptionBudget(pb *policyv1beta1.PodDisruptionBudget) error + func (s *PodDisruptionBudgetController) DeletePodDisruptionBudgetByName(namespace, name string) error + func (s *PodDisruptionBudgetController) GetPodDisruptionBudget(namespace, name string) (*policyv1beta1.PodDisruptionBudget, error) + func (s *PodDisruptionBudgetController) UpdatePodDisruptionBudget(pb *policyv1beta1.PodDisruptionBudget) error