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
