return "$orig ($job_name)";
}
-sub search : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
+sub search : Job : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
warn "# search $job ", dump($workload);
warn "# begin ", dump( $workload );
}
-sub search : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json_encode) {
+sub search : Job : Encode(e_json_encode) {
my ( $self, $job, $workload ) = @_;
warn "# search ",dump($workload);
sub prefix { 'Davolink_' }
-sub info : Job : MinProcesses(1) : MaxProcesses(60) : Decode(d_array) : Encode(e_json) {
+sub info : Job : Decode(d_array) : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
warn "# workload = ", dump $workload;
my $cpeip = shift @$workload;
return "$orig ($job_name)";
}
-sub search : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
+sub search : Job : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
my $filter =
my $p = Net::Ping->new;
$p->hires;
-sub ping : Job : MinProcesses(1) : MaxProcesses(100) : Encode(e_json) {
+sub ping : Job : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
warn "# ping $job $workload\n";
my ( $ok, $rtt, $ip ) = $p->ping( $workload );
sub prefix { 'poll_' }
-sub by_prefix : Job : MinProcesses(1) : MaxProcesses(1) : Encode(e_json) {
+sub by_prefix : Job : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
my $start = DateTime->now();
return { ldap => $ip_username, results => $results, duration => $finish - $start, poll => $poll };
}
-sub ip_username : Job : MinProcesses(1) : MaxProcesses(25) : Decode(d_array) : Encode(e_json) {
+sub ip_username : Job : Decode(d_array) : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
my ( $ip, $username ) = @$workload;
$sth->execute( map { $h->{$_} } @c );
}
-sub ADSL : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
+sub ADSL : Job : Decode(d_json) {
my ( $self, $job, $workload ) = @_;
my $h = $workload->{ADSL} || die "no ADSL in ",dump $workload;
$self->pg_insert(adsl => $h)
}
-sub ping : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
+sub ping : Job : Decode(d_json) {
my ( $self, $job, $workload ) = @_;
$self->pg_insert(ping => $workload);
}
-sub voice : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
+sub voice : Job : Decode(d_json) {
my ( $self, $job, $workload ) = @_;
$self->pg_insert(voice => $workload);
}
-sub insert_table : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
+sub insert_table : Job : Decode(d_json) {
my ( $self, $job, $workload ) = @_;
my $table = delete $workload->{_table} || die "no _table";
$self->pg_insert($table => $workload);
}
-sub sql : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
+sub sql : Job : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
my $sth = $self->dbh->prepare($workload);
sub prefix { 'VOICE_' }
-sub info : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) {
+sub info : Job : Encode(e_json) {
my ( $self, $job, $workload ) = @_;
warn "# workload = ", dump $workload;