#!/usr/bin/perl # # Parameters supported: # # config # autoconf # # Configurable variables # # url - Override default status-url # # Must be symlinked to what the graph should monitor. Run with --suggest # to see valid targets - or just run munin-node-configure --shell # # Written by Bjo"rn Ruberg 2006-2007 # # Magic markers: #%# family=auto #%# capabilities=autoconf suggest my $ret = undef; if (!eval "require LWP::UserAgent;") { $ret = "LWP::UserAgent not found"; } # watch-list exists on localhost # watch-info does not my %plugs = ( 'bytes' => 'Input/output (bytes)', 'requests' => 'Requests', 'documents' => 'Documents served', ); my $URL = exists $ENV{'url'} ? $ENV{'url'} : "http://localhost:%d/watch-list"; my @PORTS = exists $ENV{'ports'} ? split(' ', $ENV{'ports'}) : (80); my $type = "throughput"; if (exists $ARGV[0] and $ARGV[0] eq "autoconf") { if ($ret) { print "no ($ret)\n"; exit 1; } my $ua = LWP::UserAgent->new (timeout => 30); my @badports; foreach my $port (@PORTS) { my $url = sprintf $URL, $port; my $response = $ua->request (HTTP::Request->new('GET', $url)); push @badports, $port unless $response->is_success; } if (@badports) { print "no (no mod_watch exists on ports @badports)\n"; exit 1; } else { print "yes\n"; exit 0; } } if (exists $ARGV[0] and $ARGV[0] eq "suggest") { while (my ($key, undef) = each %plugs) { print "$key\n"; } exit 0; } my @servers = (); my @data; foreach my $port (@PORTS) { my $ua = LWP::UserAgent->new (timeout => 30); my $url = sprintf $URL, $port; my $response = $ua->request (HTTP::Request->new ('GET', $url)); foreach my $string (split (/\n/, $response->content)) { my ($server, undef, $ifInOctets, $ifOutOctets, $ifRequests, $ifDocuments) = split (/\s/, $string, 6); push @servers, $server unless $server eq "SERVER"; push @data, "$server $ifInOctets $ifOutOctets $ifRequests $ifDocuments" unless $server eq "SERVER"; } } # From here and out, the plugin must be run with a symlinked service. my $check = join ("|", keys %plugs); die ("Plugin must be symlinked to aspect to be monitored") unless $0 =~ /\_($check)$/; my $action = $1; if (exists $ARGV[0] and $ARGV[0] eq "config") { print "graph_title Apache $plugs{$action}\n"; print "graph_args --base 1000 -l 0\n"; print "graph_category apache\n"; print "graph_vlabel activity\n"; my $i = 0; foreach my $server (sort (@servers)) { (my $txtserver = $server) =~ s/(-|\.)/\_/g; my $draw = ($i==0) ? 'AREA' : 'STACK'; if ($action eq "bytes") { print "${txtserver}.label $server\n"; print "${txtserver}.draw $draw\n"; print "${txtserver}.type COUNTER\n"; } else { print "${txtserver}.label $server\n"; print "${txtserver}.draw $draw\n"; print "${txtserver}.type COUNTER\n"; } $i++; } exit 0; } foreach my $string (sort (@data)) { my ($server, $ifInOctets, $ifOutOctets, $ifRequests, $ifDocuments) = split (/\s/, $string); (my $txtserver = $server) =~ s/(-|\.)/\_/g; if ($action eq "documents") { print "${txtserver}.value $ifDocuments\n"; } elsif ($action eq "requests") { print "${txtserver}.value $ifRequests\n"; } elsif ($action eq "bytes") { print "${txtserver}.value " . ($ifInOctets + $ifOutOctets) . "\n"; } }