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.
• mbox
  Reading emails as events from an mbox.
• 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 Data.

Functions

• split
  Spawns worker threads to process events in parallel.

Type Definitions

• SeqNo