Skip to content

Commit

Permalink
rebase mess correction
Browse files Browse the repository at this point in the history
  • Loading branch information
louiseschmidtgen committed Sep 25, 2024
1 parent a830d07 commit c077647
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 2 deletions.
11 changes: 10 additions & 1 deletion test/delete_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,16 @@ func TestDelete(t *testing.T) {
// Delete a key that does not exist
t.Run("NonExistentKeys", func(t *testing.T) {
g := NewWithT(t)
deleteKey(ctx, g, kine.client, "missingKey", 1)
key := "missing key"
rev := 0
resp, err := kine.client.Txn(ctx).
If(clientv3.Compare(clientv3.ModRevision(key), "=", rev)).
Then(clientv3.OpDelete(key)).
Else(clientv3.OpGet(key)).
Commit()

g.Expect(err).To(BeNil())
g.Expect(resp.Succeeded).To(BeFalse())
})

// Add a key, make sure it exists, then delete it, make sure it got deleted,
Expand Down
5 changes: 4 additions & 1 deletion test/get_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -99,8 +99,11 @@ func TestGet(t *testing.T) {
t.Run("FailNotFound", func(t *testing.T) {
g := NewWithT(t)
key := "testKeyFailNotFound"
value := "testValue"

rev := createKey(ctx, g, kine.client, key, value)
// Delete key
deleteKey(ctx, g, kine.client, key, 0)
deleteKey(ctx, g, kine.client, key, rev)

// Get key
resp, err := kine.client.Get(ctx, key, clientv3.WithRange(""))
Expand Down

0 comments on commit c077647

Please sign in to comment.