跳转至

API 参考

英文版本为准

本页译自英文,由模型翻译。若与英文原文存在差异,以英文原文为准。

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

ruststream 命令行工具由同一个 crate 的 cli feature 提供。参见 runtime::cli

在本地构建参考文档

cargo doc --all-features --open

主要入口

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