rpc disconnected

Kong · Jan 3, 2025 · a14aec8 · a14aec8
1 parent e91b020
commit a14aec8
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/kong/clustering/services/sync/init.lua b/kong/clustering/services/sync/init.lua
@@ -86,6 +86,11 @@ function _M:init_worker()
     assert(self.rpc:sync_every(EACH_SYNC_DELAY))
 
   end, "clustering:jsonrpc", "connected")
+
+  -- if rpc is down we will also stop to sync
+  worker_events.register(function()
+    assert(self.rpc:sync_every(EACH_SYNC_DELAY), true)  -- stop timer
+  end, "clustering:jsonrpc", "disconnected")
 end