Hello,
I would like to know if it would be possible to use GenStage.PartitionDispatcher but with dynamic partition management based on a callback.
Here’s what I need: I have a source event (producer
) with several producer_consumers
who can subscribe/unsubscribe dynamically. Each producer_consumers
has a unique id. Events arriving at my producer
also have a tag corresponding to the id of the producer_consumers
to which they must be redirected.
The problem is the dynamic nature of producer_consumers
and the fact that I don’t know the IDs in advance.
Is there already a solution, or would I have to write my own GenStage.Dispatcher?