digitalocean/firebolt

Support For Node Returning Multiple Events

jnadler opened this issue · 2 comments

Today, a node may pass to its children a single event (or none). Add support for returning multiple events. This will support use cases like routing a log to multiple elasticsearch indexes, or generating multiple kafka messages based on a condition.

Proposing to address this with a new node type FanoutNode. Signature for Process for this node type will expect a return of []firebolt.Event. An empty array will be equivalent to filtering, and will be treated as such for internal metrics.

Resolved with #43