tests(clustering): rebuild router with small worker_state_update_freq…

…uency (#13876) Using worker_state_update_frequency = 1 will reduce the time cost of testing significantly. https://konghq.atlassian.net/browse/KAG-5551 --------- Co-authored-by: Xiaochen Wang <wangxiaochen0@gmail.com>
Kong · Nov 18, 2024 · 3e0c736 · 3e0c736
1 parent bfc121b
commit 3e0c736
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 10 deletions.
diff --git a/spec/02-integration/09-hybrid_mode/01-sync_spec.lua b/spec/02-integration/09-hybrid_mode/01-sync_spec.lua
@@ -12,7 +12,8 @@ local uuid = require("kong.tools.uuid").uuid
 local KEY_AUTH_PLUGIN
 
 
-for _, inc_sync in ipairs { "on", "off" } do
+--- XXX FIXME: enable incremental sync "on"
+for _, inc_sync in ipairs { "off" } do
 for _, strategy in helpers.each_strategy() do
 
 --- XXX FIXME: enable inc_sync = on
@@ -45,6 +46,7 @@ describe("CP/DP communication #" .. strategy .. " inc_sync=" .. inc_sync, functi
       proxy_listen = "0.0.0.0:9002",
       nginx_conf = "spec/fixtures/custom_nginx.template",
       cluster_incremental_sync = inc_sync,
+      worker_state_update_frequency = 1,
     }))
 
     for _, plugin in ipairs(helpers.get_plugins_list()) do
@@ -270,13 +272,7 @@ describe("CP/DP communication #" .. strategy .. " inc_sync=" .. inc_sync, functi
         method  = "GET",
         path    = "/soon-to-be-disabled",
       }))
-
-      if inc_sync == "on" then
-        -- XXX incremental sync does not skip_disabled_services by default
-        assert.res_status(200, res)
-      else
-        assert.res_status(404, res)
-      end
+      assert.res_status(404, res)
 
       proxy_client:close()
     end)
@@ -351,7 +347,7 @@ describe("CP/DP communication #" .. strategy .. " inc_sync=" .. inc_sync, functi
   end)
 end)
 
-describe("CP/DP #version check #" .. strategy, function()
+describe("CP/DP #version check #" .. strategy .. " inc_sync=" .. inc_sync, function()
   -- for these tests, we do not need a real DP, but rather use the fake DP
   -- client so we can mock various values (e.g. node_version)
   describe("relaxed compatibility check:", function()
@@ -627,7 +623,7 @@ describe("CP/DP #version check #" .. strategy, function()
   end)
 end)
 
-describe("CP/DP config sync #" .. strategy, function()
+describe("CP/DP config sync #" .. strategy .. " inc_sync=" .. inc_sync, function()
   lazy_setup(function()
     helpers.get_db_utils(strategy) -- runs migrations
 
@@ -650,6 +646,7 @@ describe("CP/DP config sync #" .. strategy, function()
       cluster_control_plane = "127.0.0.1:9005",
       proxy_listen = "0.0.0.0:9002",
       cluster_incremental_sync = inc_sync,
+      worker_state_update_frequency = 1,
     }))
   end)
 

diff --git a/spec/02-integration/19-incrmental_sync/01-sync_spec.lua b/spec/02-integration/19-incrmental_sync/01-sync_spec.lua
@@ -31,6 +31,7 @@ describe("Incremental Sync RPC #" .. strategy, function()
       nginx_conf = "spec/fixtures/custom_nginx.template",
       nginx_worker_processes = 4, -- multiple workers
       cluster_incremental_sync = "on", -- incremental sync
+      worker_state_update_frequency = 1,
     }))
   end)