Contents 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	#!/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	my $label = $name;
47	$name =~ s/\W+/_/g;
48	print "$name.label $label\n";
49	}
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