jenkins_nodes_
Sadly there is no documentation for this plugin.
#!/usr/bin/env perl
# -*- perl -*-
# MAIN
use warnings;
use strict;
use JSON;
use File::Basename;
use Data::Dumper;
# VARS
my $url = ($ENV{'url'} || 'localhost');
my $port = ($ENV{'port'} || '4040');
my $user = ($ENV{'user'} || '');
my $apiToken = ($ENV{'apiToken'} || '');
my $context = ($ENV{'context'} || '');
my $wgetBin = "/usr/bin/env wget";
# mem_sum, mem, swap, ws, tmp, executors, arch
my $type = basename($0);
$type =~ s/jenkins_nodes_//;
my $auth = ( $user ne "" and $apiToken ne "" ? " --auth-no-challenge --user=$user --password=$apiToken" : "" );
my $cmd = "$wgetBin $auth -qO- $url:$port$context";
my $monitor;
if ( exists $ARGV[0] and $ARGV[0] eq "config" ) {
my $base_config = "graph_category devel\n";
if( $type eq "mem_sum" ) {
print $base_config;
print "graph_args --base 1000 -l 0\n";
print "graph_title Jenkins Memory Summary\n";
print "graph_vlabel Memory Summary\n";
print "graph_info The Graph shows the Jenkins Memory Summary\n";
print "mem_sum_total.draw AREA\n";
print "mem_sum_total.label available\n";
print "mem_sum_total.type GAUGE\n";
print "mem_sum_used.label used\n";
print "mem_sum_used.type GAUGE\n";
}
if( $type eq "mem" ) {
print $base_config;
print "graph_args --base 1000 -l 0\n";
print "graph_title available Memory per Node\n";
print "graph_vlabel available Memory per Node\n";
print "graph_info The Graph shows the available Physical Memory per Node\n";
my $lcount = 0;
my $node;
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
my $cat = $cur->{'displayName'};
$cat =~ s/\./\_/g;
if( $lcount > 0 ){
print $cat,"_mem.draw STACK\n";
} else {
print $cat,"_mem.draw AREA\n";
}
print $cat,"_mem.label $cur->{'displayName'}\n";
print $cat,"_mem.type GAUGE\n";
$lcount++;
}
}
}
if( $type eq "ws" ) {
print $base_config;
print "graph_args --base 1000 -l 0\n";
print "graph_title available Workspace per Node\n";
print "graph_vlabel available Workspace\n";
print "graph_info The Graph shows the available Workspace per Node\n";
my $lcount = 0;
my $node;
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
my $cat = $cur->{'displayName'};
$cat =~ s/\./\_/g;
if( $lcount > 0 ){
print $cat,"_ws.draw STACK\n";
} else {
print $cat,"_ws.draw AREA\n";
}
print $cat,"_ws.label $cur->{'displayName'}\n";
print $cat,"_ws.type GAUGE\n";
$lcount++;
}
}
}
if( $type eq "tmp" ) {
print $base_config;
print "graph_args --base 1000 -l 0\n";
print "graph_title available TMP Space per Node\n";
print "graph_vlabel available TMP Space\n";
print "graph_info The Graph shows the available TMP Space per Node\n";
my $lcount = 0;
my $node;
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
my $cat = $cur->{'displayName'};
$cat =~ s/\./\_/g;
if( $lcount > 0 ){
print $cat,"_tmp.draw STACK\n";
} else {
print $cat,"_tmp.draw AREA\n";
}
print $cat,"_tmp.label $cur->{'displayName'}\n";
print $cat,"_tmp.type GAUGE\n";
$lcount++;
}
}
}
if( $type eq "arch" ) {
print $base_config;
print "graph_args --base 1000 -l 0\n";
print "graph_title available Node Architectures\n";
print "graph_vlabel available Node Architectures\n";
print "graph_info The Graph shows the available Node Architectures\n";
my $lcount = 0;
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
my %archs = ();
my $cat;
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
$cat = $cur->{'monitorData'}{'hudson.node_monitors.ArchitectureMonitor'};
if (exists $archs{$cat} ) {} else {
$archs{$cat} = 0;
}
}
}
foreach my $cur (keys %archs) {
$cat = clean_name($cur);
if( $lcount > 0 ){
print $cat,".draw STACK\n";
} else {
print $cat,".draw AREA\n";
}
print $cat,".label $cur\n";
print $cat,".type GAUGE\n";
$lcount++;
}
}
if( $type eq "executors" ) {
print $base_config;
print "graph_args --base 1000 -l 0\n";
print "graph_title Jenkins Executors\n";
print "graph_vlabel Executors\n";
print "graph_info The Graph shows the Jenkins Executors\n";
print "executors_offline.label offline\n";
print "executors_offline.type GAUGE\n";
print "executors_offline.draw AREA\n";
print "executors_offline.colour 8A8A8A\n";
print "executors_busy.label busy\n";
print "executors_busy.type GAUGE\n";
print "executors_busy.draw STACK\n";
print "executors_idle.label idle\n";
print "executors_idle.type GAUGE\n";
print "executors_idle.draw STACK\n";
}
} else {
# CODE
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
if( $type eq "mem_sum" ) {
my $avail_mem = 0;
my $total_mem = 0;
my $used_mem = 0;
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
$monitor = $cur->{'monitorData'}{'hudson.node_monitors.SwapSpaceMonitor'};
$avail_mem += $monitor->{'availablePhysicalMemory'};
$total_mem += $monitor->{'totalPhysicalMemory'};
}
}
$used_mem = $total_mem - $avail_mem;
print "mem_sum_total.value $total_mem\n";
print "mem_sum_used.value $used_mem\n";
}
if( $type eq "mem" ) {
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
$monitor = $cur->{'monitorData'}{'hudson.node_monitors.SwapSpaceMonitor'};
my $cat = $cur->{'displayName'};
$cat =~ s/\./\_/g;
print $cat,"_mem.value ",$monitor->{'availablePhysicalMemory'},"\n";
}
}
}
if( $type eq "tmp" ) {
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
$monitor = $cur->{'monitorData'}{'hudson.node_monitors.TemporarySpaceMonitor'};
my $cat = $cur->{'displayName'};
$cat =~ s/\./\_/g;
print $cat,"_tmp.value ",$monitor->{'size'},"\n";
}
}
}
if( $type eq "ws" ) {
my $result = `$cmd/computer/api/json`;
my $parsed = decode_json($result);
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
$monitor = $cur->{'monitorData'}{'hudson.node_monitors.DiskSpaceMonitor'};
my $cat = $cur->{'displayName'};
$cat =~ s/\./\_/g;
print $cat,"_ws.value ",$monitor->{'size'},"\n";
}
}
}
if( $type eq "arch" ) {
my $parsed = decode_json($result);
my %archs = ();
my $cat;
foreach my $cur(@{$parsed->{'computer'}}) {
if( !$cur->{'offline'} ) {
$cat = $cur->{'monitorData'}{'hudson.node_monitors.ArchitectureMonitor'};
if (exists $archs{$cat} ) {
$archs{$cat} += 1;
} else {
$archs{$cat} = 1;
}
}
}
foreach my $cur (keys %archs) {
$cat = clean_name($cur);
print $cat,".value ", $archs{$cur}, "\n";
}
}
if( $type eq "executors" ) {
my $busyExecutors = $parsed->{'busyExecutors'};
my $totalExecutors = 0;
my $offlineExecutors = 0;
foreach my $cur(@{$parsed->{'computer'}}) {
$totalExecutors += $cur->{'numExecutors'};
if( $cur->{'offline'} =~ /true$/ ) {
$offlineExecutors += $cur->{'numExecutors'};
}
}
print "executors_idle.value ", ($totalExecutors - $busyExecutors - $offlineExecutors), "\n";
print "executors_busy.value $busyExecutors\n";
print "executors_offline.value $offlineExecutors\n";
}
}
sub clean_name {
my $name = $_[0];
$name =~ s/\./\_/g;
$name =~ s/\(/\_/g;
$name =~ s/\)/\_/g;
$name =~ s/ //g;
return $name;
}