Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix: let etcd v3 read_watch handle the case where a chunk contains partial event or multiple events #154

Merged
merged 14 commits into from
Mar 3, 2022
Merged

fix: let etcd v3 read_watch handle the case where a chunk contains partial event or multiple events #154

Changes from 2 commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
eb21766
fix: let etcd v3 `read_watch` handle the case where a chunk contains …
nic-6443 Feb 18, 2022
de344ce
add test case
nic-6443 Feb 26, 2022
64ca04b
fix code format
nic-6443 Feb 26, 2022
77e8ef7
undo useless change
nic-6443 Feb 27, 2022
7b456db
drop support for etcd vesion < v3.4.0
nic-6443 Feb 27, 2022
0faf78c
resolve comments
nic-6443 Feb 27, 2022
a85dab8
Update lib/resty/etcd/v3.lua
nic-6443 Feb 28, 2022
d60dea1
revert useless changes
nic-6443 Mar 1, 2022
331449a
Merge branch 'fix-read-watch' of github.com:api7/lua-resty-etcd into …
nic-6443 Mar 1, 2022
3a58c08
fix
nic-6443 Mar 2, 2022
46b56dd
add more comments
nic-6443 Mar 2, 2022
f428a26
reformat
nic-6443 Mar 2, 2022
aca8a02
fix body initial value
nic-6443 Mar 2, 2022
bb20595
rename variable
nic-6443 Mar 2, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion lib/resty/etcd/v3.lua
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -726,7 +726,7 @@ local function request_chunk(self, method, path, opts, timeout)
for _, chunk in ipairs(chunks) do
body, err = decode_json(chunk)
if not body then
return nil, "failed to decode json body: " .. (err or " unkwon")
return nil, "failed to decode json body: " .. (err or " unknown")
elseif body.error and body.error.http_code >= 500 then
-- health_check retry should do nothing here
-- and let connection closed to create a new one
Expand Down