amacgregor

amacgregor

GenStage usecases and best practices

Elixir Noob here, I’m looking for advice about GenStage and some general guidelines when designing systems with Elixir.

At a high level, I’m looking to build a system where the end-user can modify/select each stage of a data pipeline, the start and end of said pipeline will always be the same, but the end user can add/activate a new stage that will do the additional computation.

Will using GenStage and the Flow module be a good fit for the usage I described? if so any examples or advice anyone can offer in regards to the implementation?

Cheers!

Most Liked

josevalim

josevalim

Creator of Elixir

Your description of the problem is very vague to say if GenStage or Flow is a good fit. I would first worry about writing the application and business domain. As an Elixir beginner, there are a couple things you would need to learn before dynamically managing GenStage pipelines, such as managing simple processes, and you can reevaluate later if you need the performance characteristics or the backpressure provided by GenStage.

To put it shortly, start with the simplest abstraction until you are familiar and you are sure you need more complex ones.

LostKobrakai

LostKobrakai

Not really. GenStage servers are just GenServers as well, but they have some extra functionality build on top for handling events in a chain of producers and consumers (or producer/consumers which do both things), reducing the boilerplate needed to set those up. Flow is another layer of abstraction on top of that which handles common cases like faning out to multiple processes and reducing those back at a later stage.

All this could be done using plain GenServers as well, but you’d need to write a ton more code to wire things up. Also each of those servers, be it a genserver or genstage instance still works syncronously on it’s own events. It’s multiple of those servers, which makes things async.

amacgregor

amacgregor

Thank you Jose, then I’ll do as you advice and go work on my basics before jumping into GenStage

Where Next?

Trending in Questions Top

lanycrost
Hi everyone! I need implement if…else if…else condition from my elixir code, and anymore of this control flow structures not work proper...
New
senggen
Erlang/OTP 25 [erts-13.2.2] [source] [64-bit] [smp:8:8] [ds:8:8:10] [async-threads:1] 15:22:35.803 [error] gen_event {lager_file_backend...
New
hariharasudhan94
Lets say I have map like this fetching from my database %{"_id" => #BSON.ObjectId<58eb1a7a9ad169198c3dXXXX>, "email" => ...
New
tj0
I’ve been following the steps here for the upgrade from 1.6 to 1.7 and it has gone relatively smoothly all the way till the phoenix_view ...
New
cgraham
Hi! What is currently the best library/method for parsing text and tabular data out of PDF files in Elixir or Erlang?
New
stefanchrobot
Hi, I need a way to handle data migrations in my application. I found an article by @wojtekmach about manual migrations: Automatic and ma...
New
stjefim
Hello! Suppose you are building workflow (order / task / payment) processing system with the following requirements: Each workflow con...
New

Other Trending Topics Top

GenericJam
Edit: 2026 May 15 - This post is archived. Mob is alive!! Main docs: mob v0.7.11 — Documentation A bit of explanation for the slightly c...
New
JesseHerrick
Hey, I’m Jesse and I’m the main contributor behind Dexter, a full-featured, lightning-fast Elixir LSP optimized for large codebases. It s...
New
kip
Localize is the next generation localisation library for Elixir. Think of it as ex_cldr version 3.0. The first version will be released ...
New
webofbits
Squid Mesh is an open source workflow automation runtime for Elixir applications. It is aimed at Phoenix and OTP apps that want to defin...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
kip
In 2021 I started a new library called Tempo with the objective of modelling time as a set of intervals - not as instants. In 2022 I gave...
New

We're in Beta

About us Mission Statement