-
Notifications
You must be signed in to change notification settings - Fork 386
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 metric for queue #1756
add metric for queue #1756
Conversation
@@ -58,14 +83,26 @@ bool SenderQueue::Remove(SenderQueueItem* item) { | |||
++mRead; | |||
} | |||
--mSize; | |||
|
|||
mOutItemsCnt->Add(1); |
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.
这里为啥没有对称的mOutItemDataSizeBytes?
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.
因为没啥用,统计个数也只是为了计算平均延时,这个指标本身没有实际价值
@@ -220,6 +235,20 @@ void WriteMetrics::PrepareMetricsRecordRef(MetricsRecordRef& ref, | |||
mHead = cur; | |||
} | |||
|
|||
void WriteMetrics::CreateMetricsRecordRef(MetricsRecordRef& ref, |
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.
这一对能在PrepareMetricsRecordRef中复用吗?让他们建立点联系,一看就知道API选用哪个
新增队列公共指标(除exactly once发送队列)
进入的数量、进入的size、出去的数量、总时延、队列长度、size
队列指标公共label
config_name、project、component_name、queue_type