add test case

Author: jizhuozhi

t/discovery/consul.t

@@ -849,3 +849,138 @@ location /sleep {
 ]
 --- no_error_log
 [error]
+
+
+
+=== TEST 17: dynamic etcd update with consul discovery (metadata_match)
+--- yaml_config eval: $::yaml_config
+--- apisix_yaml
+# 保持初始为空，由 /add 动态创建
+#END
+--- config
+location /v1/agent {
+    proxy_pass http://127.0.0.1:8500;
+}
+location /add {
+    content_by_lua_block {
+        local t = require("lib.test_admin").test
+        local code, body = t('/apisix/admin/routes/1001',
+            ngx.HTTP_PUT,
+            [[{
+                "uri": "/*",
+                "upstream": {
+                    "service_name": "service-b",
+                    "type": "roundrobin",
+                    "discovery_type": "consul",
+                    "discovery_args": {
+                        "metadata_match": {
+                            "version": ["v2", "v3"]
+                        }
+                    }
+                }
+            }]],
+            nil
+        )
+        ngx.status = code
+        ngx.say(body)
+    }
+}
+location /update {
+    content_by_lua_block {
+        local t = require("lib.test_admin").test
+        local code, body = t('/apisix/admin/routes/1001',
+            ngx.HTTP_PUT,
+            [[{
+                "uri": "/*",
+                "upstream": {
+                    "service_name": "service-b",
+                    "type": "roundrobin",
+                    "discovery_type": "consul",
+                    "discovery_args": {
+                        "metadata_match": {
+                            "version": ["v3"]
+                        }
+                    }
+                }
+            }]],
+            nil
+        )
+        ngx.status = code
+        ngx.say(body)
+    }
+}
+location /delete {
+    content_by_lua_block {
+        local t = require("lib.test_admin").test
+        local code, body = t('/apisix/admin/routes/1001', ngx.HTTP_DELETE)
+        ngx.status = code
+        ngx.say(body)
+    }
+}
+location /sleep {
+    content_by_lua_block {
+        ngx.sleep(1)
+        ngx.say("ok")
+    }
+}
+--- timeout: 10
+--- pipelined_requests eval
+[
+    # 1. 注册服务实例（四个版本）
+    "PUT /v1/agent/service/register\n" . "{\"ID\":\"service-b1\",\"Name\":\"service-b\",\"Address\":\"127.0.0.1\",\"Port\":30611,\"Meta\":{\"version\":\"v1\"}}",
+    "PUT /v1/agent/service/register\n" . "{\"ID\":\"service-b2\",\"Name\":\"service-b\",\"Address\":\"127.0.0.1\",\"Port\":30612,\"Meta\":{\"version\":\"v2\"}}",
+    "PUT /v1/agent/service/register\n" . "{\"ID\":\"service-b3\",\"Name\":\"service-b\",\"Address\":\"127.0.0.1\",\"Port\":30613,\"Meta\":{\"version\":\"v3\"}}",
+    "PUT /v1/agent/service/register\n" . "{\"ID\":\"service-b4\",\"Name\":\"service-b\",\"Address\":\"127.0.0.1\",\"Port\":30614,\"Meta\":{\"version\":\"v4\"}}",
+
+    "GET /sleep",
+
+    "GET /add",
+    "GET /hello?first",
+    "GET /hello?second",
+
+    "GET /update",
+    "GET /hello?updated",
+
+    "GET /delete",
+    "GET /hello?deleted",
+
+    "PUT /v1/agent/service/deregister/service-b1",
+    "PUT /v1/agent/service/deregister/service-b2",
+    "PUT /v1/agent/service/deregister/service-b3",
+    "PUT /v1/agent/service/deregister/service-b4"
+]
+--- response_body_like eval
+[
+    qr//,
+    qr//,
+    qr//,
+    qr//,
+
+    qr/ok\n/,
+
+    qr/passed\n/,
+    qr/[2-3]/,
+    qr/[2-3]/,
+
+    qr/passed\n/,
+    qr/3/,
+
+    qr/passed\n/,
+    qr/404 Route Not Found/,
+
+    qr//,
+    qr//,
+    qr//,
+    qr//
+]
+--- error_code eval
+[
+    200,200,200,200,
+    200,
+    201,200,200,
+    200,200,
+    200,404,
+    200,200,200,200
+]
+--- no_error_log
+[error]