wedb_embed 0.1.13

Embedded database engine providing Redis-like APIs, built on fjall / 嵌入式数据库引擎,提供类似 Redis 的接口,底层基于 fjall 开发
Documentation
pub mod api;
pub mod engine;
pub mod error;
pub mod key_composer;
pub mod meta;
pub mod wedb;

pub use api::{
  bitmap, bloom, geo, hash, hll, json, key, list, search, set, sortedint, stream, string, tdigest,
  timeseries, zset,
};
pub use bitmap::{
  ArrayBitfieldBitmap, BITMAP_SEGMENT_BITS, BITMAP_SEGMENT_BYTES, BitCount, BitOp, BitPos, BitUnit,
  BitfieldEncoding, BitfieldOpType, BitfieldOperation, BitfieldOverflow, BitfieldValue, BitmapMeta,
  MAX_BITMAP_TO_STRING_BYTES, bit_op_exec, bit_op_exec_into, bitfield_op_calc,
  expand_bitmap_segment, find_bit_in_byte_lsb, find_bit_in_byte_msb, get_bit_from_bytes,
  get_bit_lsb, normalize_to_byte_range_with_padding_mask, parse_bitfield_offset, raw_bitpos_lsb,
  raw_popcount, segment_byte_offset_for_bit, segment_index_for_bit, set_bit_in_bytes, set_bit_lsb,
  string_bitcount, string_bitpos,
};
pub use bloom::{
  BfInsert, BfReserve, BlockSplitBloomFilter, BloomChainMeta, BloomFilterAddResult,
  BloomFilterInfo, BloomFilterInsert, CfInsert, CfReserve, CuckooChainMeta, CuckooFilterHelper,
  CuckooFilterInfo, CuckooFilterInsert,
};
pub use engine::{Batch, Engine, Fjall, Partition};
pub use error::{ERR_NO_SUCH_KEY, ERR_WRONG_TYPE, Error, Result};
pub use geo::{
  DistanceSort, DistanceUnit, GeoHashArea, GeoHashBits, GeoHashNeighbors, GeoHashRadius,
  GeoHashRange, GeoPoint, GeoRadius, GeoSearch, GeoSearchStore, GeoShape, GeoShapeType,
  OriginPoint, base32_to_coords, coords_to_base32, geohash_to_base32,
};
pub use hash::{
  FIELD_EXPIRE_PREFIX_LEN, FieldValue, HExpire, HGetEx, HSet, HashFieldPair, HashFieldSetCondition,
  HashGetEx, HashLengthMode, HashMeta, HashRandField, HashScanResult, HashSetEx,
  HashSubkeyEncodingMode, TTLAction, decode_hash_value, decode_live_hash_value, encode_hash_value,
  encode_hash_value_into, is_field_expired,
};
pub use hll::{
  HLL_ALPHA_INF, HLL_DENSE_SIZE, HLL_HASH_BIT_COUNT, HLL_HASH_SEED, HLL_REGISTER_COUNT_MASK,
  HLL_REGISTER_COUNT_POW, HLL_REGISTER_MAX, HLL_REGISTERS, HLL_SEGMENT_BYTES, HLL_SEGMENT_COUNT,
  HLL_SEGMENT_REGISTERS, HLL_SPARSE_MAX_BYTES, HllEncodeType, HllSparseOp, HyperLogLog,
  HyperLogLogMeta, decode_sparse_op, dense_estimate, extract_dense_hll_result, get_register,
  hll_dense_estimate, hll_dense_estimate_segments, hll_dense_get_register, hll_dense_reg_histo,
  hll_dense_set_register, hll_dense_to_sparse, hll_estimate_from_histo, hll_merge_bytes,
  hll_merge_segments, hll_merge_sparse_into_dense, hll_murmur_hash_64a, hll_sigma,
  hll_sparse_estimate, hll_sparse_get_register, hll_sparse_is_valid, hll_sparse_new,
  hll_sparse_reg_histo, hll_sparse_set_register, hll_sparse_to_dense, hll_tau, murmur_hash_64a,
  rapid_hash, set_register,
};
pub use json::{
  JsonArrIndex, JsonGet, JsonMeta, JsonNumberOp, JsonSet, JsonStorageFormat, delete_path_values,
  extract_simple_field, get_path_values, json_transform_resp, mutate_path_values, parse_json_path,
};
pub use key::{DBScanInfo, ExpireCondition, KeyNumStats, SortArgs};
pub use key_composer::{
  ALL_COMPOSITE_META_TAGS, CATALOG_PREFIX, DEFAULT_NAMESPACE, HASH_SLOTS_MASK, HASH_SLOTS_SIZE,
  INLINE_CAP, KeyComposer, KeyTag, NS_NEXT_ID_KEY, SmallKey, SubkeyComposer, SystemDomainTag,
  catalog_db_key, catalog_ns_prefix, compose_slot_key_prefix, compose_slot_key_upper_bound, crc16,
  decode_oppv_u64, encode_oppv_u64, encode_oppv_u64_fixed, encode_slot_key_prefix_fixed,
  get_slot_id_from_key, get_tag_from_key, is_default_namespace, matches_glob, matches_glob_bytes,
  oppv_len_u64,
};
pub use list::{LPos, ListMeta, ListPopResult};
pub use meta::{
  IntoIndexRange, KeyMeta, RedisType, current_now_ms, current_now_sec, generate_version,
  init_version_counter, normalize_range, version_to_time,
};
pub use search::{
  AggregateResult, AggregateRow, Candidate, DEFAULT_STOP_WORDS, DistanceMetric, FtAggregate,
  FtAliasAdd, FtAliasDel, FtAliasUpdate, FtConfigCommand, FtCreate, FtDropIndex, FtFieldInfo,
  FtGroupBy, FtIndexDefinition, FtInfo, FtList, FtReducer, FtSearch, FtSugAdd, FtSugDel, FtSugGet,
  FtSugLen, FtTagVals, HnswGraph, HnswLevelType, HnswNode, IndexField, IndexFieldType,
  IndexOnDataType, InvertedIndex, MinCandidate, NodePackFormat, NodePackRef, OppvDeltaNeighborIter,
  Posting, SearchDoc, SearchIndexManager, SearchIndexSchema, SearchKey, SearchQueryNode,
  SearchResult, SearchSubkeyType, Sq8Vector, SuggestionDict, SuggestionItem, VectorAlgorithm,
  VectorFieldMetadata, VectorType, compute_vector_distance, decode_hnsw_node_meta,
  decode_hnsw_vector_field_meta, decode_index_meta, decode_index_prefixes,
  decode_numeric_field_meta, decode_sortable_f64, decode_sortable_f64_u64, decode_sortable_i64,
  decode_tag_field_meta, encode_hnsw_node_meta, encode_hnsw_vector_field_meta, encode_index_meta,
  encode_index_prefixes, encode_numeric_field_meta, encode_sortable_f64, encode_sortable_f64_u64,
  encode_sortable_i64, encode_tag_field_meta, explain_search_query, explain_search_query_cli,
  extract_doc_terms, levenshtein_distance, parse_search_query, parse_search_query_with_params,
  parse_vector_from_slice, tokenize_tags, tokenize_text, tokenize_text_with_stopwords,
  unescape_tag_string,
};
pub use set::{SetMeta, SetScanByMemberResult, SetScanResult};
pub use sortedint::{IntoSortedintRange, SortedintMeta, SortedintRange, parse_range_spec};
pub use stream::{
  NextStreamEntryIdStrategy, StreamAdd, StreamAutoClaim, StreamAutoClaimResult, StreamClaim,
  StreamClaimResult, StreamConsumerGroupMeta, StreamConsumerMeta, StreamEntry,
  StreamGetPendingEntryResult, StreamId, StreamInfo, StreamLen, StreamMeta, StreamNack,
  StreamPelEntry, StreamPending, StreamRange, StreamRead, StreamSubkeyType, StreamTrim,
  StreamTrimStrategy, StreamXGroupCreate, XAdd, XAutoClaim, XClaim, XGroupCreate, XPending, XRange,
  XRead, XTrim, decode_stream_entry_fields, decode_stream_entry_fields_borrowed,
  decode_stream_entry_raw_bytes, encode_stream_entry_fields, encode_stream_entry_pairs,
};
pub use string::{
  DelEx, GetEx, Lcs, Set, StringLCS, StringLCSIdxResult, StringLCSMatchedRange, StringLCSRange,
  StringLCSResult, StringLCSType, StringMSet, StringMeta, StringPair, StringSet, StringSetType,
  decode_live_string_value, decode_string_value, encode_string_value, encode_string_value_into,
  format_float, format_float_bytes, is_string_expired,
};
pub use tdigest::{
  ABS_EPS, Centroid, CentroidsWithDelta, REL_EPS, ScalerK1, TDigestCreate, TDigestInfo,
  TDigestMerge, TDigestMerger, TDigestMergerTool, TDigestMeta, TDigestState, calculate_capacity,
  decode_double_from_u64, double_compare, double_equal, encode_double_to_u64, lerp,
  tdigest_by_rank_calc, tdigest_cdf_calc, tdigest_merge_buffer_and_centroids,
  tdigest_merge_centroids_list, tdigest_quantile_calc, tdigest_rank_calc,
  tdigest_trimmed_mean_calc,
};
pub use timeseries::{
  AggregationType, Aggregator, BucketTimestampType, ChunkHeader, ChunkType, DuplicatePolicy,
  GroupReducerType, IntoTsRange, TSChunk, TSDownStreamMeta, TSSample, TsCreate, TsFilter,
  TsInfoResult, TsMGet, TsMGetResult, TsMRange, TsMRangeResult, TsRange,
};
pub use wedb::{DATA, Db, DbBatch, Dbs, IntoOptId, META, Namespace, Namespaces, WeDb};
pub use wedb_resp::{RespValue, find_crlf, parse_i64_fast, parse_resp, parse_resp_slice};
pub use zset::{
  Aggregate, IntoRangeLex, IntoRangeRank, IntoRangeScore, RangeLex, RangeRank, RangeScore, ZAdd,
  ZRange, ZScanResult, ZSetKeyMemberScore, ZSetMemberScore, ZSetMeta, ZSetPopResult,
  ZSetScanByMemberResult,
};