Send per queue metrics#3
Conversation
| } | ||
|
|
||
| let mut total_enqueued = 0; | ||
| for (_queue_name, count) in enqueued_count_by_queue { |
There was a problem hiding this comment.
please use something like https://doc.rust-lang.org/std/iter/trait.Sum.html
|
|
||
| let mut previous_total_processed: Option<u32> = None; | ||
|
|
||
| debug!("Welcome to datadog-sidekiq"); |
There was a problem hiding this comment.
given the usage of info! around the existing code base I could see this as info! as well (rather than debug!).
|
thanks for your pull request and sorry for the long wait :) I left a few comments. on top of that, could you also update the 🥇 |
|
I have been tagged in a "too good to be real" crypto scam. I cannot flag it, could you @lipanski, please? Else, delete it if possible |
|
@PastorJordi I'm not sure what you mean. Flag/delete what exactly? |
|
Sorry about annoying you. see the screenshot attached |
3 participants
👋 This sends metrics about each queue's enqueued count.
Added the print so that you know the container is doing something when it boots, and also moved the sleep to the end of the loop, so that it sends metrics before it 😴