notify func

Kong · Nov 29, 2024 · ec5d9b9 · ec5d9b9
1 parent 7f1acb1
commit ec5d9b9
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/kong/clustering/rpc/socket.lua b/kong/clustering/rpc/socket.lua
@@ -289,4 +289,16 @@ function _M:call(node_id, method, params, callback)
 end
 
 
+function _M:notify(node_id, method, params)
+  assert(node_id == self.node_id)
+
+  return self.outgoing:push({
+    jsonrpc = "2.0",
+    method = method,
+    params = params,
+    -- notification has no id
+  })
+end
+
+
 return _M