Expand description
Rust流处理引擎
这个基于Rust的流处理引擎参考了Benthos的设计理念， 旨在提供一个高性能、可靠且易于扩展的数据流处理系统。
Modules§
- buffer
- 缓冲区组件模块
- config
- 配置模块
- input
- 输入组件模块
- metrics
- 指标收集模块
- output
- 输出组件模块
- pipeline
- 管道组件模块
- plugin
- 插件系统模块
- processor
- 处理器组件模块
- stream
- 流组件模块
Structs§
- Message
- 表示流处理引擎中的消息
- Message
Batch - Metadata
- 消息元数据，存储消息的附加信息
Enums§
- Error
- 表示流处理引擎中的错误