qw(timethis timethese cmpthese);
use Net::Riak;
use Time::Out qw(timeout);
use Time::HiRes;
use JSON;
use FindBin qw($Bin);
use lib "$Bin/../lib";
use Riak::Light;
die "please set the RIAK_PBC_HOS
foo_data_riak',
riak => $data_riak_client
}
);
$data_riak_bucket->add( key => encode_json($hash) );
use Data::Riak::Fast;
my $data_riak_fast_client = Data::Riak::Fast->new(
{ tran
ey => encode_json($hash) );
use Riak::Tiny;
my $riak_tiny_client = Riak::Tiny->new( host => 'http://127.0.0.1:8098' );
$riak_tiny_client->new_object( foo_riak_tiny => key => encode_json($hash) );
r::Util qw(blessed);
use IO::Socket;
use Socket qw(TCP_NODELAY IPPROTO_TCP);
use Const::Fast;
use JSON;
use Carp;
use Module::Runtime qw(use_module);
use Moo;
# ABSTRACT: Fast and lightweight Perl cl
$vclock ) =
$check->(@_);
( $content_type ||= 'application/json' ) eq 'application/json'
and $value = encode_json($value);
$self->_store( $bucket, $key, $value, $content_type, $i
$check->(@_);
my @args;
push @args, ref($request) ? encode_json($request) : $request;
push @args, 'application/json';
push @args, $callback if $callback;
$self->map_reduce_raw(
chmark::Forking qw(timethis timethese cmpthese);
use Time::Out qw(timeout);
use Time::HiRes;
use JSON;
use Net::Riak;
use Data::Riak;
use Data::Riak::Fast;
use Riak::Tiny;
use FindBin qw($Bin);
use
foo_data_riak',
riak => $data_riak_client
}
);
$data_riak_bucket->add( key => encode_json($hash) );
my $data_riak_fast_client = Data::Riak::Fast->new(
{ transport => Data::Riak::Fa
ast',
riak => $data_riak_fast_client
}
);
$data_riak_fast_bucket->add( key => encode_json($hash) );
my $riak_tiny_client = Riak::Tiny->new( host => 'http://127.0.0.1:8098' );
cmpthese(