GenStage

GenStage is a specification for exchanging events between producers and consumers. It also provides a mechanism to specify the computational flow between stages.

This project currently provides the following functionality:

Experimental.GenStage (docs) - a behaviour for implementing producer and consumer stages
Experimental.GenStage.Flow (docs) - GenStage.Flow allows developers to express computations on collections, similar to the Enum and Stream modules, although computations will be executed in parallel using multiple GenStages
Experimental.DynamicSupervisor (docs) - a supervisor designed for starting children dynamically. Besides being a replacement for the :simple_one_for_one strategy in the regular Supervisor, a DynamicSupervisor can also be used as a stage consumer, making it straight-forward to spawn a new process for every event in a stage pipeline

The module names are marked as Experimental to avoid conflicts as they are meant to be included in future Elixir releases. In your code, you may add alias Experimental.{DynamicSupervisor, GenStage} to the top of your files and use the relative names from then on.

You can find examples on how to use the modules above in the examples directory:

ProducerConsumer - a simple example of setting up a pipeline of A -> B -> C stages and having events flowing through
DynamicSupervisor - an example of how to use one or more DynamicSupervisor as a consumer to a producer that works as a counter
GenEvent - an example of how to use GenStage to implement a GenEvent replacement that leverages concurrency and provides more flexibility regarding buffer size and back-pressure

Installation

GenStage requires Elixir v1.3.

Add :gen_stage to your list of dependencies in mix.exs:
def deps do
```
 [{:gen_stage, "~> 0.4"}]
```
end
Ensure :gen_stage is started before your application:
def application do
```
 [applications: [:gen_stage]]
```
end

Future research

Here is a list of potential topics to be explored by this project (in no particular order or guarantee):

Consider using DynamicSupervisor to implement Task.Supervisor (as a consumer)
TCP and UDP acceptors as producers
Explore different windowing strategies - the ideas behind the Apache Beam project are interesting, specially the mechanism that divides operations between what/where/when/how (1, 2) as well as windowing from the perspective of aggregation (3)

Other research topics include the Titan (4), Naiad's Differential Dataflow engine (5) and Lasp (6).

License

Same as Elixir.

GenStage

Installation

Future research

Links

License