[WIP] feature: implement operation 'compact'

lib/resty/etcd/v3.lua

@@ -907,6 +907,22 @@ function _M.leases(self)
                         choose_endpoint(self).full_prefix .. "/lease/leases")
 end
 
+function _M.compact(self, revision, physical)
+    if revision == nil then
+        return nil, "compact command needs revision argument"
+    end
+
+    local opts = {
+        body = {
+            revision = revision,
+            physical = physical
+        },
+    }
+
+    return _request_uri(self, "POST",
+                        choose_endpoint(self).full_prefix .. "/kv/compaction", opts)
+end
+
 
 -- /version
 function _M.version(self)

t/v3/tmp.t

@@ -0,0 +1,93 @@
+use Test::Nginx::Socket::Lua;
+
+# "The entire event history can be watched starting from the\nlast compaction revision."
+# Need test on compaction
+
+log_level('info');
+no_long_string();
+repeat_each(1);
+
+my $etcd_version = `etcd --version`;
+if ($etcd_version =~ /^etcd Version: 2/ || $etcd_version =~ /^etcd Version: 3.1./) {
+    plan(skip_all => "etcd is too old, skip v3 protocol");
+} else {
+    plan 'no_plan';
+}
+
+our $HttpConfig = <<'_EOC_';
+    lua_socket_log_errors off;
+    lua_package_path 'lib/?.lua;/usr/local/share/lua/5.3/?.lua;/usr/share/lua/5.1/?.lua;;';
+    init_by_lua_block {
+        local cjson = require("cjson.safe")
+
+        function check_res(data, err, val, status)
+            if err then
+                ngx.say("err: ", err)
+                ngx.exit(200)
+            end
+
+            if val then
+                if data.body.kvs==nil then
+                    ngx.exit(404)
+                end
+                if data.body.kvs and val ~= data.body.kvs[1].value then
+                    ngx.say("failed to check value")
+                    ngx.log(ngx.ERR, "failed to check value, got: ", data.body.kvs[1].value,
+                            ", expect: ", val)
+                    ngx.exit(200)
+                else
+                    ngx.say("checked val as expect: ", val)
+                end
+            end
+
+            if status and status ~= data.status then
+                ngx.exit(data.status)
+            end
+        end
+    }
+_EOC_
+
+run_tests();
+
+__DATA__
+
+=== TEST 8: compact and get
+--- http_config eval: $::HttpConfig
+--- config
+    location /t {
+        content_by_lua_block {
+            local etcd, err = require "resty.etcd" .new({protocol = "v3"})
+            check_res(etcd, err)
+
+            local res1, err1 = etcd:set("/test1", "abc")
+            check_res(res1, err1)
+
+            local res2, err2 = etcd:set("/test2", "bcd")
+            check_res(res2, err2)
+
+            local data, err = etcd:get("/test1", {revision = res1.body.header.revision})
+            check_res(data, err, "abc")
+
+            local data, err = etcd:get("/test2", {revision = res2.body.header.revision})
+            check_res(data, err, "bcd")
+
+            local data, err = etcd:compact(res2.body.header.revision)
+            check_res(data, err)
+
+            local data, err = etcd:get("/test1", {revision = res1.body.header.revision})
+            --[[
+            check_res(data, err, nil, 400)
+
+            local data, err = etcd:get("/test2", {revision = res2.body.header.revision})
+            check_res(data, err, "bcd")
+            ]]--
+        }
+    }
+--- request
+GET /t
+--- no_error_log
+[error]
+--- response_body
+checked val as expect: abc
+checked val as expect: bcd
+checked val as expect: bcd