contents() = [{metadata(), value()}]
metadata() = dict()
preflist_with_pnum_ann() = [{{non_neg_integer(), node()}, primary | fallback}]
quorum() = symbolic_quorum() | non_neg_integer()
symbolic_quorum() = one | quorum | all | default
value() = binary()
| decode_content/1 | Convert an rpccontent pb message to an erlang {MetaData,Value} tuple. |
| decode_content_meta/3 | |
| decode_contents/1 | Convert a list of rpbcontent pb messages to a list of [{MetaData,Value}] tuples. |
| decode_link/1 | Convert RpbLink PB message to erlang link tuple. |
| decode_pair/1 | Convert RpbPair PB message to erlang {K,V} tuple. |
| decode_quorum/1 | Decodes a Protocol Buffers value into a symbolic or numeric quorum. |
| encode_apl_ann/1 | Convert preflist to RpbBucketKeyPreflist. |
| encode_content/1 | Convert a metadata/value pair into an #rpbcontent{} record. |
| encode_content_meta/3 | Convert the metadata dictionary entries to protocol buffers. |
| encode_contents/1 | Convert a list of object {MetaData,Value} pairs to protocol buffers messages. |
| encode_index_pair/1 | Convert {K,V} index entries into protocol buffers. |
| encode_link/1 | Convert erlang link tuple to RpbLink PB message. |
| encode_pair/1 | Convert {K,V} tuple to protocol buffers. |
| encode_quorum/1 | Encode a symbolic or numeric quorum value into a Protocol Buffers value. |
decode_content(PBContent::tuple()) -> {metadata(), binary()}
Convert an rpccontent pb message to an erlang {MetaData,Value} tuple
decode_content_meta(X1::atom(), CType::any(), Rpbcontent::#rpbcontent{value = binary(), content_type = binary() | undefined, charset = binary() | undefined, content_encoding = binary() | undefined, vtag = binary() | undefined, links = [#rpblink{bucket = binary() | undefined, key = binary() | undefined, tag = binary() | undefined}], last_mod = non_neg_integer() | undefined, last_mod_usecs = non_neg_integer() | undefined, usermeta = [#rpbpair{key = binary(), value = binary() | undefined}], indexes = [#rpbpair{key = binary(), value = binary() | undefined}], deleted = boolean() | 0 | 1 | undefined, ttl = non_neg_integer() | undefined}) -> [{binary(), any()}]
decode_contents(PBContents::[tuple()]) -> contents()
Convert a list of rpbcontent pb messages to a list of [{MetaData,Value}] tuples
decode_link(PBLink::#rpblink{bucket = binary() | undefined, key = binary() | undefined, tag = binary() | undefined}) -> {{binary(), binary()}, binary()}
Convert RpbLink PB message to erlang link tuple
decode_pair(Rpbpair::#rpbpair{key = binary(), value = binary() | undefined}) -> {binary(), binary()}
Equivalent to riak_pb_codec:decode_pair / 1.
Convert RpbPair PB message to erlang {K,V} tuple
decode_quorum(I::non_neg_integer()) -> quorum()
Decodes a Protocol Buffers value into a symbolic or numeric quorum.
encode_apl_ann(Preflist::preflist_with_pnum_ann()) -> PBPreflist::[#rpbbucketkeypreflistitem{partition = integer(), node = binary(), primary = boolean() | 0 | 1}]
Convert preflist to RpbBucketKeyPreflist.
encode_content(C::{metadata(), value()}) -> #rpbcontent{value = binary(), content_type = binary() | undefined, charset = binary() | undefined, content_encoding = binary() | undefined, vtag = binary() | undefined, links = [#rpblink{bucket = binary() | undefined, key = binary() | undefined, tag = binary() | undefined}], last_mod = non_neg_integer() | undefined, last_mod_usecs = non_neg_integer() | undefined, usermeta = [#rpbpair{key = binary(), value = binary() | undefined}], indexes = [#rpbpair{key = binary(), value = binary() | undefined}], deleted = boolean() | 0 | 1 | undefined, ttl = non_neg_integer() | undefined}
Convert a metadata/value pair into an #rpbcontent{} record
encode_content_meta(MetadataKey::string(), ContentType::any(), PbContent::tuple()) -> tuple()
Convert the metadata dictionary entries to protocol buffers
encode_contents(List::contents()) -> [#rpbcontent{value = binary(), content_type = binary() | undefined, charset = binary() | undefined, content_encoding = binary() | undefined, vtag = binary() | undefined, links = [#rpblink{bucket = binary() | undefined, key = binary() | undefined, tag = binary() | undefined}], last_mod = non_neg_integer() | undefined, last_mod_usecs = non_neg_integer() | undefined, usermeta = [#rpbpair{key = binary(), value = binary() | undefined}], indexes = [#rpbpair{key = binary(), value = binary() | undefined}], deleted = boolean() | 0 | 1 | undefined, ttl = non_neg_integer() | undefined}]
Convert a list of object {MetaData,Value} pairs to protocol buffers messages.
encode_index_pair(E::{binary(), integer() | binary()}) -> #rpbpair{key = binary(), value = binary() | undefined}
Convert {K,V} index entries into protocol buffers
encode_link(X1::{{binary(), binary()}, binary() | string()}) -> #rpblink{bucket = binary() | undefined, key = binary() | undefined, tag = binary() | undefined}
Convert erlang link tuple to RpbLink PB message
encode_pair(Pair::{Key::binary(), Value::any()}) -> #rpbpair{key = binary(), value = binary() | undefined}
Equivalent to riak_pb_codec:encode_pair / 1.
Convert {K,V} tuple to protocol buffers
encode_quorum(Bin::quorum()) -> non_neg_integer()
Encode a symbolic or numeric quorum value into a Protocol Buffers value
Generated by EDoc