feat: support etcd range get

lib/resty/etcd/v3.lua

@@ -1286,6 +1286,7 @@ function _M.get(self, key, opts)
     end
 
     attr.timeout = opts and opts.timeout
+    attr.range_end = opts and opts.range_end
     return http_get(self, key, attr)
 end
 

t/v3/prefix.t

@@ -0,0 +1,129 @@
+use Test::Nginx::Socket::Lua;
+
+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';
+}
+
+add_block_preprocessor(sub {
+    my ($block) = @_;
+
+    if (!$block->main_config) {
+        $block->set_value("main_config", "thread_pool grpc-client-nginx-module threads=1;");
+    }
+
+    if (!$block->request) {
+        $block->set_value("request", "GET /t");
+    }
+
+    if ((!defined $block->error_log) && (!defined $block->no_error_log)) {
+        $block->set_value("no_error_log", "[error]");
+    }
+});
+
+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 and data.body.kvs==nil then
+                    ngx.exit(400)
+                end
+                if data and data.body.kvs and #data.body.kvs ~= 0 and
+                  ((#val == 0) or (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 == 0 and "[]" or val)
+                end
+            end
+
+            if status and status ~= data.status then
+                ngx.exit(data.status)
+            end
+        end
+    }
+_EOC_
+
+run_tests();
+
+__DATA__
+
+=== TEST 1: get with range_end
+--- http_config eval: $::HttpConfig
+--- config
+    location /t {
+        content_by_lua_block {
+            local etcd, err = require "resty.etcd" .new({protocol = "v3", use_grpc = false})
+            check_res(etcd, err)
+
+            etcd:set("/test/foo", "oof")
+            etcd:set("/test/bar", "rab")
+            etcd:set("/test/baz", "zab")
+
+            local data, err = etcd:get("/test", {range_end = "/tesu"})
+
+            for _, value in pairs(data.body.kvs) do
+                ngx.log(ngx.WARN, "key: ", value.key, " value: ", value.value)
+            end
+        }
+    }
+--- error_log
+key: /test/foo value: oof
+key: /test/bar value: rab
+key: /test/baz value: zab
+
+
+
+=== TEST 2: get without range_end
+--- http_config eval: $::HttpConfig
+--- config
+    location /t {
+        content_by_lua_block {
+            local etcd, err = require "resty.etcd" .new({protocol = "v3", use_grpc = false})
+            check_res(etcd, err)
+
+            etcd:set("/test/foo", "oof")
+            etcd:set("/test/bar", "rab")
+            etcd:set("/test/baz", "zab")
+
+            local data, err = etcd:get("/test")
+
+            for _, value in pairs(data.body.kvs or {}) do
+                ngx.log(ngx.WARN, "key: ", value.key, " value: ", value.value)
+            end
+
+            if not data.body.kvs then
+                ngx.say("passed")
+                ngx.exit(200)
+                return
+            end
+
+            ngx.say("failed")
+            ngx.exit(200)
+        }
+    }
+--- response_body
+passed
+--- no_error_log
+key: /test/foo value: oof
+key: /test/bar value: rab
+key: /test/baz value: zab