diff options
Diffstat (limited to 'lib/Net')
-rw-r--r-- | lib/Net/Riak/Role/PBC.pm | 2 | ||||
-rw-r--r-- | lib/Net/Riak/Role/PBC/Bucket.pm | 9 | ||||
-rw-r--r-- | lib/Net/Riak/Role/PBC/Link.pm | 12 | ||||
-rw-r--r-- | lib/Net/Riak/Role/PBC/MapReduce.pm | 5 | ||||
-rw-r--r-- | lib/Net/Riak/Role/PBC/Object.pm | 10 | ||||
-rw-r--r-- | lib/Net/Riak/Search.pm | 9 | ||||
-rw-r--r-- | lib/Net/Riak/Transport/PBC.pm | 7 | ||||
-rw-r--r-- | lib/Net/Riak/Transport/PBC/Transport.pm | 212 |
8 files changed, 126 insertions, 140 deletions
diff --git a/lib/Net/Riak/Role/PBC.pm b/lib/Net/Riak/Role/PBC.pm index 775976e..7e6aee3 100644 --- a/lib/Net/Riak/Role/PBC.pm +++ b/lib/Net/Riak/Role/PBC.pm @@ -82,4 +82,4 @@ sub server_info { sub stats { die "->stats is only avaliable through the REST interface" } -1; +1; diff --git a/lib/Net/Riak/Role/PBC/Bucket.pm b/lib/Net/Riak/Role/PBC/Bucket.pm index aa7d7fa..6cd4240 100644 --- a/lib/Net/Riak/Role/PBC/Bucket.pm +++ b/lib/Net/Riak/Role/PBC/Bucket.pm @@ -1,7 +1,5 @@ package Net::Riak::Role::PBC::Bucket; - use Moose::Role; -use Data::Dumper; sub get_properties { my ( $self, $name, $params ) = @_; @@ -29,7 +27,7 @@ sub get_keys { if ( defined $_[0]->keys ) { if ($params->{cb}) { $params->{cb}->($_) for @{ $_[0]->keys }; - } + } else { push @$keys, @{ $_[0]->keys }; } @@ -37,10 +35,7 @@ sub get_keys { } ); - return $params->{cb} ? undef : $keys; + return $params->{cb} ? undef : $keys; } - - 1; - diff --git a/lib/Net/Riak/Role/PBC/Link.pm b/lib/Net/Riak/Role/PBC/Link.pm index 5e6a336..7cba54a 100644 --- a/lib/Net/Riak/Role/PBC/Link.pm +++ b/lib/Net/Riak/Role/PBC/Link.pm @@ -23,12 +23,12 @@ sub _links_for_message { my ($self, $object) = @_; return [ - map { { - tag => $_->tag, - key => $_->key, - bucket => $_->bucket->name - } - } $object->all_links + map { { + tag => $_->tag, + key => $_->key, + bucket => $_->bucket->name + } + } $object->all_links ] } diff --git a/lib/Net/Riak/Role/PBC/MapReduce.pm b/lib/Net/Riak/Role/PBC/MapReduce.pm index afeabe8..00e7de1 100644 --- a/lib/Net/Riak/Role/PBC/MapReduce.pm +++ b/lib/Net/Riak/Role/PBC/MapReduce.pm @@ -2,7 +2,6 @@ package Net::Riak::Role::PBC::MapReduce; use Moose::Role; use JSON; use List::Util 'sum'; -use Data::Dump 'pp'; sub execute_job { my ($self, $job, $timeout, $returned_phases) = @_; @@ -16,8 +15,8 @@ sub execute_job { my $resp = $self->send_message( MapRedReq => { request => $job_request, content_type => 'application/json' - }, sub { push @$results, $self->decode_phase(shift) }) - or + }, sub { push @$results, $self->decode_phase(shift) }) + or die "MapReduce query failed!"; diff --git a/lib/Net/Riak/Role/PBC/Object.pm b/lib/Net/Riak/Role/PBC/Object.pm index 280956c..0f960d2 100644 --- a/lib/Net/Riak/Role/PBC/Object.pm +++ b/lib/Net/Riak/Role/PBC/Object.pm @@ -1,8 +1,6 @@ package Net::Riak::Role::PBC::Object; - use JSON; use Moose::Role; -use Data::Dumper; use List::Util 'first'; sub store_object { @@ -10,7 +8,7 @@ sub store_object { die "Storing object without a key is not supported in the PBC interface" unless $object->key; - my $value = (ref $object->data && $object->content_type eq 'application/json') + my $value = (ref $object->data && $object->content_type eq 'application/json') ? JSON::encode_json($object->data) : $object->data; my $content = { @@ -94,7 +92,7 @@ sub populate_object { $self->_populate_metas($object, $content->usermeta); } - my $data = ($object->content_type eq 'application/json') + my $data = ($object->content_type eq 'application/json') ? JSON::decode_json($content->value) : $content->value; $object->exists(1); @@ -117,7 +115,7 @@ sub retrieve_sibling { # hack for loading 1 sibling if ($params->{vtag}) { - $resp->{content} = [ + $resp->{content} = [ first { $_->vtag eq $params->{vtag} } @{$resp->content} @@ -133,7 +131,7 @@ sub retrieve_sibling { $sibling->_jsonize($object->_jsonize); $self->populate_object($sibling, $resp); - + $sibling; } diff --git a/lib/Net/Riak/Search.pm b/lib/Net/Riak/Search.pm index 368b7e7..c31516f 100644 --- a/lib/Net/Riak/Search.pm +++ b/lib/Net/Riak/Search.pm @@ -1,5 +1,4 @@ -package -Net::Riak::Search; +package Net::Riak::Search; use Moose; #ABSTRACT: Search interface @@ -37,9 +36,9 @@ sub setup_indexing { my $obj3 = $bucket->new_object('foo3', {...}); $obj3->add_index('index', 'first'); $obj3->store; - + my @keys = $client->index('bucket', 'myindex_bin', 'first_value' [, 'last_value'] ); - + =head1 DESCRIPTION L<Net::Riak::Search> allows you to enable indexing documents for a given bucket and querying/searching the index. @@ -98,7 +97,7 @@ remove secondary index from object =item index Find keys via secondary index. - + =back diff --git a/lib/Net/Riak/Transport/PBC.pm b/lib/Net/Riak/Transport/PBC.pm index e495663..a0951d6 100644 --- a/lib/Net/Riak/Transport/PBC.pm +++ b/lib/Net/Riak/Transport/PBC.pm @@ -1,9 +1,4 @@ package Net::Riak::Transport::PBC; - use Moose::Role; - -with qw/ - Net::Riak::Role::PBC - /; - +with qw/Net::Riak::Role::PBC/; 1; diff --git a/lib/Net/Riak/Transport/PBC/Transport.pm b/lib/Net/Riak/Transport/PBC/Transport.pm index 7993f66..32242a4 100644 --- a/lib/Net/Riak/Transport/PBC/Transport.pm +++ b/lib/Net/Riak/Transport/PBC/Transport.pm @@ -3,18 +3,18 @@ package Net::Riak::Transport::PBC::Transport; ## ## This file was generated by Google::ProtocolBuffers (0.08) ## on Mon Dec 13 11:30:34 2010 -## +## use strict; use warnings; use Google::ProtocolBuffers; -{ +{ unless (RpbSetClientIdReq->can('_pb_fields_list')) { Google::ProtocolBuffers->create_message( 'RpbSetClientIdReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'client_id', 1, undef ], @@ -28,13 +28,13 @@ use Google::ProtocolBuffers; 'RpbSetBucketReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'bucket', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - 'RpbBucketProps', + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + 'RpbBucketProps', 'props', 2, undef ], @@ -48,38 +48,38 @@ use Google::ProtocolBuffers; 'RpbPutReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'bucket', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'key', 2, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'vclock', 3, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - 'RpbContent', + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + 'RpbContent', 'content', 4, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'w', 5, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'dw', 6, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BOOL(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BOOL(), 'return_body', 7, undef ], @@ -93,8 +93,8 @@ use Google::ProtocolBuffers; 'RpbListBucketsResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_REPEATED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REPEATED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'buckets', 1, undef ], @@ -108,8 +108,8 @@ use Google::ProtocolBuffers; 'RpbGetBucketResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - 'RpbBucketProps', + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + 'RpbBucketProps', 'props', 1, undef ], @@ -123,18 +123,18 @@ use Google::ProtocolBuffers; 'RpbGetReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'bucket', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'key', 2, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'r', 3, undef ], @@ -148,8 +148,8 @@ use Google::ProtocolBuffers; 'RpbGetBucketReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'bucket', 1, undef ], @@ -163,18 +163,18 @@ use Google::ProtocolBuffers; 'RpbLink', [ [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'bucket', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'key', 2, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'tag', 3, undef ], @@ -188,13 +188,13 @@ use Google::ProtocolBuffers; 'RpbGetResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_REPEATED(), - 'RpbContent', + Google::ProtocolBuffers::Constants::LABEL_REPEATED(), + 'RpbContent', 'content', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'vclock', 2, undef ], @@ -208,13 +208,13 @@ use Google::ProtocolBuffers; 'RpbPair', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'key', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'value', 2, undef ], @@ -228,13 +228,13 @@ use Google::ProtocolBuffers; 'RpbPutResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_REPEATED(), - 'RpbContent', + Google::ProtocolBuffers::Constants::LABEL_REPEATED(), + 'RpbContent', 'content', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'vclock', 2, undef ], @@ -248,18 +248,18 @@ use Google::ProtocolBuffers; 'RpbDelReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'bucket', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'key', 2, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'rw', 3, undef ], @@ -273,13 +273,13 @@ use Google::ProtocolBuffers; 'RpbMapRedReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'request', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'content_type', 2, undef ], @@ -293,18 +293,18 @@ use Google::ProtocolBuffers; 'RpbMapRedResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'phase', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'response', 2, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BOOL(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BOOL(), 'done', 3, undef ], @@ -318,8 +318,8 @@ use Google::ProtocolBuffers; 'RpbGetClientIdResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'client_id', 1, undef ], @@ -333,13 +333,13 @@ use Google::ProtocolBuffers; 'RpbErrorResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'errmsg', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'errcode', 2, undef ], @@ -353,13 +353,13 @@ use Google::ProtocolBuffers; 'RpbBucketProps', [ [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'n_val', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BOOL(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BOOL(), 'allow_mult', 2, undef ], @@ -373,13 +373,13 @@ use Google::ProtocolBuffers; 'RpbGetServerInfoResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'node', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'server_version', 2, undef ], @@ -393,8 +393,8 @@ use Google::ProtocolBuffers; 'RpbListKeysReq', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'bucket', 1, undef ], @@ -408,13 +408,13 @@ use Google::ProtocolBuffers; 'RpbListKeysResp', [ [ - Google::ProtocolBuffers::Constants::LABEL_REPEATED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REPEATED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'keys', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BOOL(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BOOL(), 'done', 2, undef ], @@ -428,48 +428,48 @@ use Google::ProtocolBuffers; 'RpbContent', [ [ - Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_REQUIRED(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'value', 1, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'content_type', 2, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'charset', 3, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'content_encoding', 4, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_BYTES(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_BYTES(), 'vtag', 5, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REPEATED(), - 'RpbLink', + Google::ProtocolBuffers::Constants::LABEL_REPEATED(), + 'RpbLink', 'links', 6, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'last_mod', 7, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), - Google::ProtocolBuffers::Constants::TYPE_UINT32(), + Google::ProtocolBuffers::Constants::LABEL_OPTIONAL(), + Google::ProtocolBuffers::Constants::TYPE_UINT32(), 'last_mod_usecs', 8, undef ], [ - Google::ProtocolBuffers::Constants::LABEL_REPEATED(), - 'RpbPair', + Google::ProtocolBuffers::Constants::LABEL_REPEATED(), + 'RpbPair', 'usermeta', 9, undef ], |