NAME

Job::Async::Worker::Redis - Net::Async::Redis worker implementation for Job::Async::Worker

SYNOPSIS

DESCRIPTION

incoming_job

Source for jobs received from the BRPOP(LPUSH) queue wait.

on_job_received

Called for each job that's received.

pending_queues

Note that reliable mode only supports a single queue, and will fail if you attempt to start with multiple queues defined.

processing_queue

start

stop

Requests to stop processing.

Returns a future which will complete when all currently-processing jobs have finished.

max_concurrent_jobs

Number of jobs to process in parallel. Defaults to 1.

job_poll_interval

Polling interval (e.g. for BRPOPLPUSH in reliable mode), in seconds.

Defaults to 3 seconds.

INHERITED METHODS

Job::Async::Worker

id, jobs, ryu, timeout

IO::Async::Notifier

add_child, adopt_future, adopted_futures, can_event, children, configure_unknown, debug_printf, get_loop, invoke_error, invoke_event, loop, make_event_cb, maybe_invoke_event, maybe_make_event_cb, new, notifier_name, parent, remove_child, remove_from_parent

AUTHOR

Tom Molesworth <TEAM@cpan.org>

LICENSE

Copyright Tom Molesworth 2016-2019. Licensed under the same terms as Perl itself.