-
Notifications
You must be signed in to change notification settings - Fork 11
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add dequeue enqueue stats #98
base: main
Are you sure you want to change the base?
Conversation
internal/pkg/queue/stats.go
Outdated
@@ -174,9 +174,6 @@ func (q *PersistentGroupedQueue) calculateAverageDuration(samples []Sample) OpAv | |||
} | |||
|
|||
func (q *PersistentGroupedQueue) addSample(duration time.Duration, sampleType SampleType) { | |||
q.stats.Lock() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you sure this will not cause any data race?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you sure this will not cause any data race?
I'm not sure any lock is needed at the stats level here considering the entire queue struct (which hold the stats) is locked in Enqueue and Dequeue ?
also can we display the stats using |
Nah, I don't think we should add too much stuff to live-stats.. We already added a lot with the recent PRs. |
No description provided.