ruststream 0.7.0-rc.7

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.
Documentation
# API 参考

完整的 Rust API 参考由 rustdoc 生成,发布在 docs.rs 上。本站讲解安装、教程、Broker 与 Broker 作者的契约;各功能模块的文档见 docs.rs。

- **[docs.rs 上的 ruststream]https://docs.rs/ruststream**,即该 crate。AsyncAPI、指标和 conformance
  各模块只在启用相应 feature 的构建里可见:
  [docs.rs/ruststream(全部 feature)]https://docs.rs/crate/ruststream/latest/features。

`ruststream` 命令行工具由同一个 crate 的 `cli` feature 提供。参见
[`runtime::cli`](https://docs.rs/ruststream/latest/ruststream/runtime/cli/index.html)。

## 在本地构建参考文档

```bash
cargo doc --all-features --open
```

## 主要入口

| 条目 | 模块 | 用途 |
|---|---|---|
| `RustStream` | `ruststream::runtime` | 应用对象 |
| `RunningApp` | `ruststream::runtime` | 已启动服务的句柄:就绪、fail-fast 故障信号和优雅关闭 |
| `Router` | `ruststream::runtime` | 一组处理器,在挂载时获得 Broker |
| `Handle`、`subscriber` | `ruststream::runtime` | 手写注册:处理器函数体的 trait,以及把函数体绑定到订阅来源 |
| `FromContext`、`State`、`FromRef` | `ruststream::runtime` / `ruststream` | 处理器的提取器参数,以及注入状态的 derive |
| `Broker`、`Subscribe`、`Subscriber`、`Publisher`、`IncomingMessage` | `ruststream` | Broker 契约 |
| `SubscriptionSource`、`Name` | `ruststream` | 订阅描述符 |
| `JsonCodec`、`MsgpackCodec`、`CborCodec` | `ruststream::codec` | 传输格式的编解码器 |
| `build_spec` | `ruststream::asyncapi` | 生成 AsyncAPI 文档 |
| `Metrics` | `ruststream::metrics` | Prometheus 指标 |
| `TestApp` | `ruststream::testing` | 应用的进程内单元测试套件 |
| `TestableBroker` | `ruststream::testing` | Broker 进程内传输实现的契约 |
| `harness::run_suite` | `ruststream::conformance` | 供 Broker 作者使用的校验套件 |