Skip to main content

Crate wedb_embed

Crate wedb_embed 

Source

Re-exports§

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

Modules§

api
engine
Storage engine abstractions and concrete engine implementations. 存储引擎抽象与具体底层实现。
error
key_composer
meta
wedb
Core WeDb database handles, multi-tenant namespaces, and write batches. WeDb 核心数据库操作句柄、多租户命名空间与批量写入。

Macros§

impl_simple_meta
Macro for implementing standard KeyMeta wrapper types with MetaOps and Deref. 宏:一键实现基于基础 KeyMeta 的复合数据结构元数据及其 MetaOps / Deref 特征

Enums§

RespValue
RESP3 协议数据类型枚举(纯 RESP3 规范实现)

Traits§

Batch
Atomic write batch abstraction across partitions. 跨分区的批量原子写入抽象 (WriteBatch)
Engine
Storage engine abstraction providing partitioned storage and atomic batch writes. 通用底层存储引擎 Trait (Database / Storage Engine)
Partition
Read and write interface for an individual keyspace / partition. 单个分区的读写接口 (Keyspace / Partition)

Functions§

find_crlf
基于 memchr SIMD 加速的 CRLF 扫描定位
parse_i64_fast
高性能无分配 i64 解析
parse_resp
解析 RESP 协议帧(基于字节切片的高性能单次扫描零拷贝解析)
parse_resp_slice
核心切片解析函数:返回 (解析出的拥有型值, 消耗的字节数)