Using AsyncRead and AsyncWrite directly Reading data with AsyncRead Writing data with AsyncWrite Shutdown An example of using AsyncWrite Using AsyncRead and AsyncWrite dire...

快速开始 1 前置条件 2 使用 IDL 定义 Dubbo 服务 3 添加 Dubbo-rust 及相关依赖到项目 4 配置 dubbo-build 编译 IDL 5 编写 Dubbo 业务代码 5.1 编写 Dubbo Server 5.2 配置dubbo.yaml 5.3 编写 Dubbo Client 6 运行并总结 快速开始 ...

Rust client Setup Connecting to OpenSearch Creating an index Indexing a document Performing bulk operations Searching for documents Deleting a document Deleting an index Sa...

Iteration Mini-Redis broadcast Iteration Currently, the Rust programming language does not support async for loops. Instead, iterating streams is done using a while let loop...

A few loose ends Notify utility A few loose ends Recall when we were implementing the Delay future, we said there were a few more things to fix. Rust’s asynchronous model al...

Building a runtime The Park trait The usual components Global state Building a runtime The runtime ‒ all the pieces needed to run an event driven application ‒ isalready ...

How to write a gRPC SDK for GreptimeDB How to use tokio-console in GreptimeDB

How to write a gRPC SDK for GreptimeDB How to use tokio-console in GreptimeDB

Futures 同步模型 非阻塞套接字 仔细看看期货 基于轮询模型的Future The Future trait Futures 让我们仔细看看futures。Tokio构建在futures crate 之上并使用其运行时模型。这允许它也使用futures库与其他库互操作。 注意：此运行时模型与其他语言中的异步库非常不同。虽然在较高的层...

Rust client Setup Connecting to OpenSearch Connecting to Amazon OpenSearch Service Connecting to Amazon OpenSearch Serverless Creating an index Indexing a document Performing...