Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const StatefulPodTimeout + const StatefulSetPoll + const StatefulSetTimeout + func BreakHTTPProbe(c clientset.Interface, ss *appsv1.StatefulSet) error + func BreakPodHTTPProbe(ss *appsv1.StatefulSet, pod *v1.Pod) error + func CheckHostname(c clientset.Interface, ss *appsv1.StatefulSet) error + func CheckMount(c clientset.Interface, ss *appsv1.StatefulSet, mountPath string) error + func CheckServiceName(ss *appsv1.StatefulSet, expectedServiceName string) error + func CreateStatefulSet(c clientset.Interface, manifestPath, ns string) *appsv1.StatefulSet + func CreateStatefulSetService(name string, labels map[string]string) *v1.Service + func DeleteAllStatefulSets(c clientset.Interface, ns string) + func DeleteStatefulPodAtIndex(c clientset.Interface, index int, ss *appsv1.StatefulSet) + func ExecInStatefulPods(c clientset.Interface, ss *appsv1.StatefulSet, cmd string) error + func GetPodList(c clientset.Interface, ss *appsv1.StatefulSet) *v1.PodList + func GetStatefulSet(c clientset.Interface, namespace, name string) *appsv1.StatefulSet + func NewStatefulSet(name, ns, governingSvcName string, replicas int32, ...) *appsv1.StatefulSet + func NewStatefulSetPVC(name string) v1.PersistentVolumeClaim + func PauseNewPods(ss *appsv1.StatefulSet) + func Restart(c clientset.Interface, ss *appsv1.StatefulSet) + func RestoreHTTPProbe(c clientset.Interface, ss *appsv1.StatefulSet) error + func RestorePodHTTPProbe(ss *appsv1.StatefulSet, pod *v1.Pod) error + func ResumeNextPod(c clientset.Interface, ss *appsv1.StatefulSet) + func Saturate(c clientset.Interface, ss *appsv1.StatefulSet) + func Scale(c clientset.Interface, ss *appsv1.StatefulSet, count int32) (*appsv1.StatefulSet, error) + func SetHTTPProbe(ss *appsv1.StatefulSet) + func SortStatefulPods(pods *v1.PodList) + func UpdateReplicas(c clientset.Interface, ss *appsv1.StatefulSet, count int32) + func UpdateStatefulSetWithRetries(c clientset.Interface, namespace, name string, ...) (statefulSet *appsv1.StatefulSet, err error) + func VerifyPodAtIndex(c clientset.Interface, index int, ss *appsv1.StatefulSet, ...) + func WaitForPartitionedRollingUpdate(c clientset.Interface, set *appsv1.StatefulSet) (*appsv1.StatefulSet, *v1.PodList) + func WaitForPodNotReady(c clientset.Interface, set *appsv1.StatefulSet, podName string) (*appsv1.StatefulSet, *v1.PodList) + func WaitForPodReady(c clientset.Interface, set *appsv1.StatefulSet, podName string) (*appsv1.StatefulSet, *v1.PodList) + func WaitForRollingUpdate(c clientset.Interface, set *appsv1.StatefulSet) (*appsv1.StatefulSet, *v1.PodList) + func WaitForRunning(c clientset.Interface, numPodsRunning, numPodsReady int32, ...) + func WaitForRunningAndNotReady(c clientset.Interface, numStatefulPods int32, ss *appsv1.StatefulSet) + func WaitForRunningAndReady(c clientset.Interface, numStatefulPods int32, ss *appsv1.StatefulSet) + func WaitForState(c clientset.Interface, ss *appsv1.StatefulSet, ...) + func WaitForStatus(c clientset.Interface, set *appsv1.StatefulSet) *appsv1.StatefulSet + func WaitForStatusReadyReplicas(c clientset.Interface, ss *appsv1.StatefulSet, expectedReplicas int32) + func WaitForStatusReplicas(c clientset.Interface, ss *appsv1.StatefulSet, expectedReplicas int32) + type VerifyStatefulPodFunc func(*v1.Pod)