File Coverage

blib/lib/Qless/Queues.pm

Criterion	Covered	Total	%
statement	18	30	60.0
branch	0	2	0.0
condition			n/a
subroutine	6	9	66.6
pod	0	3	0.0
total	24	44	54.5

package Qless::Queues;
=head1 NAME

Qless::Queues

=cut

use strict; use warnings;
use Qless::Queue;
use JSON::XS qw(decode_json);
use Time::HiRes qw();
use Qless::Utils qw(fix_empty_array);

sub new {
	my $class = shift;
	my ($client) = @_;

	$class = ref $class if ref $class;
	my $self = bless {}, $class;

	$self->{'client'} = $client;

	$self;
}

sub counts {
	my ($self) = @_;
	my $results = decode_json($self->{'client'}->_queues([], Time::HiRes::time));
	$results = fix_empty_array($results);
	return $results;
}

sub item {
	my ($self, $name) = @_;
	return Qless::Queue->new($name, $self->{'client'}, $self->{'client'}->{'worker_name'});
}

1;