EVOLUTION-MANAGER

Edit File: redis_stats.lua

--
-- (C) 2013-20 - ntop.org
--

local dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
if((dirs.scriptdir ~= nil) and (dirs.scriptdir ~= "")) then package.path = dirs.scriptdir .. "/lua/modules/?.lua;" .. package.path end

require "lua_utils"
local page_utils = require("page_utils")
local alert_consts = require("alert_consts")
local plugins_utils = require("plugins_utils")
require("graph_utils")
require("alert_utils")

local charts_available = plugins_utils.timeseriesCreationEnabled()

if not isAllowedSystemInterface() then
   return
end

sendHTTPContentTypeHeader('text/html')

page_utils.set_active_menu_entry(page_utils.menu_entries.redis_monitor)

dofile(dirs.installdir .. "/scripts/lua/inc/menu.lua")

local page = _GET["page"] or "overview"
local url = plugins_utils.getUrl("redis_stats.lua") .. "?ifid=" .. getInterfaceId(ifname)

page_utils.print_navbar("Redis", url,
			{
			 {
			 active = page == "overview" or not page,
			 page_name = "overview",
			 label = "",
			 },
			 {
			 active = page == "stats",
			 page_name = "stats",
			 label = "",
			 },
			 {
			 hidden = not charts_available,
			 active = page == "historical",
			 page_name = "historical",
			 label = "",
			 },
			}
)

-- #######################################################

if(page == "overview") then
 local fa_external = ""
 local tags = {ifid=getSystemInterfaceId()}
 print("<table class=\"table table-bordered table-striped\">\n")

print("<tr><td nowrap width='30%'>".. i18n("system_stats.health") .." "..i18n("system_stats.redis.short_desc_redis_health").."</td><td></td><td><img class=\"redis-info-load\" border=0 src=".. ntop.getHttpPrefix() .. "/img/throbber.gif style=\"vertical-align:text-top;\" id=throbber></td></tr>\n")

print("<tr><td nowrap width='30%'>".. i18n("about.ram_memory") .." "..i18n("system_stats.redis.short_desc_redis_ram_memory").."</td>")
 print("<td class='text-center' width=5%>")
 print(ternary(charts_available, "<A HREF='"..url.."&page=historical&ts_schema=redis:memory'></A>", ""))
 print("</td><td><img class=\"redis-info-load\" border=0 src=".. ntop.getHttpPrefix() .. "/img/throbber.gif style=\"vertical-align:text-top;\" id=throbber></td></tr>\n")

print("<tr><td nowrap width='30%'>".. i18n("system_stats.redis.redis_keys") .." "..i18n("system_stats.redis.short_desc_redis_keys").."</td>")
 print("<td class='text-center' width=5%>")
 print(ternary(charts_available, "<A HREF='"..url.."&page=historical&ts_schema=redis:keys'></A>", ""))
 print("</td><td><img class=\"redis-info-load\" border=0 src=".. ntop.getHttpPrefix() .. "/img/throbber.gif style=\"vertical-align:text-top;\" id=throbber></td></tr>\n")

print[[<script>

var last_keys, last_memory
 var health_descr = {
]]
 print('"green" : {"status" : "'..i18n("system_stats.redis.redis_health_green")..'", "descr" : "'..i18n("system_stats.redis.redis_health_green_descr")..'"},')
 print('"red" : {"status" : "'..i18n("system_stats.redis.redis_health_red")..'", "descr" : "'..i18n("system_stats.redis.redis_health_red_descr", {product = ntop.getInfo()["product"]})..'"},')
 print[[
 };

function refreshRedisStats() {
  $.get("]] print(plugins_utils.getUrl("get_redis_info.lua")) print[[", function(info) {
     $(".redis-info-load").hide();

if(typeof info.health !== "undefined" && health_descr[info.health]) {
 $("#redis-health").html(health_descr[info.health]["status"] + " " + health_descr[info.health]["descr"]);
 }
 if(typeof info.dbsize !== "undefined") {
 $("#redis-info-keys").html(formatValue(info.dbsize) + " ");
 if(typeof last_keys !== "undefined")
	 $("#redis-info-keys").append(drawTrend(info.dbsize, last_keys));
 last_keys = info.dbsize;
 }
 if(typeof info.memory !== "undefined") {
 $("#redis-info-memory").html(bytesToVolume(info.memory) + " ");
 if(typeof last_memory !== "undefined")
	 $("#redis-info-memory").append(drawTrend(info.memory, last_memory));
 last_memory = info.memory;
 }
 }).fail(function() {
 $(".redis-info-load").hide();
 });
 }

setInterval(refreshRedisStats, 5000);
refreshRedisStats();
 </script>
 ]]
 print("</table>\n")
elseif(page == "stats") then

print [[
<div id="table-redis-stats"></div>
<script type='text/javascript'>

$("#table-redis-stats").datatable({
 title: "",
 perPage: 100,
 hidePerPage: true,
 url: "]] print(plugins_utils.getUrl("get_redis_stats.lua")) print(ntop.getHttpPrefix()) print[[",
 columns: [
 {
 field: "column_key",
 hidden: true,
 css: {
 width: '15%',
 }
 }, {
 field: "column_command",
 sortable: true,
 title: "]] print(i18n("please_wait_page.command")) print[[",
 css: {
 width: '15%',
 }
 }, {
 title: "]] print(i18n("chart")) print[[",
 field: "column_chart",
 hidden: ]] if not charts_available then print("true") else print("false") end print[[,
 sortable: false,
 css: {
 textAlign: 'center',
 width: '5%',
 }
 }, {
 title: "]] print(i18n("system_stats.redis.tot_calls")) print[[",
 field: "column_hits",
 sortable: true,
 css: {
 textAlign: 'right'
 }
 }
 ], tableCallback: function() {
 datatableInitRefreshRows($("#table-redis-stats"), "column_key", 5000, {"column_hits": addCommas});
 }
});
</script>
 ]]

elseif(page == "historical" and charts_available) then
   local ts_utils = require("ts_utils")
   local schema = _GET["ts_schema"] or "redis:memory"
   local selected_epoch = _GET["epoch"] or ""
   local tags = {ifid = getSystemInterfaceId(), command = _GET["redis_command"]}
   url = url.."&page=historical"

local timeseries = {
      {schema = "redis:memory", label = i18n("about.ram_memory")},
      {schema = "redis:keys", label = i18n("system_stats.redis.redis_keys")},
      {separator=1, label=i18n("system_stats.redis.commands")},
   }

-- Populate individual commands timeseries
   local series = ts_utils.listSeries("redis:hits", {ifid = getSystemInterfaceId()}, 0)

if(series) then
      for _, serie in pairsByField(series, "command", asc) do
          timeseries[#timeseries + 1] = {
             schema = "redis:hits",
             label = i18n("system_stats.redis.command_hits", {cmd = string.upper(string.sub(serie.command, 5))}),
             extra_params = {redis_command = serie.command},
             metrics_labels = {i18n("graphs.num_calls")},
          }
      end
   end

drawGraphs(getSystemInterfaceId(), schema, tags, _GET["zoom"], url, selected_epoch, {
       top_redis_hits = "top:redis:hits",
		 timeseries = timeseries,
   })
elseif((page == "alerts") and isAdministrator()) then
   local old_ifname = ifname
   interface.select(getSystemInterfaceId())

_GET["ifid"] = getSystemInterfaceId()
   -- _GET["entity"] = alert_consts.alertEntity("redis")

drawAlerts()

interface.select(old_ifname)
end

-- #######################################################

dofile(dirs.installdir .. "/scripts/lua/inc/footer.lua")