From 06094dd3e7cc2d4b9299886037fc39f4344a2b9f Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Mon, 14 Jun 2010 15:25:35 +0200
Subject: add n::r::client and now client is a n::r::client

---
 lib/Net/Riak/Role/MapReduce.pm | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 lib/Net/Riak/Role/MapReduce.pm

(limited to 'lib/Net/Riak/Role/MapReduce.pm')

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;
-- 
cgit v1.2.3