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§
- fluentd
- A partial implementation of Fluentd Forward Protocol.
- mbox
- Reading emails as events from an mbox.
- text
- Reading lines as events from a text input.
Structs§
- Bare
Event - A raw event as a byte sequence.
Enums§
- Error
- The error type for event I/O operations.
Traits§
- Event
- A trait for a single event from any type of data source.
- Input
- A trait for a data source that produces messages of type
Data.
Functions§
- split
- Spawns worker threads to process events in parallel.