Yet Another CPAN Grep

Net-Bullfinch ( G/GP/GPHAT/Net-Bullfinch-0.05.tar.gz, GPHAT, 2012; MetaCPAN )

Net-Bullfinch/lib/Net/Bullfinch.pm ( view source; MetaCPAN )

ooseX::Types::DateTime;

# ABSTRACT: Perl wrapper for talking with Bullfinch

use Data::UUID;
use JSON::XS;
use Memcached::Client;

use Net::Bullfinch::Iterator;


has '_client' => (
    is => 'rw',

onal => 1 }
    );

    my ($rname, $json) = $self->_prepare_request($data, $queuename, $trace, $procby);
    my $kes = $self->_client;

    $kes->set($queue, $json, $expire);

    my @items = ();

    if(defined($resp)) {
            $kes->get($rname.'/close');
            my $decoded = decode_json($resp);
            if(exists($decoded->{EOF})) {
                last;
            }

Net-Bullfinch ( G/GP/GPHAT/Net-Bullfinch-0.05.tar.gz, GPHAT, 2012; MetaCPAN )

Net-Bullfinch/lib/Net/Bullfinch/Iterator.pm ( view source; MetaCPAN )

r::VERSION = '0.05';
}
use Moose;

# ABSTRACT: A way to iterator over results from Bullfinch

use JSON::XS;

use Net::Bullfinch;

with 'Data::Stream::Bulk::DoneFlag';


has 'bullfinch' => (
    is

fined $resp ) {
            $kestrel->confirm( $resp_queue, 1 );
            my $decoded = decode_json( $resp );
            if ( exists $decoded->{'EOF'} ) {
                $self->_set_done;

fined $resp ) {
            $kestrel->confirm( $resp_queue, 1 );
            my $decoded = decode_json( $resp );
            if ( exists $decoded->{'EOF'} ) {
                last;
            }