Skip to content

Commit fe3b9f4

Browse files
committed
update testDeleteWithResourceVersion
1 parent 4ddc198 commit fe3b9f4

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/helpers.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -228,8 +228,8 @@ func NewUIDPreconditions(uid string) *Preconditions {
228228
return &Preconditions{UID: &u}
229229
}
230230

231-
// NewPreconditionDeleteOptionsWithResourceVersion returns a DeleteOptions with a ResourceVersion precondition set.
232-
func NewPreconditionDeleteOptionsWithResourceVersion(rv string) *DeleteOptions {
231+
// NewRVDeletionPrecondition returns a DeleteOptions with a ResourceVersion precondition set.
232+
func NewRVDeletionPrecondition(rv string) *DeleteOptions {
233233
p := Preconditions{ResourceVersion: &rv}
234234
return &DeleteOptions{Preconditions: &p}
235235
}

staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -921,13 +921,15 @@ func (t *Tester) testDeleteWithResourceVersion(obj runtime.Object, createFn Crea
921921
if err := createFn(ctx, foo); err != nil {
922922
t.Errorf("unexpected error: %v", err)
923923
}
924-
opts.Preconditions = metav1.NewPreconditionDeleteOptionsWithResourceVersion("RV1111").Preconditions
925-
obj, _, err := t.storage.(rest.GracefulDeleter).Delete(ctx, objectMeta.GetName(), &opts)
924+
opts.Preconditions = metav1.NewRVDeletionPrecondition("RV1111").Preconditions
925+
obj, wasDeleted, err := t.storage.(rest.GracefulDeleter).Delete(ctx, objectMeta.GetName(), &opts)
926926
if err == nil || !errors.IsConflict(err) {
927927
t.Errorf("unexpected error: %v", err)
928928
}
929-
930-
obj, _, err = t.storage.(rest.GracefulDeleter).Delete(ctx, objectMeta.GetName(), metav1.NewPreconditionDeleteOptionsWithResourceVersion("RV0000"))
929+
if wasDeleted {
930+
t.Errorf("unexpected, object %s should not have been deleted immediately", objectMeta.GetName())
931+
}
932+
obj, _, err = t.storage.(rest.GracefulDeleter).Delete(ctx, objectMeta.GetName(), metav1.NewRVDeletionPrecondition("RV0000"))
931933
if err != nil {
932934
t.Errorf("unexpected error: %v", err)
933935
}

0 commit comments

Comments
 (0)