github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-11 21:12:07 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #115452 from my-git9/cleanup/sts

Browse Source 
Cleanup: modify some sentences about statefulset
This commit is contained in:
Kubernetes Prow Robot 2023-05-07 19:47:29 -07:00 committed by GitHub
commit a8e3344634
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/e2e/apps/statefulset.go
View File

@ -602,7 +602,7 @@ var _ = SIGDescribe("StatefulSet", func() {
}) })
framework.ExpectNoError(err) framework.ExpectNoError(err)
// Verify that statuful set will be scaled up in order. // Verify that stateful set will be scaled up in order.
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
var orderErr error var orderErr error
wg.Add(1) wg.Add(1)
@ -656,7 +656,7 @@ var _ = SIGDescribe("StatefulSet", func() {
}) })
framework.ExpectNoError(err) framework.ExpectNoError(err)
// Verify that statuful set will be scaled down in order. // Verify that stateful set will be scaled down in order.
wg.Add(1) wg.Add(1)
go func() { go func() {
defer ginkgo.GinkgoRecover() defer ginkgo.GinkgoRecover()
@ -1942,7 +1942,7 @@ func rollbackTest(ctx context.Context, c clientset.Interface, ns string, ss *app
} }
// confirmStatefulPodCount asserts that the current number of Pods in ss is count, waiting up to timeout for ss to // confirmStatefulPodCount asserts that the current number of Pods in ss is count, waiting up to timeout for ss to
// to scale to count. // scale to count.
func confirmStatefulPodCount(ctx context.Context, c clientset.Interface, count int, ss *appsv1.StatefulSet, timeout time.Duration, hard bool) { func confirmStatefulPodCount(ctx context.Context, c clientset.Interface, count int, ss *appsv1.StatefulSet, timeout time.Duration, hard bool) {
start := time.Now() start := time.Now()
deadline := start.Add(timeout) deadline := start.Add(timeout)
@ -2037,7 +2037,7 @@ func getStatefulSetPodNameAtIndex(index int, ss *appsv1.StatefulSet) string {
type updateStatefulSetFunc func(*appsv1.StatefulSet) type updateStatefulSetFunc func(*appsv1.StatefulSet)
// updateStatefulSetWithRetries updates statfulset template with retries. // updateStatefulSetWithRetries updates statefulset template with retries.
func updateStatefulSetWithRetries(ctx context.Context, c clientset.Interface, namespace, name string, applyUpdate updateStatefulSetFunc) (statefulSet *appsv1.StatefulSet, err error) { func updateStatefulSetWithRetries(ctx context.Context, c clientset.Interface, namespace, name string, applyUpdate updateStatefulSetFunc) (statefulSet *appsv1.StatefulSet, err error) {
statefulSets := c.AppsV1().StatefulSets(namespace) statefulSets := c.AppsV1().StatefulSets(namespace)
var updateErr error var updateErr error

2
test/integration/statefulset/statefulset_test.go
View File

@ -385,7 +385,7 @@ func TestStatefulSetStatusWithPodFail(t *testing.T) {
sts := newSTS("sts", ns.Name, 4) sts := newSTS("sts", ns.Name, 4)
_, err := c.AppsV1().StatefulSets(sts.Namespace).Create(ctx, sts, metav1.CreateOptions{}) _, err := c.AppsV1().StatefulSets(sts.Namespace).Create(ctx, sts, metav1.CreateOptions{})
if err != nil { if err != nil {
t.Fatalf("Could not create statefuleSet %s: %v", sts.Name, err) t.Fatalf("Could not create statefulSet %s: %v", sts.Name, err)
} }
wantReplicas := limitedPodNumber wantReplicas := limitedPodNumber