File Coverage

blib/lib/Net/Hadoop/YARN/NodeManager.pm

Criterion	Covered	Total	%
statement	14	34	41.1
branch	0	10	0.0
condition	0	9	0.0
subroutine	5	10	50.0
pod			n/a
total	19	63	30.1

package Net::Hadoop::YARN::NodeManager;
$Net::Hadoop::YARN::NodeManager::VERSION = '0.201';
use strict;
use warnings;
use 5.10.0;
use Moo;
use Data::Dumper;

with 'Net::Hadoop::YARN::Roles::Common';

has '+servers' => ( default => sub { ["localhost:50060"] }, );


sub info {
    my $self = shift;
    my $res = $self->_get("node/info");
    return $res->{nodeInfo} || $res;
}


sub app {
    my $self = shift;
    return $self->apps(@_);
}

sub apps {
    my $self = shift;
    my $app_id;
    my $options;
    if ( @_ == 1 ) {
        if ( !ref $_[0] ) {
            $app_id = shift;
        }
        else {
            $options = shift;
        }
    }
    elsif ( @_ > 1 ) {
        $options = {@_};
    }
    my $res = $self->_get(
        $app_id ? "node/apps/$app_id" : ( "node/apps", { params => $options } )
    );
    return $res->{app} || $res;
}


sub container {
    my $self = shift;
    return $self->containers(@_);
}

sub containers {
    my $self = shift;
    my $container_id = shift;
    my $res = $self->_get( "node/containers" . ($container_id ? "/$container_id" : "") );
    return $res->{container} || $res;
}

1;

__END__