File Coverage

blib/lib/Kevin/Command/kevin/workers.pm

Criterion	Covered	Total	%
statement	15	31	48.3
branch			n/a
condition			n/a
subroutine	5	11	45.4
pod	1	1	100.0
total	21	43	48.8

package Kevin::Command::kevin::workers;
$Kevin::Command::kevin::workers::VERSION = '0.4.0';
# ABSTRACT: Command to list Minion workers
use Mojo::Base 'Mojolicious::Command';

use Kevin::Commands::Util ();
use Mojo::Util qw(getopt);
use Text::Yeti::Table qw(render_table);
use Time::HiRes qw(time);

has description => 'List Minion workers';
has usage => sub { shift->extract_usage };

sub run {
  my ($self, @args) = @_;

  my $app    = $self->app;
  my $minion = $app->minion;

  my ($args, $options) = ([], {});
  getopt \@args,
    'l|limit=i'  => \(my $limit  = 100),
    'o|offset=i' => \(my $offset = 0);

  my $jobs = $minion->backend->list_workers($offset, $limit, $options);

  my $spec = $self->_table_spec;
  render_table($jobs, $spec);
}

*_running_since = *Kevin::Commands::Util::_running_since;

sub _table_spec {
  my $now = time;
  return [
    qw(id ),
    ['host', sub {"$_[0]:$_[1]{pid}"}, 'HOST:PID'],
    [
      'jobs',
      sub {
        sprintf "%i/%i/%i", scalar @{$_[0]}, $_[1]{status}{jobs},
          $_[1]{status}{performed};
      }
    ],
    ['started', sub { _running_since($now - shift) }, 'STATUS'],
    ['status',  sub {"@{ $_[0]{queues} }"},           'QUEUES'],
  ];
}

1;

#pod =encoding utf8
#pod
#pod =head1 SYNOPSIS
#pod
#pod   Usage: APPLICATION kevin workers [OPTIONS]
#pod
#pod     ./myapp.pl kevin workers
#pod     ./myapp.pl kevin workers -l 10 -o 20
#pod
#pod   Options:
#pod     -h, --help                  Show this summary of available options
#pod     -l, --limit         Number of workers to show when listing
#pod                                 them, defaults to 100
#pod     -o, --offset        Number of workers to skip when listing
#pod                                 them, defaults to 0
#pod
#pod =head1 DESCRIPTION
#pod
#pod L lists workers at a L queue.
#pod It produces output as below.
#pod
#pod     ID      HOST:PID                       JOBS      STATUS       QUEUES
#pod     27302   39c7d2ded2c4/dev13.ke.vin:31   0/4/310   Up 2 days    image-resizer
#pod     27293   e7b1c0a64810/dev12.ke.vin:34   0/4/378   Up 2 days    image-resizer
#pod     27187   7d7190787c5e/dev12.ke.vin:33   0/4/381   Up 2 days    uploader video-uploader
#pod     27186   6badf6e19282/dev12.ke.vin:34   0/4/289   Up 2 days    uploader video-uploader
#pod     27185   59dc9b9752dd/dev12.ke.vin:35   0/4/108   Up 2 days    uploader video-uploader
#pod     26851   8bd2e06cdbd2/dev13.ke.vin:31   0/4/209   Up 2 days    poker
#pod     26850   b9d044771a57/dev13.ke.vin:32   0/4/237   Up 11 days   poker
#pod     26822   f24eaa47795d:6429              0/4/183   Up 2 weeks   item-searcher
#pod     26748   0fdb4ead83c5:6400              0/4/349   Up 2 weeks   item-searcher
#pod
#pod The entry under C reads as
#pod
#pod     active jobs / capacity / performed jobs
#pod
#pod =head1 ATTRIBUTES
#pod
#pod L inherits all attributes from
#pod L and implements the following new ones.
#pod
#pod =head2 description
#pod
#pod   my $description = $command->description;
#pod   $command        = $command->description('Foo');
#pod
#pod Short description of this command, used for the command list.
#pod
#pod =head2 usage
#pod
#pod   my $usage = $command->usage;
#pod   $command  = $command->usage('Foo');
#pod
#pod Usage information for this command, used for the help screen.
#pod
#pod =head1 METHODS
#pod
#pod L inherits all methods from
#pod L and implements the following new ones.
#pod
#pod =head2 run
#pod
#pod   $command->run(@ARGV);
#pod
#pod Run this command.
#pod
#pod =head1 SEE ALSO
#pod
#pod L, L.
#pod
#pod =cut

__END__