Adding jobs from Rust?

[MichielvdVelde]

Hello all,
I'm currently working on a distributed system which uses BullMQ in Node.js. However, one crucial component will be written in Rust. This component generates events which should be processed to update the game state. My current approach is to use output streams from the Rust component, and a 'bridge' which reads from the stream and converts events into jobs. These jobs are then picked up for processing.

I'd very much like to be able to simplify this flow by adding the events to BullMQ as jobs directly from the Rust component. I have taken a preliminary look at the TS code, and it seems it would be possible to partially port to Rust (only and exclusively the adding of standard and possibly prioritized jobs).

So, the question is, can anybody provide some insight in what this would entail? It seems relatively straightforward and would cut out the middle-man.

Thanks in advance!

[manast]

Easiest would be to use this: https://github.com/taskforcesh/bullmq-proxy

[manast]

Btw, if you decide to use bullmq-proxy I will be available for quick fixes and enhancements If needed as I am quite eager in getting people to use it in production.

[MichielvdVelde]

Thanks for the quick reply.

Using the proxy would basically be the same set-up I've already considered. My goal would be to cut out the middle-man, and the proxy is just such a middle-man. As an example, I was originally considering something like this.

I will take a better look at the code to gauge the feasibility. Any advice you can give me ragarding how the relevant Lua scripts are used would be much appreciated!