[][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
pcap

Reading packets as events from a pcap input.

text

Reading lines as events from a text input.

Structs

BareEvent

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.