rooty/yubikey-val
1
0
Fork 0
mirror of https://github.com/Yubico/yubikey-val.git synced 2025-02-08 03:54:20 +01:00
Code Issues Projects Releases Wiki Activity

Rewrote ykval-munin-queuelength plugin.

Browse Source 
- bring in line with ksm and val latency plugin.
This commit is contained in:
Jean Paul Galea 2015-09-08 17:10:31 +02:00
parent f566a75dcd
commit f2483a6ff9
1 changed files with 53 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

86
ykval-munin-queuelength.php
View File

@ -38,19 +38,37 @@ require_once 'ykval-config.php';
require_once 'ykval-db.php'; require_once 'ykval-db.php';
require_once 'ykval-common.php'; require_once 'ykval-common.php';
$urls = $baseParams['__YKVAL_SYNC_POOL__']; function get_db_counters()
$shortnames = array_map("shortname", $urls);
foreach($shortnames as $shortname)
{ {
if ($shortname === FALSE) $db = Db::GetDatabaseHandle($baseParams, 'ykval-munin-queuelength');
if (!$db->connect())
return false;
$result = $db->customQuery('
SELECT server,
COUNT(server) as count
FROM queue
GROUP BY server');
if ($result)
$result = $result->fetchAll(PDO::FETCH_ASSOC);
else
return false;
$counters = array();
foreach ($result as $row)
{ {
echo "Cannot parse URL from sync pool list\n"; $counters[$row['server']] = $row['count'];
exit(1);
} }
return $counters;
} }
if ($argc == 2 && strcmp($argv[1], "autoconf") == 0) $urls = $baseParams['__YKVAL_SYNC_POOL__'];
if ($argc == 2 && strcmp($argv[1], 'autoconf') == 0)
{ {
if (is_array($urls) && count($urls) > 0) if (is_array($urls) && count($urls) > 0)
{ {
@ -62,44 +80,46 @@ if ($argc == 2 && strcmp($argv[1], "autoconf") == 0)
exit(0); exit(0);
} }
if ($argc == 2 && strcmp($argv[1], "config") == 0) if (($endpoints = endpoints($urls)) === FALSE)
{
echo "Cannot parse URLs from sync pool list\n";
exit(1);
}
if ($argc == 2 && strcmp($argv[1], 'config') == 0)
{ {
echo "graph_title YK-VAL queue size\n"; echo "graph_title YK-VAL queue size\n";
echo "graph_vlabel sync requests in queue\n"; echo "graph_vlabel sync requests in queue\n";
echo "graph_category ykval\n"; echo "graph_category ykval\n";
foreach ($shortnames as $shortname) foreach ($endpoints as $endpoint)
{ {
echo "queuelength_${shortname}.label sync ${shortname}\n"; list ($internal, $label, $url) = $endpoint;
echo "queuelength_${shortname}.draw AREASTACK\n";
echo "queuelength_${shortname}.type GAUGE\n"; echo "${internal}_queuelength.label sync ${label}\n";
echo "${internal}_queuelength.draw AREASTACK\n";
echo "${internal}_queuelength.type GAUGE\n";
} }
exit(0); exit(0);
} }
$db = Db::GetDatabaseHandle($baseParams, 'ykval-munin-queuelength'); if (($counters = get_db_counters()) === FALSE)
if (!$db->connect())
logdie($myLog, 'ERROR Database connect error (1)');
$res = $db->customQuery('select server,count(server) as count from queue group by server');
if ($res)
$r = $res->fetchAll(PDO::FETCH_ASSOC);
else
logdie($myLog, 'ERROR getting data from db');
foreach ($shortnames as $shortname)
{ {
echo "Error fetching data from database\n";
exit(1);
}
foreach ($endpoints as $endpoint)
{
list ($internal, $label, $url) = $endpoint;
$count = 0; $count = 0;
foreach ($r as $result) if (array_key_exists($url, $counters))
{ $count = $counters[$url];
if (shortname($result['server']) === $shortname)
{
$count = $result['count'];
break;
}
}
echo "queuelength_${shortname}.value $count\n"; echo "${internal}_queuelength.value $count\n";
} }
exit(0);