AnyEvent-Gearman-WorkerPool

 view release on metacpan or  search on metacpan

META.yml  view on Meta::CPAN

license: perl
meta-spec:
  url: http://module-build.sourceforge.net/META-spec-v1.4.html
  version: '1.4'
name: AnyEvent-Gearman-WorkerPool
requires:
  AnyEvent: '0'
  AnyEvent::Gearman::Client: '0'
  AnyEvent::Gearman::Worker: '0'
  AnyEvent::Gearman::Worker::RetryConnection: '0'
  Data::Dumper: '0'
  Gearman::Server: '0'
  Log::Log4perl: '0'
  Moose: '0'
  Storable: '0'
resources:
  homepage: https://github.com/sng2c/Gearman-SlotManager
  repository: git://github.com/sng2c/Gearman-SlotManager.git
version: '1.0'

Makefile.PL  view on Meta::CPAN

  },
  "DISTNAME" => "AnyEvent-Gearman-WorkerPool",
  "EXE_FILES" => [],
  "LICENSE" => "perl",
  "NAME" => "AnyEvent::Gearman::WorkerPool",
  "PREREQ_PM" => {
    "AnyEvent" => 0,
    "AnyEvent::Gearman::Client" => 0,
    "AnyEvent::Gearman::Worker" => 0,
    "AnyEvent::Gearman::Worker::RetryConnection" => 0,
    "Data::Dumper" => 0,
    "Gearman::Server" => 0,
    "Log::Log4perl" => 0,
    "Moose" => 0,
    "Storable" => 0
  },
  "TEST_REQUIRES" => {
    "AnyEvent::Gearman" => 0,
    "Exporter" => 0,
    "Scalar::Util" => 0,
    "Test::More" => 0,

Makefile.PL  view on Meta::CPAN

  }
);


my %FallbackPrereqs = (
  "AnyEvent" => 0,
  "AnyEvent::Gearman" => 0,
  "AnyEvent::Gearman::Client" => 0,
  "AnyEvent::Gearman::Worker" => 0,
  "AnyEvent::Gearman::Worker::RetryConnection" => 0,
  "Data::Dumper" => 0,
  "Exporter" => 0,
  "Gearman::Server" => 0,
  "Log::Log4perl" => 0,
  "Moose" => 0,
  "Scalar::Util" => 0,
  "Storable" => 0,
  "Test::More" => 0,
  "lib" => 0
);

lib/AnyEvent/Gearman/WorkerPool.pm  view on Meta::CPAN

package AnyEvent::Gearman::WorkerPool;
# ABSTRACT: Managing Worker's lifecycle with Slots
our $VERSION = '1.0'; # VERSION
use Log::Log4perl qw(:easy);

use Data::Dumper;
use Moose;
use Storable qw(freeze thaw);

use AnyEvent;
use AnyEvent::Gearman::Worker;
use AnyEvent::Gearman::Worker::RetryConnection;

use AnyEvent::Gearman::WorkerPool::Slot;
has slotmap=>(is=>'rw', isa=>'HashRef', default=>sub{ return {}; });
has config=>(is=>'rw', isa=>'HashRef',required=>1);

lib/AnyEvent/Gearman/WorkerPool/Slot.pm  view on Meta::CPAN

package AnyEvent::Gearman::WorkerPool::Slot;


# ABSTRACT: Slot class
our $VERSION = '1.0'; # VERSION
use Log::Log4perl qw(:easy);

use Moose;
use AnyEvent;
use AnyEvent::Gearman::WorkerPool::Worker;
use Data::Dumper;

has libs=>(is=>'rw',isa=>'ArrayRef',default=>sub{[]});
has job_servers=>(is=>'rw',isa=>'ArrayRef',required=>1);
has workleft=>(is=>'rw');
has worker_package=>(is=>'rw');
has worker_channel=>(is=>'rw');

has is_busy=>(is=>'rw',default=>0);
has is_stopped=>(is=>'rw',default=>1);
has boss_channel=>(is=>'rw',default=>'');