Crate arkflow

Expand description

Rust流处理引擎

Modules§

config: 配置模块
input: 输入组件模块
metrics: 指标收集模块
output: 输出组件模块
pipeline: 管道组件模块
processor: 处理器组件模块
stream: 流组件模块

Structs§

MessageBatch: 表示流处理引擎中的消息
Metadata: 消息元数据，存储消息的附加信息

Enums§

Content
Error: 表示流处理引擎中的错误