Mirrors/Munin-Contrib
1
0
Fork 0
mirror of https://github.com/munin-monitoring/contrib.git synced 2025-07-22 02:51:03 +00:00
Code Issues Releases Wiki Activity

Merge pull request #67 from apankov/plugin_redis_resque

Browse source 
adding new plugin for resque monitoring
This commit is contained in:
Kenyon Ralph 2012-03-14 18:15:23 -07:00
commit c398f857d9
1 changed files with 136 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

136
plugins/redis/resque Executable file
View file

@ -0,0 +1,136 @@
#!/usr/bin/perl
#
## Copyright (C) 2012 Andrey Pankov <a.pankov@gmail.com>
##
## This program is free software; you can redistribute it and/or
## modify it under the terms of the GNU General Public License
## as published by the Free Software Foundation; version 2 dated June,
## 1991.
##
## This program is distributed in the hope that it will be useful,
## but WITHOUT ANY WARRANTY; without even the implied warranty of
## MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
## GNU General Public License for more details.
##
## You should have received a copy of the GNU General Public License
## along with this program; if not, write to the Free Software
## Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
##
##
## $Log$
##
## Based on resque monitoring code from https://github.com/caius/redis-munin
##
## Installation process:
##
## 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
## 3. Edit plugin-conf.d/munin-node if it is needed (env.host and env.port variables are accepted)
## 4. Restart munin-node service
use strict;
use Redis;
my $HOST = exists $ENV{'host'} ? $ENV{'host'} : "127.0.0.1";
my $PORT = exists $ENV{'port'} ? $ENV{'port'} : 6379;
my $server = "$HOST:$PORT";
my $r = Redis->new( server => sprintf("%s:%d", $HOST, $PORT) );
my $config = ( defined $ARGV[0] and $ARGV[0] eq "config" );
$0 =~ s/(.+)resque_//g;
my $opt = $0 ? $0 : 'default';
if ($opt eq 'failed') {
if ($config) {
print "graph_title Resque Failure rate\n";
print "graph_category Resque\n";
print "graph_info This graph shows resque jobs that failed\n";
print "graph_args --lower-limit 0\n";
print 'graph_vlabel fails/s\n';
print "failed.label Failed per/s\n";
print "failed.type COUNTER\n";
}
else {
my $value = $r->get('resque:stat:failed') || 0;
print "failed.value $value\n";
}
}
elsif ($opt eq 'queues') {
if ($config) {
print "graph_title Resque queue rates\n";
print "graph_category Resque\n";
print "graph_vlabel queue rates/s\n";
print "graph_info This graph monitors the in and out rate of the queues\n";
print "graph_args --lower-limit 0\n";
my @queues = $r->smembers( 'resque:queues' );
for my $name (@queues) {
$name =~ s/:/_/;
print "${name}_pushed.label ${name}_pushed\n";
print "${name}_pushed.type COUNTER\n";
print "${name}_finished.label ${name}_finished\n";
print "${name}_finished.type COUNTER\n";
}
}
else {
my @queues = $r->smembers( 'resque:queues' );
for my $queue (@queues) {
my $name = $queue;
$name =~ s/:/_/;
my $pushed = $r->get("resque:stat:${queue}:pushed") || 0;
print "${name}_pushed.value ${pushed}\n";
my $finished = $r->get("resque:stat:${queue}:finished") || 0;
print "${name}_finished.value ${finished}\n";
}
}
}
elsif ($opt eq 'workers_count') {
if ($config) {
print "graph_title Resque Workers Count\n";
print "graph_category Resque\n";
print "graph_info This graph shows number of resque workers\n";
print "graph_args --lower-limit 0\n";
print "graph_vlabel workers\n";
print "workers_count.label No. of workers\n";
print "workers_count.type COUNTER\n";
}
else {
my @workers = $r->smembers('resque:workers');
print "workers_count.value " . (scalar @workers) . "\n";
}
}
elsif ($opt eq 'workers_working') {
if ($config) {
print "graph_title Resque Workers in use\n";
print "graph_category Resque\n";
print "graph_info This graph shows the \%age of resque workers busy\n";
print "graph_args --lower-limit 0 --upper-limit 100\n";
print "graph_vlabel %\n";
print "workers_working.label Workers Busy\n";
print "workers_working.type GAUGE\n";
}
else {
my @workers = $r->smembers('resque:workers');
my $working = 0;
for my $worker (@workers) {
my $value = $r->get("worker:$worker") || 0;
$working++ if $value;
}
my $value = scalar @workers;
if ($value) {
$value = $working * 100 / $value;
}
print "workers_working.value $value\n";
}
}