admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-02-02 01:06:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

remove annoying timerecorder print (#24263)

Browse Source 
Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
This commit is contained in:
aoiasd 2023-05-20 18:25:25 +08:00 committed by GitHub
parent 112c8f03d3
commit 4fbb3f2b34
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/mq/msgstream/mqwrapper/kafka/kafka_producer.go
View File

@ -70,7 +70,7 @@ func (kp *kafkaProducer) Send(ctx context.Context, message *mqwrapper.ProducerMe
return nil, m.TopicPartition.Error
}
elapsed := start.Elapse("send msg to stream done")
elapsed := start.ElapseSpan()
metrics.MsgStreamRequestLatency.WithLabelValues(metrics.SendMsgLabel).Observe(float64(elapsed.Milliseconds()))
metrics.MsgStreamOpCounter.WithLabelValues(metrics.SendMsgLabel, metrics.SuccessLabel).Inc()

2
internal/mq/msgstream/mqwrapper/rmq/rmq_producer.go
View File

@ -44,7 +44,7 @@ func (rp *rmqProducer) Send(ctx context.Context, message *mqwrapper.ProducerMess
return &rmqID{messageID: id}, err
}
elapsed := start.Elapse("send msg to stream done")
elapsed := start.ElapseSpan()
metrics.MsgStreamRequestLatency.WithLabelValues(metrics.SendMsgLabel).Observe(float64(elapsed.Milliseconds()))
metrics.MsgStreamOpCounter.WithLabelValues(metrics.SendMsgLabel, metrics.SuccessLabel).Inc()
return &rmqID{messageID: id}, nil