[apisix] branch master updated: test(clickhouse-logger): to show that different endpoints will be chosen randomly (#8777)

[monkeydluffy]

This is an automated email from the ASF dual-hosted git repository.

monkeydluffy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/apisix.git


The following commit(s) were added to refs/heads/master by this push:
     new f1d4168e3 test(clickhouse-logger): to show that different endpoints 
will be chosen randomly (#8777)
f1d4168e3 is described below

commit f1d4168e33a5e2de26055c004c35b8284e5517d2
Author: xiaoxuanzi <xiaoxi...@gmail.com>
AuthorDate: Fri Oct 27 12:02:25 2023 +0800

    test(clickhouse-logger): to show that different endpoints will be chosen 
randomly (#8777)
---
 t/plugin/clickhouse-logger.t | 41 +++++++++++++++++++++++++++++++++++++----
 1 file changed, 37 insertions(+), 4 deletions(-)

diff --git a/t/plugin/clickhouse-logger.t b/t/plugin/clickhouse-logger.t
index 43ce54cd8..4efcf11e3 100644
--- a/t/plugin/clickhouse-logger.t
+++ b/t/plugin/clickhouse-logger.t
@@ -187,7 +187,9 @@ passed
                                 "database": "default",
                                 "logtable": "test",
                                 "endpoint_addrs": ["http://127.0.0.1:8123";,
-                                                  "http://127.0.0.1:8124";]
+                                                  "http://127.0.0.1:8124";],
+                                "batch_max_size":1,
+                                "inactive_timeout":1
                             }
                         },
                         "upstream": {
@@ -229,7 +231,38 @@ echo "select * from default.test" | curl 
'http://localhost:8124/' --data-binary
 
 
 
-=== TEST 8: use single clickhouse server
+=== TEST 8: to show that different endpoints will be chosen randomly
+--- config
+    location /t {
+        content_by_lua_block {
+            local code_count = {}
+            local t = require("lib.test_admin").test
+            for i = 1, 12 do
+                local code, body = t('/opentracing', ngx.HTTP_GET)
+                if code ~= 200 then
+                    ngx.say("code: ", code, " body: ", body)
+                end
+                code_count[code] = (code_count[code] or 0) + 1
+            end
+
+            local code_arr = {}
+            for code, count in pairs(code_count) do
+                table.insert(code_arr, {code = code, count = count})
+            end
+
+            ngx.say(require("toolkit.json").encode(code_arr))
+            ngx.exit(200)
+        }
+    }
+--- response_body
+[{"code":200,"count":12}]
+--- error_log
+sending a batch logs to http://127.0.0.1:8123
+sending a batch logs to http://127.0.0.1:8124
+
+
+
+=== TEST 9: use single clickhouse server
 --- config
     location /t {
         content_by_lua_block {
@@ -267,7 +300,7 @@ passed
 
 
 
-=== TEST 9: hit route
+=== TEST 10: hit route
 --- request
 GET /opentracing
 --- error_code: 200
@@ -275,7 +308,7 @@ GET /opentracing
 
 
 
-=== TEST 10: get log
+=== TEST 11: get log
 --- exec
 echo "select * from default.test" | curl 'http://localhost:8123/' 
--data-binary @-
 --- response_body_like