Documentation
¶
Index ¶
- func EnsureHPA(kubeClient kubernetes.Interface, hpa *autoscalingv2.HorizontalPodAutoscaler) error
- func NeedUpdateSts(oldSts, newSts *appsv1.StatefulSet) ([]byte, bool, error)
- func PatchConfigMap(kubeClient kubernetes.Interface, oldCM, newCM *corev1.ConfigMap) error
- func PatchDeployment(kubeClient kubernetes.Interface, oldDeploy, newDeploy *appsv1.Deployment) error
- func PatchHPA(kubeClient kubernetes.Interface, ...) error
- func PatchService(kubeClient kubernetes.Interface, oldSVC, newSVC *corev1.Service) error
- func PatchServiceAccount(kubeClient kubernetes.Interface, oldSA, newSA *corev1.ServiceAccount) error
- func PatchStatefulSet(kubeClient kubernetes.Interface, oldSts, newSts *appsv1.StatefulSet) (*appsv1.StatefulSet, error)
- func RemoveHPA(kubClient kubernetes.Interface, hpa *autoscalingv2.HorizontalPodAutoscaler) error
- func SyncConfigMap(kubeClient kubernetes.Interface, cm *corev1.ConfigMap) error
- func SyncDeployment(kubeClient kubernetes.Interface, deploy *appsv1.Deployment) error
- func SyncDeployments(kubeClient kubernetes.Interface, deployments []*appsv1.Deployment) error
- func SyncHPA(kubeClient kubernetes.Interface, hpa *autoscalingv2.HorizontalPodAutoscaler, ...) error
- func SyncService(kubeClient kubernetes.Interface, svc *corev1.Service) error
- func SyncServiceAccount(kubeClient kubernetes.Interface, sa *corev1.ServiceAccount) error
- func SyncServices(kubeClient kubernetes.Interface, services []*corev1.Service) error
- func SyncStatefulSet(kubeClient kubernetes.Interface, sts *appsv1.StatefulSet, overwrite bool) (oldSts, newSts *appsv1.StatefulSet, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnsureHPA ¶
func EnsureHPA(kubeClient kubernetes.Interface, hpa *autoscalingv2.HorizontalPodAutoscaler) error
EnsureHPA ensures the hpa object with expected data.
func NeedUpdateSts ¶
func NeedUpdateSts(oldSts, newSts *appsv1.StatefulSet) ([]byte, bool, error)
NeedUpdateSts returns whether we need to update the statefulSet.
func PatchConfigMap ¶
func PatchConfigMap(kubeClient kubernetes.Interface, oldCM, newCM *corev1.ConfigMap) error
PatchConfigMap patches the old configMap to new configMap.
func PatchDeployment ¶
func PatchDeployment(kubeClient kubernetes.Interface, oldDeploy, newDeploy *appsv1.Deployment) error
PatchDeployment patches the old deployment to new deployment.
func PatchHPA ¶
func PatchHPA(kubeClient kubernetes.Interface, oldHPA, newHPA *autoscalingv2.HorizontalPodAutoscaler) error
PatchHPA patches the old hpa to new hpa.
func PatchService ¶
func PatchService(kubeClient kubernetes.Interface, oldSVC, newSVC *corev1.Service) error
PatchService patches the old service to new service.
func PatchServiceAccount ¶
func PatchServiceAccount(kubeClient kubernetes.Interface, oldSA, newSA *corev1.ServiceAccount) error
PatchServiceAccount patches the old serviceAccount to new serviceAccount.
func PatchStatefulSet ¶
func PatchStatefulSet(kubeClient kubernetes.Interface, oldSts, newSts *appsv1.StatefulSet) (*appsv1.StatefulSet, error)
PatchStatefulSet patches the old statefulSet to new statefulSet.
func RemoveHPA ¶
func RemoveHPA(kubClient kubernetes.Interface, hpa *autoscalingv2.HorizontalPodAutoscaler) error
RemoveHPA removes the hpa object.
func SyncConfigMap ¶
func SyncConfigMap(kubeClient kubernetes.Interface, cm *corev1.ConfigMap) error
SyncConfigMap synchronizes configMap object.
func SyncDeployment ¶
func SyncDeployment(kubeClient kubernetes.Interface, deploy *appsv1.Deployment) error
SyncDeployment synchronizes deployment object.
func SyncDeployments ¶
func SyncDeployments(kubeClient kubernetes.Interface, deployments []*appsv1.Deployment) error
SyncDeployments synchronizes deployment objects.
func SyncHPA ¶
func SyncHPA(kubeClient kubernetes.Interface, hpa *autoscalingv2.HorizontalPodAutoscaler, enable bool) error
SyncHPA synchronizes a hpa object.
func SyncService ¶
func SyncService(kubeClient kubernetes.Interface, svc *corev1.Service) error
SyncService synchronizes service object.
func SyncServiceAccount ¶
func SyncServiceAccount(kubeClient kubernetes.Interface, sa *corev1.ServiceAccount) error
SyncServiceAccount synchronizes serviceAccount object.
func SyncServices ¶
func SyncServices(kubeClient kubernetes.Interface, services []*corev1.Service) error
SyncServices synchronizes service objects.
func SyncStatefulSet ¶
func SyncStatefulSet(kubeClient kubernetes.Interface, sts *appsv1.StatefulSet, overwrite bool) (oldSts, newSts *appsv1.StatefulSet, err error)
SyncStatefulSet synchronizes statefulSet object and returns original and patched object.
Types ¶
This section is empty.
Source Files