simplify role apply for jobqueue
This commit is contained in:
20
Netdisco/lib/App/Netdisco/Daemon/JobQueue.pm
Normal file
20
Netdisco/lib/App/Netdisco/Daemon/JobQueue.pm
Normal file
@@ -0,0 +1,20 @@
|
|||||||
|
package App::Netdisco::Daemon::JobQueue;
|
||||||
|
|
||||||
|
use Dancer qw/:moose :syntax :script/;
|
||||||
|
|
||||||
|
use Role::Tiny;
|
||||||
|
use namespace::clean;
|
||||||
|
|
||||||
|
with 'App::Netdisco::Daemon::JobQueue::'. setting('job_queue');
|
||||||
|
|
||||||
|
requires qw/
|
||||||
|
jq_get
|
||||||
|
jq_getlocal
|
||||||
|
jq_queued
|
||||||
|
jq_lock
|
||||||
|
jq_defer
|
||||||
|
jq_complete
|
||||||
|
jq_insert
|
||||||
|
/;
|
||||||
|
|
||||||
|
true;
|
||||||
@@ -6,8 +6,7 @@ use Try::Tiny;
|
|||||||
use Role::Tiny;
|
use Role::Tiny;
|
||||||
use namespace::clean;
|
use namespace::clean;
|
||||||
|
|
||||||
with 'App::Netdisco::Daemon::JobQueue::'. setting('job_queue');
|
with 'App::Netdisco::Daemon::JobQueue';
|
||||||
requires qw/worker_type worker_name munge_action jq_defer jq_complete/;
|
|
||||||
|
|
||||||
sub worker_body {
|
sub worker_body {
|
||||||
my $self = shift;
|
my $self = shift;
|
||||||
|
|||||||
@@ -5,8 +5,7 @@ use Dancer qw/:moose :syntax :script/;
|
|||||||
use Role::Tiny;
|
use Role::Tiny;
|
||||||
use namespace::clean;
|
use namespace::clean;
|
||||||
|
|
||||||
with 'App::Netdisco::Daemon::JobQueue::'. setting('job_queue');
|
with 'App::Netdisco::Daemon::JobQueue';
|
||||||
requires qw/jq_get jq_getlocal jq_lock/;
|
|
||||||
|
|
||||||
sub worker_begin {
|
sub worker_begin {
|
||||||
my $self = shift;
|
my $self = shift;
|
||||||
|
|||||||
@@ -12,9 +12,6 @@ use NetAddr::IP::Lite ':lower';
|
|||||||
use Role::Tiny;
|
use Role::Tiny;
|
||||||
use namespace::clean;
|
use namespace::clean;
|
||||||
|
|
||||||
with 'App::Netdisco::Daemon::JobQueue::'. setting('job_queue');
|
|
||||||
requires qw/jq_queued jq_insert/;
|
|
||||||
|
|
||||||
# queue a job for all devices known to Netdisco
|
# queue a job for all devices known to Netdisco
|
||||||
sub _walk_body {
|
sub _walk_body {
|
||||||
my ($self, $job_type, $job) = @_;
|
my ($self, $job_type, $job) = @_;
|
||||||
|
|||||||
@@ -13,9 +13,6 @@ use NetAddr::IP::Lite ':lower';
|
|||||||
use Role::Tiny;
|
use Role::Tiny;
|
||||||
use namespace::clean;
|
use namespace::clean;
|
||||||
|
|
||||||
with 'App::Netdisco::Daemon::JobQueue::'. setting('job_queue');
|
|
||||||
requires qw/jq_queued jq_insert/;
|
|
||||||
|
|
||||||
# queue a discover job for all devices known to Netdisco
|
# queue a discover job for all devices known to Netdisco
|
||||||
sub discoverall {
|
sub discoverall {
|
||||||
my ($self, $job) = @_;
|
my ($self, $job) = @_;
|
||||||
|
|||||||
@@ -6,8 +6,7 @@ use Algorithm::Cron;
|
|||||||
use Role::Tiny;
|
use Role::Tiny;
|
||||||
use namespace::clean;
|
use namespace::clean;
|
||||||
|
|
||||||
with 'App::Netdisco::Daemon::JobQueue::'. setting('job_queue');
|
with 'App::Netdisco::Daemon::JobQueue';
|
||||||
requires 'jq_insert';
|
|
||||||
|
|
||||||
sub worker_begin {
|
sub worker_begin {
|
||||||
my $self = shift;
|
my $self = shift;
|
||||||
|
|||||||
Reference in New Issue
Block a user