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?