Crate arkflow_core

Rust stream processing engine

Modules

cli

config

Configuration module

engine

input

Input component module

output

Output component module

pipeline

Pipeline Component Module

processor

Processor component module

stream

Stream component module

Structs

MessageBatch

Represents a message in a stream processing engine.

Enums

Content

Error

Error in the stream processing engine

Type Aliases

Bytes