ReachableCEO
54cc5f7308
- Implements Apache APISIX packaging for Cloudron platform. - Includes Dockerfile, CloudronManifest.json, and start.sh. - Configured to use Cloudron's etcd addon. 🤖 Generated with Gemini CLI Co-Authored-By: Gemini <noreply@google.com>
291 lines
10 KiB
Perl
291 lines
10 KiB
Perl
# Licensed to the Apache Software Foundation (ASF) under one
|
|
# or more contributor license agreements. See the NOTICE file
|
|
# distributed with this work for additional information
|
|
# regarding copyright ownership. The ASF licenses this file
|
|
# to you under the Apache License, Version 2.0 (the
|
|
# "License"); you may not use this file except in compliance
|
|
# with the License. You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing,
|
|
# software distributed under the License is distributed on an
|
|
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
# KIND, either express or implied. See the License for the
|
|
# specific language governing permissions and limitations
|
|
# under the License.
|
|
BEGIN {
|
|
if ($ENV{TEST_EVENTS_MODULE} ne "lua-resty-events") {
|
|
$SkipReason = "Only for lua-resty-events events module";
|
|
}
|
|
}
|
|
use Test::Nginx::Socket::Lua $SkipReason ? (skip_all => $SkipReason) : ();
|
|
use t::APISIX 'no_plan';
|
|
|
|
log_level('info');
|
|
no_root_location();
|
|
|
|
run_tests();
|
|
|
|
__DATA__
|
|
|
|
=== TEST 1: create stream route with a upstream that enable active healthcheck only, \
|
|
two upstream nodes: one healthy + one unhealthy, unhealthy node with high priority
|
|
--- config
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin").test
|
|
local code, body = t('/apisix/admin/stream_routes/1',
|
|
ngx.HTTP_PUT,
|
|
[[{
|
|
"remote_addr": "127.0.0.1",
|
|
"upstream": {
|
|
"nodes": [
|
|
{ "host": "127.0.0.1", "port": 1995, "weight": 100, "priority": 0 },
|
|
{ "host": "127.0.0.1", "port": 9995, "weight": 100, "priority": 1 }
|
|
],
|
|
"type": "roundrobin",
|
|
"retries": 0,
|
|
"checks": {
|
|
"active": {
|
|
"type": "tcp",
|
|
"timeout": 1,
|
|
"healthy": {
|
|
"interval": 1,
|
|
"successes": 2
|
|
},
|
|
"unhealthy": {
|
|
"interval": 1,
|
|
"tcp_failures": 1,
|
|
"timeouts": 1
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}]]
|
|
)
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
end
|
|
ngx.say(body)
|
|
}
|
|
}
|
|
--- request
|
|
GET /t
|
|
--- response_body
|
|
passed
|
|
|
|
|
|
|
|
=== TEST 2: hit stream routes
|
|
--- stream_conf_enable
|
|
--- config
|
|
location /t {
|
|
content_by_lua_block {
|
|
-- send first request to create health checker
|
|
local sock = ngx.socket.tcp()
|
|
local ok, err = sock:connect("127.0.0.1", 1985)
|
|
if not ok then
|
|
ngx.say("failed to connect: ", err)
|
|
return
|
|
end
|
|
local data, _ = sock:receive()
|
|
assert(data == nil, "first request should fail")
|
|
sock:close()
|
|
|
|
-- wait for health check to take effect
|
|
ngx.sleep(2.5)
|
|
|
|
for i = 1, 3 do
|
|
local sock = ngx.socket.tcp()
|
|
local ok, err = sock:connect("127.0.0.1", 1985)
|
|
if not ok then
|
|
ngx.say("failed to connect: ", err)
|
|
return
|
|
end
|
|
|
|
local _, err = sock:send("mmm")
|
|
if err then
|
|
ngx.say("failed to send: ", err)
|
|
return
|
|
end
|
|
|
|
local data, err = sock:receive()
|
|
if err then
|
|
ngx.say("failed to receive: ", err)
|
|
return
|
|
end
|
|
|
|
assert(data == "hello world", "response should be 'hello world'")
|
|
|
|
sock:close()
|
|
end
|
|
|
|
local t = require("lib.test_admin").test
|
|
local code, body = t('/apisix/admin/stream_routes/1',
|
|
ngx.HTTP_DELETE
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
ngs.say("failed to delete stream route")
|
|
return
|
|
end
|
|
|
|
-- wait for checker to release
|
|
ngx.sleep(1)
|
|
|
|
ngx.say("passed")
|
|
}
|
|
}
|
|
--- timeout: 10
|
|
--- request
|
|
GET /t
|
|
--- response_body
|
|
passed
|
|
--- error_log
|
|
create new checker
|
|
proxy request to 127.0.0.1:9995 while connecting to upstream
|
|
connect() failed (111: Connection refused) while connecting to upstream, client: 127.0.0.1, server: 0.0.0.0:1985, upstream: "127.0.0.1:9995"
|
|
unhealthy TCP increment (1/1) for '127.0.0.1(127.0.0.1:9995)'
|
|
proxy request to 127.0.0.1:1995 while connecting to upstream
|
|
proxy request to 127.0.0.1:1995 while connecting to upstream
|
|
proxy request to 127.0.0.1:1995 while connecting to upstream
|
|
try to release checker
|
|
|
|
|
|
|
|
=== TEST 3: create stream route with a upstream that enable active and passive healthcheck, \
|
|
configure active healthcheck with a high unhealthy threshold, \
|
|
two upstream nodes: one healthy + one unhealthy, unhealthy node with high priority
|
|
--- config
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin").test
|
|
local code, body = t('/apisix/admin/stream_routes/1',
|
|
ngx.HTTP_PUT,
|
|
[[{
|
|
"remote_addr": "127.0.0.1",
|
|
"upstream": {
|
|
"nodes": [
|
|
{ "host": "127.0.0.1", "port": 1995, "weight": 100, "priority": 0 },
|
|
{ "host": "127.0.0.1", "port": 9995, "weight": 100, "priority": 1 }
|
|
],
|
|
"type": "roundrobin",
|
|
"retries": 0,
|
|
"checks": {
|
|
"active": {
|
|
"type": "tcp",
|
|
"timeout": 1,
|
|
"healthy": {
|
|
"interval": 60,
|
|
"successes": 2
|
|
},
|
|
"unhealthy": {
|
|
"interval": 1,
|
|
"tcp_failures": 254,
|
|
"timeouts": 1
|
|
}
|
|
},
|
|
"passive": {
|
|
"type": "tcp",
|
|
"healthy": {
|
|
"successes": 1
|
|
},
|
|
"unhealthy": {
|
|
"tcp_failures": 1
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}]]
|
|
)
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
end
|
|
ngx.say(body)
|
|
}
|
|
}
|
|
--- request
|
|
GET /t
|
|
--- response_body
|
|
passed
|
|
|
|
|
|
|
|
=== TEST 4: hit stream routes
|
|
--- stream_conf_enable
|
|
--- config
|
|
location /t {
|
|
content_by_lua_block {
|
|
local sock = ngx.socket.tcp()
|
|
local ok, err = sock:connect("127.0.0.1", 1985)
|
|
if not ok then
|
|
ngx.say("failed to connect: ", err)
|
|
return
|
|
end
|
|
local data, _ = sock:receive()
|
|
assert(data == nil, "first request should fail")
|
|
sock:close()
|
|
|
|
-- Due to the implementation of lua-resty-events, it relies on the kernel and
|
|
-- the Nginx event loop to process socket connections.
|
|
-- When lua-resty-healthcheck handles passive healthchecks and uses lua-resty-events
|
|
-- as the events module, the synchronization of the first event usually occurs
|
|
-- before the start of the passive healthcheck. So when the execution finishes and
|
|
-- healthchecker tries to record the healthcheck status, it will not be able to find
|
|
-- an existing target (because the synchronization event has not finished yet), which
|
|
-- will lead to some anomalies that deviate from the original test case, so compatibility
|
|
-- operations are performed here.
|
|
local sock = ngx.socket.tcp()
|
|
local ok, err = sock:connect("127.0.0.1", 1985)
|
|
if not ok then
|
|
ngx.say("failed to connect: ", err)
|
|
return
|
|
end
|
|
local data, _ = sock:receive()
|
|
assert(data == nil, "first request should fail")
|
|
sock:close()
|
|
|
|
for i = 1, 3 do
|
|
local sock = ngx.socket.tcp()
|
|
local ok, err = sock:connect("127.0.0.1", 1985)
|
|
if not ok then
|
|
ngx.say("failed to connect: ", err)
|
|
return
|
|
end
|
|
|
|
local _, err = sock:send("mmm")
|
|
if err then
|
|
ngx.say("failed to send: ", err)
|
|
return
|
|
end
|
|
|
|
local data, err = sock:receive()
|
|
if err then
|
|
ngx.say("failed to receive: ", err)
|
|
return
|
|
end
|
|
|
|
assert(data == "hello world", "response should be 'hello world'")
|
|
|
|
sock:close()
|
|
end
|
|
|
|
ngx.say("passed")
|
|
}
|
|
}
|
|
--- request
|
|
GET /t
|
|
--- response_body
|
|
passed
|
|
--- error_log
|
|
proxy request to 127.0.0.1:9995 while connecting to upstream
|
|
connect() failed (111: Connection refused) while connecting to upstream, client: 127.0.0.1, server: 0.0.0.0:1985, upstream: "127.0.0.1:9995"
|
|
enabled healthcheck passive while connecting to upstream, client: 127.0.0.1, server: 0.0.0.0:1985, upstream: "127.0.0.1:9995",
|
|
unhealthy TCP increment (1/1) for '(127.0.0.1:9995)' while connecting to upstream, client: 127.0.0.1, server: 0.0.0.0:1985, upstream: "127.0.0.1:9995",
|
|
proxy request to 127.0.0.1:1995 while connecting to upstream
|
|
proxy request to 127.0.0.1:1995 while connecting to upstream
|
|
proxy request to 127.0.0.1:1995 while connecting to upstream
|
|
--- timeout: 10
|