2个不稳定版本
0.1.0 | 2021年5月12日 |
---|---|
0.0.99 | 2021年4月29日 |
#2903 在 数据库接口
每月41次 下载
88KB
580 行
TiKV客户端(Rust)
本crate提供了一个易于使用的TiKV客户端,TiKV是一个用Rust编写的分布式、事务型键值数据库。
此crate允许您连接到TiKV(>= v5.0.0
) 集群,并使用事务型或原始(简单的get/put风格,不带事务一致性保证)API来访问和更新您的数据。
TiKV Rust客户端是一个开源(Apache 2)项目,由TiKV作者维护。我们欢迎贡献,以下有更多信息。
请注意,当前版本不适用于生产使用——API尚不稳定,crate在真实使用场景中尚未经过充分测试。
入门指南
TiKV客户端是一个Rust库(crate)。要在项目中使用此crate,请将以下依赖项添加到您的 Cargo.toml
[dependencies]
tikv-client = "0.3"
先决条件
rust
>=1.56.1
,这是hashbrown-v0.12.1
所必需的
使用客户端crate的一般流程是创建一个原始或事务客户端对象(可以进行配置),然后使用客户端对象发送命令,或者使用它来创建事务对象。在后一种情况下,事务是通过各种命令构建的,然后提交(或回滚)。
示例
原始模式
use tikv_client::RawClient;
let client = RawClient::new(vec!["127.0.0.1:2379"], None).await?;
client.put("key".to_owned(), "value".to_owned()).await?;
let value = client.get("key".to_owned()).await?;
事务模式
use tikv_client::TransactionClient;
let txn_client = TransactionClient::new(vec!["127.0.0.1:2379"], None).await?;
let mut txn = txn_client.begin_optimistic().await?;
txn.put("key".to_owned(), "value".to_owned()).await?;
let value = txn.get("key".to_owned()).await?;
txn.commit().await?;
由于TiKV客户端提供异步API,您需要使用异步运行时(我们目前仅支持Tokio)。有关完整示例,请参阅 getting-started.md。
API摘要
TiKV Rust 客户端支持多个抽象级别。使用客户端最方便的方式是通过 RawClient
和 TransactionClient
。这提供了一个非常高级的 API,它主要抽象了存储的分布式特性,并为所有协议提供了合理的默认值。这个接口可以进行配置,主要是通过创建客户端或事务对象时使用的 Config
和 TransactionOptions
结构体。使用一些选项,您可以自己接管部分协议(例如重试失败的消息)。
最低级别的抽象是直接创建并发送 gRPC 消息到 TiKV(和 PD)节点。`tikv-client-store` 和 `tikv-client-pd` 插件使得使用 protobuf 定义和直接使用 gRPC 库相比更容易,但您将拥有相同级别的控制。
在这两个抽象级别之间,您可以向 TiKV 集群发送和接收单个消息,同时利用库代码进行常见操作,例如将数据解析到区域和集群中的节点,或重试失败的消息。这对于测试 TiKV 集群或某些高级用例很有用。请参阅 client_rust::request
模块以了解此 API,以及 client_rust::raw::lowering
和 client_rust::transaction::lowering
以了解创建请求对象的便捷方法。
本文件的其余部分仅描述 RawClient
/TransactionClient
API。
重要提示:**不推荐或支持**在同一个数据库上同时使用原始和事务性 API。
类型
Key
:存储中的键。`String` 和 `VecInto<Key>
,因此您可以直接将它们传递给客户端函数。
Value
:存储中的值;只是 Vec<u8>
的别名。
KvPair
:一个 Key
和一个 Value
的对。它提供了转换到和从其他类型的便捷方法。
BoundRange
:用于范围相关的请求,如 scan
。它实现了 Rust 范围的 From
,因此您可以传递 Rust 键范围到请求中,例如,client.delete_range(vec![]..)
。
原始请求
请求 | 主要参数类型 | 结果类型 | 值得注意的行为 |
---|---|---|---|
put |
KvPair |
||
get |
Key |
Option<Value> |
|
delete |
Key |
||
delete_range |
BoundRange |
||
scan |
BoundRange |
Vec<KvPair> |
|
batch_put |
Iter<KvPair> |
||
batch_get |
Iter<Key> |
Vec<KvPair> |
跳过不存在的键;不保留顺序 |
batch_delete |
Iter<Key> |
||
batch_scan |
Iter<BoundRange> |
Vec<KvPair> |
有关 each_limit 参数行为的说明,请参阅文档。保留范围顺序。 |
batch_scan_keys |
Iter<BoundRange> |
Vec<Key> |
有关 each_limit 参数行为的说明,请参阅文档。保留范围顺序。 |
compare_and_swap |
Key + 2x Value |
(Option<Value>, bool) |
事务性请求
请求 | 主要参数类型 | 结果类型 | 值得注意的行为 |
---|---|---|---|
put |
KvPair |
||
get |
Key |
Option<value> |
|
get_for_update |
Key |
Option<value> |
|
key_exists |
Key |
bool |
|
delete |
Key |
||
scan |
BoundRange |
Iter<KvPair> |
|
scan_keys |
BoundRange |
Iter<Key> |
|
batch_get |
Iter<Key> |
Iter<KvPair> |
跳过不存在的键;不保留顺序 |
batch_get_for_update |
Iter<Key> |
Iter<KvPair> |
跳过不存在的键;不保留顺序 |
锁键 |
Iter<Key> |
||
发送心跳 |
u64 (TTL) |
||
垃圾回收 |
时间戳 |
bool |
如果PD中最近的safepoint等于参数,则返回true |
开发和贡献
我们欢迎您的贡献!贡献代码是很好的,我们也欣赏提交问题来识别错误和提供反馈,添加测试或示例,以及改进文档。
构建和测试
我们使用标准的Cargo工作流程,例如,使用cargo build
来构建,并使用cargo test/nextest
来运行单元测试。您需要使用夜间的Rust工具链来构建和运行测试。可以使用nextest来加速ut,首先安装nextest。
cargo install cargo-nextest --locked
运行集成测试或手动使用TiKV集群测试客户端稍微复杂一些。最简单的方法是使用TiUp (>= 1.5) 在您的本地机器上初始化一个集群。
tiup playground nightly --mode tikv-slim
然后如果您想运行集成测试
PD_ADDRS="127.0.0.1:2379" cargo test --package tikv-client --test integration_tests --features integration-tests
创建PR
我们使用标准的GitHub PR工作流程。我们为每个PR运行CI,并要求所有PR在构建时没有警告(包括clippy和Rustfmt警告),通过测试,有DCO签出(在提交时使用-s
,DCO机器人将引导您完成第一次PR的DCO协议),并且至少有一个审查。如果您在这方面的任何方面有困难,请不要担心,并在PR上提问。
要本地运行类似CI的测试,我们建议您在提交PR之前运行cargo clippy
、cargo test/nextest run
和cargo fmt
。有关运行集成测试的说明,但您可能不需要为您的第一次几个PR担心这一点。
请遵循PingCAP的Rust风格指南。所有代码PR都应该包括新的测试或测试用例。
寻求帮助
如果您需要帮助,无论是寻找可以工作的东西,还是任何技术问题,最容易的方式是通过internals.tidb.io,这是TiDB开发者的论坛。
您也可以在Slack中提问。我们监控tikv-wg slack上的#client-rust频道。
您可以直接在GitHub issues或PR上提问;如果您没有得到回复,您应该ping @ekexium或@andylokandy。
依赖项
~41MB
~813K SLoC