Skip to content

Commit 37867d5

Browse files
authored
fix: correct the previous test case. (#190)
1 parent dde58ac commit 37867d5

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

lib/resty/etcd/v3.lua

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1190,6 +1190,11 @@ function _M.setnx(self, key, val, opts)
11901190
success[1].request_put = {}
11911191
success[1].request_put.key = key
11921192

1193+
local err
1194+
val, err = serialize_grpc_value(self.serializer.serialize, val)
1195+
if not val then
1196+
return nil, "failed to encode val: " .. err
1197+
end
11931198
success[1].request_put.value = val
11941199
else
11951200
compare[1] = {}

t/v3/grpc/txn.t

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ checked val as expect: abc
129129
--- config
130130
location /t {
131131
content_by_lua_block {
132-
local etcd, err = require "resty.etcd" .new({protocol = "v3"})
132+
local etcd, err = require "resty.etcd" .new({protocol = "v3", use_grpc = true})
133133
check_res(etcd, err)
134134
135135
local res, err = etcd:delete("/setnx")
@@ -182,7 +182,7 @@ checked val as expect: aaa
182182
end
183183
end
184184
185-
local etcd, err = require "resty.etcd" .new({protocol = "v3", use_grpc = false})
185+
local etcd, err = require "resty.etcd" .new({protocol = "v3", use_grpc = true})
186186
check_res(etcd, err)
187187
188188
local res, err = etcd:set("/test", {k = "abc"})

0 commit comments

Comments
 (0)