k8sutil

package

Go to main page

Versions in this module

v0

v0.2.4

May 22, 2020

v0.2.3

Apr 2, 2020

v0.2.2

Mar 26, 2020

v0.2.1

Mar 9, 2020

v0.2.0

Dec 18, 2019

Changes in this version

type IPodDisruptionBudgetControl

+ DeletePodDisruptionBudgetByName func(namespace, name string) error

+ 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

+ DeleteServiceByName func(namespace, name string) error

type IStatefulSetControl

+ DeleteStatefulSetByName func(namespace, name string) error

+ GetStatefulSetPodsByLabels func(namespace string, labels map[string]string) (*corev1.PodList, error)

+ ListStatefulSetByLabels func(namespace string, labels map[string]string) (*appsv1.StatefulSetList, error)

type PodDisruptionBudgetController

+ func (s *PodDisruptionBudgetController) DeletePodDisruptionBudgetByName(namespace, name string) error

v0.1.0

Dec 2, 2019

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

+ GetPodDisruptionBudget func(namespace, name string) (*policyv1beta1.PodDisruptionBudget, error)

+ UpdatePodDisruptionBudget func(*policyv1beta1.PodDisruptionBudget) error

+ func NewPodDisruptionBudgetController(client client.Client) IPodDisruptionBudgetControl

+ type IServiceControl interface

+ CreateService func(*corev1.Service) error

+ DeleteService func(*corev1.Service) 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

+ GetStatefulSet func(namespace, name string) (*appsv1.StatefulSet, error)

+ GetStatefulSetPods func(namespace, name string) (*corev1.PodList, 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) GetPodDisruptionBudget(namespace, name string) (*policyv1beta1.PodDisruptionBudget, error)

+ func (s *PodDisruptionBudgetController) UpdatePodDisruptionBudget(pb *policyv1beta1.PodDisruptionBudget) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL