Crate arkflow 

Rust流处理引擎

Modules

config

配置模块

input

输入组件模块

metrics

指标收集模块

output

输出组件模块

pipeline

管道组件模块

processor

处理器组件模块

stream

流组件模块

Structs

MessageBatch

表示流处理引擎中的消息

Metadata

消息元数据，存储消息的附加信息

Enums

Content

Error

表示流处理引擎中的错误