[−][src]Crate eventio
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. |
kafka | Reading/writing events from/to Apache Kafka servers. |
mbox | Reading emails as events from an mbox. |
pcap | Reading packets as events from a pcap input. |
text | Reading lines as events from a text input. |
Structs
BareEvent | 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 |
Functions
split | Spawns worker threads to process events in parallel. |