Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Should appliances be pipeable / streams? #17

Closed
slifty opened this issue Sep 20, 2020 · 1 comment
Closed

Should appliances be pipeable / streams? #17

slifty opened this issue Sep 20, 2020 · 1 comment
Labels
discussion The conversation is the point

Comments

@slifty
Copy link
Member

slifty commented Sep 20, 2020

Discussion

What do you want to talk about?

This is an item that @chriszs raised months ago and frankly I think I just didn't fully grok at the time, but in light of the recent discussions around payload ordering and backpressure I'm starting to understand more.

The short concept is that right now Appliances (and the countertop in general) use generic events to convey what's going on. The alternative to this is to use streams.

There are many benefits to streams. The most pressing for now:

  • They are able to handle backpressure, which means we can control how quickly payloads are read from kafka / generated by source streams.
  • They are able to guarantee order across asynchronous pipelines (short term note: it is possible that eventemitters can ensure this too).

As an added bonus we might be able to eliminate the need for custom events.

Relevant Resources / Research

@slifty
Copy link
Member Author

slifty commented Mar 5, 2022

This is now complete -- Appliances are Transform streams.

@slifty slifty closed this as completed Mar 5, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
discussion The conversation is the point
Projects
None yet
Development

No branches or pull requests

1 participant