util

Documentation

Index

• func NoResyncPeriodFunc() time.Duration
• func PatchPod(kubeClient kubernetes.Interface, oldData *corev1.Pod, newData *corev1.Pod) (*corev1.Pod, error)
• func PatchStatefulSet(kubeClient kubernetes.Interface, oldData *appsv1beta1.StatefulSet, ...) (*appsv1beta1.StatefulSet, error)
• func UpdatePod(kubeClient kubernetes.Interface, newData *corev1.Pod) (*corev1.Pod, error)
• func UpdateStatefulSet(kubeClient kubernetes.Interface, newData *appsv1beta1.StatefulSet) (*appsv1beta1.StatefulSet, error)
• func WaitForCacheSync(controllerName string, stopCh <-chan struct{}, ...) bool

Functions

func NoResyncPeriodFunc

func NoResyncPeriodFunc() time.Duration

NoResyncPeriodFunc Returns 0 for resyncPeriod in case resyncing is not needed. See: github.com/kubernetes/kubernetes/pkg/controller/controller_utils.go

func PatchPod

func PatchPod(kubeClient kubernetes.Interface, oldData *corev1.Pod, newData *corev1.Pod) (*corev1.Pod, error)

PatchPod perform a direct patch update for the specified Pod.

func PatchStatefulSet

func PatchStatefulSet(kubeClient kubernetes.Interface, oldData *appsv1beta1.StatefulSet, newData *appsv1beta1.StatefulSet) (*appsv1beta1.StatefulSet, error)

PatchStatefulSet performs a direct patch update for the specified StatefulSet.

func UpdatePod

func UpdatePod(kubeClient kubernetes.Interface, newData *corev1.Pod) (*corev1.Pod, error)

UpdatePod performs a direct update for the specified Pod.

func UpdateStatefulSet

func UpdateStatefulSet(kubeClient kubernetes.Interface, newData *appsv1beta1.StatefulSet) (*appsv1beta1.StatefulSet, error)

UpdateStatefulSet performs a direct update for the specified StatefulSet.

func WaitForCacheSync

func WaitForCacheSync(controllerName string, stopCh <-chan struct{}, cacheSyncs ...cache.InformerSynced) bool

WaitForCacheSync is a wrapper around cache.WaitForCacheSync that generates log messages indicating that the controller identified by controllerName is waiting for syncs, followed by either a successful or failed sync.