CPAN::Groonga

 don't rely on it.

=head2 Operational modes

=head3 simple

Jobs are submitted by serialising as JSON and pushing to a Redis list
as a queue.

Workers retrieve jobs from queue, and send the results v

::Keyword::Try;
use Future::AsyncAwait;

use Job::Async::Utils;
use Future::Utils qw(repeat);
use JSON::MaybeUTF8 qw(:v1);
use Log::Any qw($log);

use Net::Async::Redis;

=head2 incoming_job

Source f

processed => Time::HiRes::time(),
                            result => ref($rslt) ? 'J' . encode_json_utf8($rslt) : 'T' . $rslt
                        ),
                        $tx->publish('client

::Client>

=head1 SYNOPSIS

=head1 DESCRIPTION

=cut

no indirect;

use Syntax::Keyword::Try;
use JSON::MaybeUTF8 qw(:v1);
use Ryu::Async;
use Job::Async::Utils;
use Net::Async::Redis 1.003;

use Log:

]};
                    my $type = substr $result, 0, 1, '';
                    $result = decode_json_utf8($result) if $type eq 'J';
                    $log->tracef('Job result %s', $result);