TODO(wutao): call it add_returned_advice()

not thread-safe

extern*/

* Returns the number of tokens currently available. * * Thread-safe (but returned value may immediately be outdated). */

the order of dropped_replica ret: 0 => equal negtive => d1 smaller than d2 positive => d1 larger than d2

sync version of Exist, please refer to the async version {@link #asyncExist(byte[], byte[], int)}

Extracts expire_ts from rocksdb value with given version. The value schema must be in v0 or v1. \return expire_ts in host endian

add a blob into the block

Create a client instance. After used, should call client.close() to release resource. @param configPath client config path,could be: <pre> - zook

Check value exist by key from the cluster @param tableName TableHandler name @param hashKey used to decide which partition the key may exist. @param

Get Scanner for {startSortKey, stopSortKey} within hashKey. startSortKey: nil or len(startSortKey) == 0 means start from begin. stopSortKey: nil or le

Unmarshal parses the wire format into v.

string_view::cbegin() Returns a const iterator pointing to the first character at the beginning of the `string_view`, or `end()` if the `string_view`

* Reserve tokens. Blocks if need be until reservation is satisfied. */

extern*/

Judge whether scan completed @return Return false if no data left, return true means some data left. @throws PException

Get multiple values stored in hash_key, and sort key range in [start_sort_key, stop_sort_key) as default. :param hash_key: (bytes) w