Overview

Module riak_ts_pb

• Data Types
• Function Index
• Function Details

Data Types

'RpbBucketProps.RpbReplMode'()

'RpbBucketProps.RpbReplMode'() = 'FALSE' | 'REALTIME' | 'FULLSYNC' | 'TRUE'

'TsColumnType'()

'TsColumnType'() = 'VARCHAR' | 'SINT64' | 'DOUBLE' | 'TIMESTAMP' | 'BOOLEAN' | 'BLOB'

rpbauthreq()

rpbauthreq() = #rpbauthreq{user = binary(), password = binary()}

rpbbucketprops()

rpbbucketprops() = #rpbbucketprops{n_val = non_neg_integer() | undefined, allow_mult = boolean() | 0 | 1 | undefined, last_write_wins = boolean() | 0 | 1 | undefined, precommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_precommit = boolean() | 0 | 1 | undefined, postcommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_postcommit = boolean() | 0 | 1 | undefined, chash_keyfun = #rpbmodfun{module = binary(), function = binary()} | undefined, linkfun = #rpbmodfun{module = binary(), function = binary()} | undefined, old_vclock = non_neg_integer() | undefined, young_vclock = non_neg_integer() | undefined, big_vclock = non_neg_integer() | undefined, small_vclock = non_neg_integer() | undefined, pr = non_neg_integer() | undefined, r = non_neg_integer() | undefined, w = non_neg_integer() | undefined, pw = non_neg_integer() | undefined, dw = non_neg_integer() | undefined, rw = non_neg_integer() | undefined, basic_quorum = boolean() | 0 | 1 | undefined, notfound_ok = boolean() | 0 | 1 | undefined, backend = binary() | undefined, search = boolean() | 0 | 1 | undefined, repl = 'FALSE' | 'REALTIME' | 'FULLSYNC' | 'TRUE' | integer() | undefined, search_index = binary() | undefined, datatype = binary() | undefined, consistent = boolean() | 0 | 1 | undefined, write_once = boolean() | 0 | 1 | undefined, hll_precision = non_neg_integer() | undefined, ttl = non_neg_integer() | undefined}

rpbcommithook()

rpbcommithook() = #rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}

rpberrorresp()

rpberrorresp() = #rpberrorresp{errmsg = binary(), errcode = non_neg_integer()}

rpbgetbucketreq()

rpbgetbucketreq() = #rpbgetbucketreq{bucket = binary(), type = binary() | undefined}

rpbgetbucketresp()

rpbgetbucketresp() = #rpbgetbucketresp{props = #rpbbucketprops{n_val = non_neg_integer() | undefined, allow_mult = boolean() | 0 | 1 | undefined, last_write_wins = boolean() | 0 | 1 | undefined, precommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_precommit = boolean() | 0 | 1 | undefined, postcommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_postcommit = boolean() | 0 | 1 | undefined, chash_keyfun = #rpbmodfun{module = binary(), function = binary()} | undefined, linkfun = #rpbmodfun{module = binary(), function = binary()} | undefined, old_vclock = non_neg_integer() | undefined, young_vclock = non_neg_integer() | undefined, big_vclock = non_neg_integer() | undefined, small_vclock = non_neg_integer() | undefined, pr = non_neg_integer() | undefined, r = non_neg_integer() | undefined, w = non_neg_integer() | undefined, pw = non_neg_integer() | undefined, dw = non_neg_integer() | undefined, rw = non_neg_integer() | undefined, basic_quorum = boolean() | 0 | 1 | undefined, notfound_ok = boolean() | 0 | 1 | undefined, backend = binary() | undefined, search = boolean() | 0 | 1 | undefined, repl = 'FALSE' | 'REALTIME' | 'FULLSYNC' | 'TRUE' | integer() | undefined, search_index = binary() | undefined, datatype = binary() | undefined, consistent = boolean() | 0 | 1 | undefined, write_once = boolean() | 0 | 1 | undefined, hll_precision = non_neg_integer() | undefined, ttl = non_neg_integer() | undefined}}

rpbgetbuckettypereq()

rpbgetbuckettypereq() = #rpbgetbuckettypereq{type = binary()}

rpbgetserverinforesp()

rpbgetserverinforesp() = #rpbgetserverinforesp{node = binary() | undefined, server_version = binary() | undefined}

rpbmodfun()

rpbmodfun() = #rpbmodfun{module = binary(), function = binary()}

rpbpair()

rpbpair() = #rpbpair{key = binary(), value = binary() | undefined}

rpbresetbucketreq()

rpbresetbucketreq() = #rpbresetbucketreq{bucket = binary(), type = binary() | undefined}

rpbsetbucketreq()

rpbsetbucketreq() = #rpbsetbucketreq{bucket = binary(), props = #rpbbucketprops{n_val = non_neg_integer() | undefined, allow_mult = boolean() | 0 | 1 | undefined, last_write_wins = boolean() | 0 | 1 | undefined, precommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_precommit = boolean() | 0 | 1 | undefined, postcommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_postcommit = boolean() | 0 | 1 | undefined, chash_keyfun = #rpbmodfun{module = binary(), function = binary()} | undefined, linkfun = #rpbmodfun{module = binary(), function = binary()} | undefined, old_vclock = non_neg_integer() | undefined, young_vclock = non_neg_integer() | undefined, big_vclock = non_neg_integer() | undefined, small_vclock = non_neg_integer() | undefined, pr = non_neg_integer() | undefined, r = non_neg_integer() | undefined, w = non_neg_integer() | undefined, pw = non_neg_integer() | undefined, dw = non_neg_integer() | undefined, rw = non_neg_integer() | undefined, basic_quorum = boolean() | 0 | 1 | undefined, notfound_ok = boolean() | 0 | 1 | undefined, backend = binary() | undefined, search = boolean() | 0 | 1 | undefined, repl = 'FALSE' | 'REALTIME' | 'FULLSYNC' | 'TRUE' | integer() | undefined, search_index = binary() | undefined, datatype = binary() | undefined, consistent = boolean() | 0 | 1 | undefined, write_once = boolean() | 0 | 1 | undefined, hll_precision = non_neg_integer() | undefined, ttl = non_neg_integer() | undefined}, type = binary() | undefined}

rpbsetbuckettypereq()

rpbsetbuckettypereq() = #rpbsetbuckettypereq{type = binary(), props = #rpbbucketprops{n_val = non_neg_integer() | undefined, allow_mult = boolean() | 0 | 1 | undefined, last_write_wins = boolean() | 0 | 1 | undefined, precommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_precommit = boolean() | 0 | 1 | undefined, postcommit = [#rpbcommithook{modfun = #rpbmodfun{module = binary(), function = binary()} | undefined, name = binary() | undefined}], has_postcommit = boolean() | 0 | 1 | undefined, chash_keyfun = #rpbmodfun{module = binary(), function = binary()} | undefined, linkfun = #rpbmodfun{module = binary(), function = binary()} | undefined, old_vclock = non_neg_integer() | undefined, young_vclock = non_neg_integer() | undefined, big_vclock = non_neg_integer() | undefined, small_vclock = non_neg_integer() | undefined, pr = non_neg_integer() | undefined, r = non_neg_integer() | undefined, w = non_neg_integer() | undefined, pw = non_neg_integer() | undefined, dw = non_neg_integer() | undefined, rw = non_neg_integer() | undefined, basic_quorum = boolean() | 0 | 1 | undefined, notfound_ok = boolean() | 0 | 1 | undefined, backend = binary() | undefined, search = boolean() | 0 | 1 | undefined, repl = 'FALSE' | 'REALTIME' | 'FULLSYNC' | 'TRUE' | integer() | undefined, search_index = binary() | undefined, datatype = binary() | undefined, consistent = boolean() | 0 | 1 | undefined, write_once = boolean() | 0 | 1 | undefined, hll_precision = non_neg_integer() | undefined, ttl = non_neg_integer() | undefined}}

tscell()

tscell() = #tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}

tscolumndescription()

tscolumndescription() = #tscolumndescription{name = binary(), type = 'VARCHAR' | 'SINT64' | 'DOUBLE' | 'TIMESTAMP' | 'BOOLEAN' | 'BLOB' | integer()}

tscoverageentry()

tscoverageentry() = #tscoverageentry{ip = binary(), port = non_neg_integer(), cover_context = binary(), range = #tsrange{field_name = binary(), lower_bound = integer(), lower_bound_inclusive = boolean() | 0 | 1, upper_bound = integer(), upper_bound_inclusive = boolean() | 0 | 1, desc = binary()} | undefined}

tscoveragereq()

tscoveragereq() = #tscoveragereq{query = #tsinterpolation{base = binary(), interpolations = [#rpbpair{key = binary(), value = binary() | undefined}]} | undefined, table = binary(), replace_cover = binary() | undefined, unavailable_cover = [binary()]}

tscoverageresp()

tscoverageresp() = #tscoverageresp{entries = [#tscoverageentry{ip = binary(), port = non_neg_integer(), cover_context = binary(), range = #tsrange{field_name = binary(), lower_bound = integer(), lower_bound_inclusive = boolean() | 0 | 1, upper_bound = integer(), upper_bound_inclusive = boolean() | 0 | 1, desc = binary()} | undefined}]}

tsdelreq()

tsdelreq() = #tsdelreq{table = binary(), key = [#tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}], vclock = binary() | undefined, timeout = non_neg_integer() | undefined}

tsdelresp()

tsdelresp() = #tsdelresp{}

tsgetreq()

tsgetreq() = #tsgetreq{table = binary(), key = [#tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}], timeout = non_neg_integer() | undefined}

tsgetresp()

tsgetresp() = #tsgetresp{columns = [#tscolumndescription{name = binary(), type = 'VARCHAR' | 'SINT64' | 'DOUBLE' | 'TIMESTAMP' | 'BOOLEAN' | 'BLOB' | integer()}], rows = [#tsrow{cells = [#tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}]}]}

tsinterpolation()

tsinterpolation() = #tsinterpolation{base = binary(), interpolations = [#rpbpair{key = binary(), value = binary() | undefined}]}

tslistkeysreq()

tslistkeysreq() = #tslistkeysreq{table = binary(), timeout = non_neg_integer() | undefined}

tslistkeysresp()

tslistkeysresp() = #tslistkeysresp{keys = [#tsrow{cells = [#tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}]}], done = boolean() | 0 | 1 | undefined}

tsputreq()

tsputreq() = #tsputreq{table = binary(), columns = [#tscolumndescription{name = binary(), type = 'VARCHAR' | 'SINT64' | 'DOUBLE' | 'TIMESTAMP' | 'BOOLEAN' | 'BLOB' | integer()}], rows = [#tsrow{cells = [#tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}]}]}

tsputresp()

tsputresp() = #tsputresp{}

tsqueryreq()

tsqueryreq() = #tsqueryreq{query = #tsinterpolation{base = binary(), interpolations = [#rpbpair{key = binary(), value = binary() | undefined}]} | undefined, stream = boolean() | 0 | 1 | undefined, cover_context = binary() | undefined}

tsqueryresp()

tsqueryresp() = #tsqueryresp{columns = [#tscolumndescription{name = binary(), type = 'VARCHAR' | 'SINT64' | 'DOUBLE' | 'TIMESTAMP' | 'BOOLEAN' | 'BLOB' | integer()}], rows = [#tsrow{cells = [#tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}]}], done = boolean() | 0 | 1 | undefined}

tsrange()

tsrange() = #tsrange{field_name = binary(), lower_bound = integer(), lower_bound_inclusive = boolean() | 0 | 1, upper_bound = integer(), upper_bound_inclusive = boolean() | 0 | 1, desc = binary()}

tsrow()

tsrow() = #tsrow{cells = [#tscell{varchar_value = binary() | undefined, sint64_value = integer() | undefined, timestamp_value = integer() | undefined, boolean_value = boolean() | 0 | 1 | undefined, double_value = float() | integer() | infinity | '-infinity' | nan | undefined}]}

Function Index

Function Details

'enum_symbol_by_value_RpbBucketProps.RpbReplMode'/1

'enum_value_by_symbol_RpbBucketProps.RpbReplMode'/1

decode/2

decode_msg/2

decode_msg/3

decode_rpbauthreq/1

decode_rpbbucketprops/1

decode_rpbcommithook/1

decode_rpberrorresp/1

decode_rpbgetbucketreq/1

decode_rpbgetbucketresp/1

decode_rpbgetbuckettypereq/1

decode_rpbgetserverinforesp/1

decode_rpbmodfun/1

decode_rpbpair/1

decode_rpbresetbucketreq/1

decode_rpbsetbucketreq/1

decode_rpbsetbuckettypereq/1

decode_tscell/1

decode_tscolumndescription/1

decode_tscoverageentry/1

decode_tscoveragereq/1

decode_tscoverageresp/1

decode_tsdelreq/1

decode_tsdelresp/1

decode_tsgetreq/1

decode_tsgetresp/1

decode_tsinterpolation/1

decode_tslistkeysreq/1

decode_tslistkeysresp/1

decode_tsputreq/1

decode_tsputresp/1

decode_tsqueryreq/1

decode_tsqueryresp/1

decode_tsrange/1

decode_tsrow/1

encode/1

encode_msg/1

encode_msg/2

encode_rpbauthreq/1

encode_rpbbucketprops/1

encode_rpbcommithook/1

encode_rpberrorresp/1

encode_rpbgetbucketreq/1

encode_rpbgetbucketresp/1

encode_rpbgetbuckettypereq/1

encode_rpbgetserverinforesp/1

encode_rpbmodfun/1

encode_rpbpair/1

encode_rpbresetbucketreq/1

encode_rpbsetbucketreq/1

encode_rpbsetbuckettypereq/1

encode_tscell/1

encode_tscolumndescription/1

encode_tscoverageentry/1

encode_tscoveragereq/1

encode_tscoverageresp/1

encode_tsdelreq/1

encode_tsdelresp/1

encode_tsgetreq/1

encode_tsgetresp/1

encode_tsinterpolation/1

encode_tslistkeysreq/1

encode_tslistkeysresp/1

encode_tsputreq/1

encode_tsputresp/1

encode_tsqueryreq/1

encode_tsqueryresp/1

encode_tsrange/1

encode_tsrow/1

enum_symbol_by_value/2

enum_symbol_by_value_TsColumnType/1

enum_value_by_symbol/2

enum_value_by_symbol_TsColumnType/1

fetch_enum_def/1

fetch_msg_def/1

fetch_rpc_def/2

find_enum_def/1

find_msg_def/1

find_rpc_def/2

get_enum_names/0

get_msg_defs/0

get_msg_names/0

get_package_name/0

get_rpc_names/1

get_service_def/1

get_service_names/0

gpb_version_as_list/0

gpb_version_as_string/0

merge_msgs/2

merge_msgs/3

verify_msg/1

verify_msg/2

Overview

Generated by EDoc