File Coverage

blib/lib/Data/Riak/Fast/MapReduce/Phase/Link.pm

Criterion	Covered	Total	%
statement	6	12	50.0
branch	0	8	0.0
condition			n/a
subroutine	2	3	66.6
pod	0	1	0.0
total	8	24	33.3

package Data::Riak::Fast::MapReduce::Phase::Link;
use Mouse;

use JSON::XS ();

# ABSTRACT: Link phase of a MapReduce

with ('Data::Riak::Fast::MapReduce::Phase');

=head1 DESCRIPTION

A map/reduce link phase for Data::Riak::Fast

=head1 SYNOPSIS

  my $lp = Data::Riak::Fast::MapReduce::Phase::Link->new(
    bucket=> "foo",
    tag   => "friend",
    keep  => 0
  );

=head2 bucket

The name of the bucket from which links should be followed.

=cut

has bucket => (
    is => 'rw',
    isa => 'Str',
    predicate => 'has_bucket'
);

has phase => (
    is => 'ro',
    isa => 'Str',
    default => 'link'
);

=head2 tag

The name of the tag of links that should be followed

=cut

has tag => (
    is => 'rw',
    isa => 'Str',
    predicate => 'has_tag'
);

=head1 METHOD
=head2 pack()

Serialize this link phase.

=cut

sub pack {
    my $self = shift;

    my $href = {};

    $href->{keep} = $self->keep ? JSON::XS::true() : JSON::XS::false() if $self->has_keep;
    $href->{bucket} = $self->bucket if $self->has_bucket;
    $href->{tag} = $self->tag if $self->has_tag;

    $href;
}

1;