Expand description
Channel-based event I/O processors.
This crate allows to collect events from text files, pcap files, and Apache Kafka servers, distribute them to multiple threads, and optionally collect them to send to Kafka.
Modules
- A partial implementation of Fluentd Forward Protocol.
- Reading emails as events from an mbox.
- Reading lines as events from a text input.
Structs
- A raw event as a byte sequence.
Enums
- The error type for event I/O operations.
Traits
- A trait for a single event from any type of data source.
- A trait for a data source that produces messages of type
Data
.
Functions
- Spawns worker threads to process events in parallel.