summaryrefslogtreecommitdiff
path: root/lib/Net/Presque.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Net/Presque.pm')
-rw-r--r--lib/Net/Presque.pm27
1 files changed, 22 insertions, 5 deletions
diff --git a/lib/Net/Presque.pm b/lib/Net/Presque.pm
index 390eb9e..9f72b20 100644
--- a/lib/Net/Presque.pm
+++ b/lib/Net/Presque.pm
@@ -14,14 +14,31 @@ net_api_method fetch_job => (
required => [qw/queue_name/],
);
-net_api_method create_job => (
- method => 'POST',
- strict => 0,
- path => '/q/:queue_name',
- params => [qw/queue_name/],
+net_api_method fetch_jobs => (
+ method => 'GET',
+ path => '/qb/:queue_name',
+ params => [qw/queue_name worker_id batch_size/],
required => [qw/queue_name/],
);
+net_api_method create_job => (
+ method => 'POST',
+ strict => 0,
+ path => '/q/:queue_name',
+ params_in_url => [qw/delayed uniq/],
+ params => [qw/queue_name/],
+ required => [qw/queue_name/],
+);
+
+net_api_method create_jobs => (
+ method => 'POST',
+ strict => 0,
+ path => '/qb/:queue_name',
+ params_in_url => [qw/delayed/],
+ params => [qw/queue_name jobs/],
+ required => [qw/queue_name jobs/],
+);
+
net_api_method reset_queue => (
method => 'DELETE',
path => '/q/:queue_name',