Crate arkflow

Source
Expand description

Rust流处理引擎

Modules§

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

Structs§

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

Enums§

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