Annotation of /recepies/munin/plugins/gearman

#!/usr/bin/perl
use warnings;
use strict;

# 2012-05-27 Dobrica Pavlinusic <dpavlin@rot13.org>

use IO::Socket::INET;
use Data::Dump qw(dump);

my $arg = shift @ARGV;
$arg ||= '';

my $sock = IO::Socket::INET->new(
        PeerAddr => '127.0.0.1',
        PeerPort => 4730,
        Proto    => 'tcp'
) || die $1;

if ( $arg eq 'autoconf' ) {
        print $sock ? "yes\n" : "no\n";
        exit 0;
}

print $sock "STATUS\n";

my $stats;

while ( my $line = <$sock> ) {
        chomp $line;
#       warn "# [$line]\n";
        last if $line eq '.';
        next if $line =~ m/\t0$/; # ignore functions which don't have active workers
        my ( $name, $queued, $running, $workers ) = split(/\t/,$line,4);
        $stats->{queued}->{$name} = $queued;
        $stats->{running}->{$name} = $running;
        $stats->{workers}->{$name} = $workers;
}

if ( $arg eq 'config' ) {
        foreach my $multigraph ( keys %$stats ) {
                print "multigraph $multigraph\n";
                print "graph_category gearman\n";
                print "graph_title Gearman $multigraph\n";

                foreach my $name ( keys %{ $stats->{$multigraph} } ) {
                        my $label = $name;
                        $name =~ s/\W+/_/g;
                        print "$name.label $label\n";
                }
        }
} else {
        foreach my $multigraph ( keys %$stats ) {
                print "multigraph $multigraph\n";
                while ( my ($name,$value) = each %{ $stats->{$multigraph} } ) {
                        $name =~ s/\W+/_/g;
                        print "$name.value $value\n";
                }
        }
}

1	dpavlin	293	#!/usr/bin/perl
2			use warnings;
3			use strict;
4
5			# 2012-05-27 Dobrica Pavlinusic <dpavlin@rot13.org>
6
7			use IO::Socket::INET;
8			use Data::Dump qw(dump);
9
10			my $arg = shift @ARGV;
11			$arg \|\|= '';
12
13			my $sock = IO::Socket::INET->new(
14			PeerAddr => '127.0.0.1',
15			PeerPort => 4730,
16			Proto => 'tcp'
17			) \|\| die $1;
18
19			if ( $arg eq 'autoconf' ) {
20			print $sock ? "yes\n" : "no\n";
21			exit 0;
22			}
23
24			print $sock "STATUS\n";
25
26			my $stats;
27
28			while ( my $line = <$sock> ) {
29			chomp $line;
30			# warn "# [$line]\n";
31			last if $line eq '.';
32			next if $line =~ m/\t0$/; # ignore functions which don't have active workers
33			my ( $name, $queued, $running, $workers ) = split(/\t/,$line,4);
34			$stats->{queued}->{$name} = $queued;
35			$stats->{running}->{$name} = $running;
36			$stats->{workers}->{$name} = $workers;
37			}
38
39			if ( $arg eq 'config' ) {
40			foreach my $multigraph ( keys %$stats ) {
41			print "multigraph $multigraph\n";
42			print "graph_category gearman\n";
43			print "graph_title Gearman $multigraph\n";
44
45			foreach my $name ( keys %{ $stats->{$multigraph} } ) {
46	dpavlin	294	my $label = $name;
47	dpavlin	293	$name =~ s/\W+/_/g;
48	dpavlin	294	print "$name.label $label\n";
49	dpavlin	293	}
50			}
51			} else {
52			foreach my $multigraph ( keys %$stats ) {
53			print "multigraph $multigraph\n";
54			while ( my ($name,$value) = each %{ $stats->{$multigraph} } ) {
55			$name =~ s/\W+/_/g;
56			print "$name.value $value\n";
57			}
58			}
59			}
60