Skip to main content
Version: 7.2405.x.x LTS

Liveness and readiness probes

If you want to test the readiness and the liveness of nevisProxy, you can use the Lua filter (LuaFilter). The sample code in the following code block illustrates how to configure two Lua filters for livenes or readiness probes within nevisProxy. The name of the two configured Lua filters is LivenessLuaFilter and ReadinessLuaFilter.

You find this example in the delivered nevisproxy package under: /opt/nevisproxy/examples/various/LuaFilter_liveness_and_readiness_probe.example

Readiness and Liveness Probes with the LuaFilter

<filter>
<filter-name>LivenessLuaFilter</filter-name>
<filter-class>ch::nevis::isiweb4::filter::lua::LuaFilter</filter-class>
<init-param>
<param-name>Script.InputHeaderFunctionName</param-name>
<param-value>inputHeaders</param-value>
</init-param>
<init-param>
<param-name>Script</param-name>
<param-value>
function inputHeaders(req, resp)
resp:setHeader("Content-Type", "application/json")
resp:setBody("{ \"status\" : \"UP\" }")
resp:send(200)
end
</param-value>
</init-param>
</filter>

<filter>
<filter-name>ReadinessLuaFilter</filter-name>
<filter-class>ch::nevis::isiweb4::filter::lua::LuaFilter</filter-class>
<init-param>
<param-name>Script.InputHeaderFunctionName</param-name>
<param-value>inputHeaders</param-value>
</init-param>
<init-param>
<param-name>Script</param-name>
<param-value>
package.path = package.path .. ";@PKG_VAR@/@PKG_INSTANCE@/lib/?.lua"
local GlobalStore = require "GlobalStore"
local databaseServlets = { "MySQLSessionStoreServlet1", "MySQLSessionStoreServlet2" }
local databasePingName = "DatabasePing"
local backendsServlets = { "HttpConnectorServlet1", "HttpConnectorServlet2" }
function testDatabaseServlets(req)
local tracer = req:getTracer()
local ret = true

for i,servlet in ipairs(databaseServlets) do
tracer:debug("Testing servlet '" .. servlet .. "'")
local store = GlobalStore:new(servlet)
local value = store:get(databasePingName)
if not value then
store:set(databasePingName, "OK", 3600)
value = store:get(databasePingName)
end
if value ~= "OK" then
tracer:error("The servlet '" .. servlet .. "' seems to be down")
ret = false;
else
tracer:debug("Servlet '" .. servlet .. "' is up and running")
end
end
return ret
end
function testBackends(req)
local tracer = req:getTracer()
local ret = true

for i,servlet in ipairs(backendsServlets) do
tracer:debug("Testing servlet '" .. servlet .. "'")
local pingRequest = nevis.filter.lua.request.new()
pingRequest:setRequestUri("/ping")
pingRequest:setMethod("GET")
local pingResponse = nevis.filter.lua.response.new()
local dispatcher = req:getDispatcher(servlet)
dispatcher:forward(pingRequest, pingResponse)
local pingStatusCode = pingResponse:getStatus()
if pingStatusCode ~= 200 then
tracer:error("The servlet '" .. servlet .. "' seems to be down")
ret = false;
else
tracer:debug("Servlet '" .. servlet .. "' is up and running")
end
end
return ret
end
function inputHeaders(req, resp)
local tracer = req:getTracer()
local dbReady
local dbackendReady

if pcall(function()
dbReady = testDatabaseServlets(req)
dbackendReady = testBackends(req)
end)
then
resp:setHeader("Content-Type", "application/json")
if not dbReady then
resp:setBody("{ \"status\" : \"DOWN\" }")
resp:send(503)
elseif not dbackendReady then
resp:setBody("{ \"status\" : \"DOWN\" }")
resp:send(503)
else
resp:setBody("{ \"status\" : \"UP\" }")
resp:send(200)
end
else
tracer:notice("An exception occured")
resp:setHeader("Content-Type", "application/json")
resp:setBody("{ \"status\" : \"DOWN\" }")
resp:send(503)
end
end
</param-value>
</init-param>
</filter>

  • The LivenessLuaFilter returns the status code "200" to the frontend if the proxy is alive. If the LivenessLuaFilter is not triggered, the proxy is not alive.
  • The ReadinessLuaFilter returns the status code "200" if the configured backends and the MySQLSessionStoreServlet (in the LuaFilter) are up and running ("ready").

In the sample code, the ReadinessLuaFilter first checks the MySQLSessionStoreServlets "MySQLSessionStoreServlet1" and "MySQLSessionStoreServlet2" by trying to add an entry to both servlets. To avoid too many update calls, the entry is added once per hour. The ReadinessLuaFilter also checks the HttpConnectorServlets "HttpConnectorServlet1" and "HttpConnectorServlet2", by calling the URL "/ping". Note that "/ping" is just an example. The correct URL depends on the backend itself.

To map both LuaFilters to a URL, and to ensure that the proxy will process the requests, you can place a DefaultServlet at the end of the filter chain. This servlet will never be reached, but this is no problem, as the LuaFilters will in any case send an answer to the frontend.