influent

influent copied to clipboard

wip: Support Fluentd Forward Protocol for TLS

2

okkez

Handshake phase support

10

https://github.com/fluent/fluentd/wiki/Forward-Protocol-Specification-v1

okumin

Reactive Streams support

1

Implement back pressure function and Reactive Streams API. http://www.reactive-streams.org/

okumin

The first implementation of event object is [here](https://github.com/okumin/influent/commit/43870bc0db70d65a2150c4f086d3d3ca4f5c18df#diff-9eefdb8af05e1b0463211be2963ce534 ). `EventStream` has a tag and forwarded messages(`entries`) in a request. `Entries` is a `List` and `EventEntry` is an event(e.g. a line...

okumin