summary refs log tree commit diff
path: root/lib/Net/Riak/Role
diff options
context:
space:
mode:
authorfranck cuny <franck@lumberjaph.net>2010-06-14 15:25:35 +0200
committerfranck cuny <franck@lumberjaph.net>2010-06-14 15:25:35 +0200
commit06094dd3e7cc2d4b9299886037fc39f4344a2b9f (patch)
treee50f472413add487039e967783e560902bbcefc6 /lib/Net/Riak/Role
parenttests for client (diff)
downloadnet-riak-06094dd3e7cc2d4b9299886037fc39f4344a2b9f.tar.gz
add n::r::client and now client is a n::r::client
Diffstat (limited to 'lib/Net/Riak/Role')
-rw-r--r--lib/Net/Riak/Role/MapReduce.pm34
1 files changed, 34 insertions, 0 deletions
diff --git a/lib/Net/Riak/Role/MapReduce.pm b/lib/Net/Riak/Role/MapReduce.pm
new file mode 100644
index 0000000..d80e242
--- /dev/null
+++ b/lib/Net/Riak/Role/MapReduce.pm
@@ -0,0 +1,34 @@
+package Net::Riak::Role::MapReduce;
+
+use Moose::Role;
+use Net::Riak::MapReduce;
+
+sub add {
+    my ($self, @args) = @_;
+    my $mr = Net::Riak::MapReduce->new(client => $self->client);
+    $mr->add(@args);
+    $mr;
+}
+
+sub link {
+    my ($self, @args) = @_;
+    my $mr = Net::Riak::MapReduce->new(client => $self->client);
+    $mr->link(@args);
+    $mr;
+}
+
+sub map {
+    my ($self, @args) = @_;
+    my $mr = Net::Riak::MapReduce->new(client => $self->client);
+    $mr->mapd(@args);
+    $mr;
+}
+
+sub reduce {
+    my ($self, @args) = @_;
+    my $mr = Net::Riak::MapReduce->new(client => $self->client);
+    $mr->reduce(@args);
+    $mr;
+}
+
+1;