Repository navigation
feat: broadcast queue state - #14
Conversation
Resolves: #13 Start decomposing the pipeline into a Prepare step and and an Execute step. During prepare we backup and broadcast term/index. During Execute we recover the data. Signed-off-by: Clint Edwards <bithckr@gmail.com>
Signed-off-by: Clint Edwards <bithckr@gmail.com>
dlawregiets
left a comment
There was a problem hiding this comment.
I haven't quite caught up on reading all of the code yet to answer these questions but I have a few.
It looks like you get the vhost from the log message. Is it documented that the rabbit user that phorcys uses needs to have access to all vhosts so it can publish everywhere it needs to?
The cfg.AMQPURL I assume has the users credentials baked in.
Do the log messages when a queue gets corrupted all go to the address on the root vhost? Is there any way to configure that so those messages go to a non-root vhost so clients on the root vhost can't read these messages?
Does phorcys use it's own vhost for message isolation or the root one?
Signed-off-by: Clint Edwards <bithckr@gmail.com>
We get a list of queues from RabbitMQ along with the Vhost. We use that list to match log messages with an actual queue. The log messages are too inconsistent to parse. I will update the README in the next commit to indicate that Yes, cfg.AMQPURL does have the user/password baked in. The log exchange is only available on the root vhost(/). This is not configurable. Right now Phorcys uses the vhost configured by the AMQPURL, but as we continue development beyond the POC, we may need to rethink that. |
Signed-off-by: Clint Edwards <bithckr@gmail.com>
Signed-off-by: Clint Edwards <bithckr@gmail.com>
Signed-off-by: Clint Edwards <bithckr@gmail.com>
Signed-off-by: Clint Edwards <bithckr@gmail.com>
Signed-off-by: Clint Edwards <bithckr@gmail.com>
Resolves: #13
Start decomposing the pipeline into a Prepare step and and an Execute step. During prepare we backup and broadcast term/index. During Execute we recover the data.