File Coverage

blib/lib/Apache/Hadoop/Watcher/Jmx.pm

Criterion	Covered	Total	%
statement	11	56	19.6
branch	0	10	0.0
condition	0	4	0.0
subroutine	4	12	33.3
pod	0	7	0.0
total	15	89	16.8

#
# (C) 2015, Snehasis Sinha
#
package Apache::Hadoop::Watcher::Jmx;

use 5.010001;
use strict;
use warnings;

use JSON;

require Apache::Hadoop::Watcher::Base;

our @ISA = qw();
our $VERSION = '0.01';


# Preloaded methods go here.
sub new {
	my $class = shift;
	my %args  = @_;
	my $self  = {
		jmx   => 'http://'.($args{'host'}||'localhost').':'.($args{'port'}||'50070').'/jmx',
		out   => undef,
		qlist => {
			'java_runtime' => 'java.lang:type=Runtime',
			'java_memory' => 'java.lang:type=Memory',
			'namenode_status' => 'Hadoop:service=NameNode,name=NameNodeStatus',
			'port9000_detailed' => 'Hadoop:service=NameNode,name=RpcDetailedActivityForPort9000',
			'namenode_activity' => 'Hadoop:service=NameNode,name=NameNodeActivity',
			'port9000_activity' => 'Hadoop:service=NameNode,name=RpcActivityForPort9000',
			'namenode_retry_cache' => 'Hadoop:service=NameNode,name=RetryCache.NameNodeRetryCache',
			'ugi_metrics' => 'Hadoop:service=NameNode,name=UgiMetrics',
			'control_metrics' => 'Hadoop:service=NameNode,name=MetricsSystem,sub=Control',
			'jvm_metrics' => 'Hadoop:service=NameNode,name=JvmMetrics',
			'fsname_state' => 'Hadoop:service=NameNode,name=FSNamesystemState',
			'fsname_system' => 'Hadoop:service=NameNode,name=FSNamesystem',
			'startup_progress' => 'Hadoop:service=NameNode,name=StartupProgress',
			'stats_metrics' => 'Hadoop:service=NameNode,name=MetricsSystem,sub=Stats',
			'namenode_info' => 'Hadoop:service=NameNode,name=NameNodeInfo',
		},
	};
	bless $self, $class;
	return $self;
}

# dumps output hashref
sub print {
	my ($self) = (@_);
	Apache::Hadoop::Watcher::Base->new->_print ( output=>$self->{'out'} );
}

# returns list of services
sub list {
	my ($self) = (@_);
	my @servicelist;
	foreach my $href ( @{$self->{'out'}} ) {
		push @servicelist, $href->{'name'};
	}
	return \@servicelist;
}

# returns output hashref
sub get {
	my ($self) = (@_);
	return $self->{'out'};
}

sub set {
	my ($self, %opts) = (@_);
}

sub get_system_properties {
	my ($self) = (@_);
	my $href;

	$self->_query (query=>$self->{'qlist'}->{'system_properties'});
	$href = $self->{'out'}->[0]->{'SystemProperties'};
	foreach my $e (sort @{$href}) {
		if ( $e->{'key'} eq 'java.class.path' ) {
			print sprintf "%30s  %s\n", $e->{'key'}, ' ';
			foreach ( split /:/, $e->{'value'} ) {
				print sprintf "%30s  %s\n", ' ', $_;
			}
			next;
		}

		if ( $e->{'key'} eq 'sun.boot.class.path' ) {
			print sprintf "%30s  %s\n", $e->{'key'}, ' ';
			foreach ( split /:/, $e->{'value'} ) {
				print sprintf "%30s  %s\n", ' ', $_;
			}
			next;
		}

		print sprintf "%30s  %s\n", $e->{'key'}, $e->{'value'};
	}
}

# jmx json methods
sub _query {
	my ($self, %opts) = (@_);
	my $base = Apache::Hadoop::Watcher::Base->new;
	my $url = defined $opts{'query'} ? $self->{'jmx'}.'?qry='.$opts{'query'} : $self->{'jmx'};
	$self->{'out'} = (decode_json $base->_wget (url=>$url))->{'beans'};
	#$self->{'out'} = (decode_json $base->_wget (url=>$url));
	$base->_jsonjmx ( $self->{'out'} );
	$self->{'out'} =~ s/\'//g;
}

# request
sub request {
	my ($self, %opts) = (@_);
	my $q = undef;

	$q = $self->{'qlist'}->{$opts{'method'}} if  defined $opts{'method'};
	$q = $opts{'service'} if  defined $opts{'service'};
	$self->_query (query => $q);
	return $self;
}

1;

__END__