Event object design

[okumin]

The first implementation of event object is here.

EventStream has a tag and forwarded messages(entries) in a request.
Entries is a List<EventEntry> and EventEntry is an event(e.g. a line of a log file).

I'm thinking to provide following APIs.

• on demand decoding
  • Influent decodes requests and transform messagepack into List<EventEntry> eagerly
  • lazy decoding saves CPUs in some cases
    • when Influent forwards requests like a proxy
    • when Influent writes requests to file and reads those later like a buffer plugin
• POJO mapping API