Robot/contrib-munin
2
0
Fork 0
mirror of https://github.com/munin-monitoring/contrib.git synced 2018-11-08 00:59:34 +01:00
Code Issues Releases Wiki Activity

Merge pull request #137 from ftopia/extend_resque_with_namespace_and_queues_size

Browse Source 
define namespace for resque plugin
This commit is contained in:
Kenyon Ralph 2012-06-27 11:54:56 -07:00
commit a08c69ef8d
1 changed files with 47 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
plugins/redis/resque
View File

@ -25,8 +25,8 @@
## Installation process: ## Installation process:
## ##
## 1. Download the plugin to your plugins directory (e.g. /usr/share/munin/plugins) ## 1. Download the plugin to your plugins directory (e.g. /usr/share/munin/plugins)
## 2. Create 4 symlinks at the directory that is used by munin for plugins detection (e.g. /etc/munin/plugins): resque_failed, resque_queues, resque_workers_count, resque_workers_working ## 2. Create 5 symlinks at the directory that is used by munin for plugins detection (e.g. /etc/munin/plugins): resque_failed, resque_queues, resque_queues_size, resque_workers_count, resque_workers_working
## 3. Edit plugin-conf.d/munin-node if it is needed (env.host and env.port variables are accepted) ## 3. Edit plugin-conf.d/munin-node if it is needed (env.namespace, env.host and env.port variables are accepted)
## 4. Restart munin-node service ## 4. Restart munin-node service
use strict; use strict;
@ -34,6 +34,7 @@ use Redis;
my $HOST = exists $ENV{'host'} ? $ENV{'host'} : "127.0.0.1"; my $HOST = exists $ENV{'host'} ? $ENV{'host'} : "127.0.0.1";
my $PORT = exists $ENV{'port'} ? $ENV{'port'} : 6379; my $PORT = exists $ENV{'port'} ? $ENV{'port'} : 6379;
my $NAMESPACE = exists $ENV{'namespace'} ? "resque:${ENV{'namespace'}}" : 'resque';
my $server = "$HOST:$PORT"; my $server = "$HOST:$PORT";
my $r = Redis->new( server => sprintf("%s:%d", $HOST, $PORT) ); my $r = Redis->new( server => sprintf("%s:%d", $HOST, $PORT) );
@ -56,7 +57,7 @@ if ($opt eq 'failed') {
print "failed.type COUNTER\n"; print "failed.type COUNTER\n";
} }
else { else {
my $value = $r->get('resque:stat:failed') || 0; my $value = $r->get("${NAMESPACE}:stat:failed") || 0;
print "failed.value $value\n"; print "failed.value $value\n";
} }
} }
@ -68,7 +69,7 @@ elsif ($opt eq 'queues') {
print "graph_info This graph monitors the in and out rate of the queues\n"; print "graph_info This graph monitors the in and out rate of the queues\n";
print "graph_args --lower-limit 0\n"; print "graph_args --lower-limit 0\n";
my @queues = $r->smembers( 'resque:queues' ); my @queues = $r->smembers( "${NAMESPACE}:queues" );
for my $name (@queues) { for my $name (@queues) {
$name =~ s/:/_/; $name =~ s/:/_/;
@ -80,19 +81,55 @@ elsif ($opt eq 'queues') {
} }
} }
else { else {
my @queues = $r->smembers( 'resque:queues' ); my @queues = $r->smembers( "${NAMESPACE}:queues" );
for my $queue (@queues) { for my $queue (@queues) {
my $name = $queue; my $name = $queue;
$name =~ s/:/_/; $name =~ s/:/_/;
my $pushed = $r->get("resque:stat:${queue}:pushed") || 0; my $pushed = $r->get("${NAMESPACE}:stat:${queue}:pushed") || 0;
print "${name}_pushed.value ${pushed}\n"; print "${name}_pushed.value ${pushed}\n";
my $finished = $r->get("resque:stat:${queue}:finished") || 0; my $finished = $r->get("${NAMESPACE}:stat:${queue}:finished") || 0;
print "${name}_finished.value ${finished}\n"; print "${name}_finished.value ${finished}\n";
} }
} }
} }
elsif ($opt eq 'queues_size') {
if ($config) {
print "graph_title Resque queue current size\n";
print "graph_category Resque\n";
print "graph_vlabel queue size\n";
print "graph_info This graph monitors the current queues size\n";
print "graph_args --lower-limit 0\n";
my @queues = $r->smembers( "${NAMESPACE}:queues" );
for my $name (@queues) {
$name =~ s/:/_/;
print "${name}_size.label ${name}_size\n";
print "${name}_size.type GAUGE\n";
}
print "total.label total\n";
print "total.type GAUGE\n";
}
else {
my @queues = $r->smembers( "${NAMESPACE}:queues" );
my $total = 0;
for my $queue (@queues) {
my $name = $queue;
$name =~ s/:/_/;
my $size = $r->llen("${NAMESPACE}:queue:${queue}") || 0;
$total += $size;
print "${name}_size.value ${size}\n";
}
print "total.value ${total}\n";
}
}
elsif ($opt eq 'workers_count') { elsif ($opt eq 'workers_count') {
if ($config) { if ($config) {
print "graph_title Resque Workers Count\n"; print "graph_title Resque Workers Count\n";
@ -105,7 +142,7 @@ elsif ($opt eq 'workers_count') {
print "workers_count.type COUNTER\n"; print "workers_count.type COUNTER\n";
} }
else { else {
my @workers = $r->smembers('resque:workers'); my @workers = $r->smembers("${NAMESPACE}:workers");
print "workers_count.value " . (scalar @workers) . "\n"; print "workers_count.value " . (scalar @workers) . "\n";
} }
} }
@ -121,10 +158,10 @@ elsif ($opt eq 'workers_working') {
print "workers_working.type GAUGE\n"; print "workers_working.type GAUGE\n";
} }
else { else {
my @workers = $r->smembers('resque:workers'); my @workers = $r->smembers("${NAMESPACE}:workers");
my $working = 0; my $working = 0;
for my $worker (@workers) { for my $worker (@workers) {
my $value = $r->get("worker:$worker") || 0; my $value = $r->get("${NAMESPACE}:worker:$worker") || 0;
$working++ if $value; $working++ if $value;
} }
my $value = scalar @workers; my $value = scalar @workers;