lib/APKPM.pm

   1 package APKPM;
   2
   3 use base qw(Gearman::Driver::Worker);
   4 use Moose;
   5 use Time::HiRes;
   6 use JSON::XS;
   7 use Data::Dump qw(dump);
   8
   9 our $VERSION = '0.00';
  10
  11 sub prefix { '' }
  12
  13 sub process_name {
  14         my ( $self, $orig, $job_name ) = @_;
  15         warn "# process_name $orig $job_name\n";
  16         return "$orig ($job_name)";
  17 }
  18
  19 sub poll : Job : MinProcesses(1) : MaxProcesses(5) : Encode : Decode {
  20         my ( $self, $job, $workload ) = @_;
  21         warn "# poll $job ", dump($workload);
  22 }
  23
  24 sub encode {
  25         my ( $self, $result ) = @_;
  26         warn "# encode ",dump $result;
  27         return JSON::XS::encode_json($result);
  28 }
  29
  30 sub decode {
  31         my ( $self, $workload ) = @_;
  32         warn "# decode ", dump $workload;
  33         return JSON::XS::decode_json($workload);
  34 }
  35
  36 1;