blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-08-07 03:35:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

prome

Browse Source
This commit is contained in:
wangchuxiao 2022-09-14 10:25:44 +08:00
parent 54a3a755d6
commit 4d6e05989e
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/msg_transfer/logic/persistent_msg_handler.go
View File

@ -54,12 +54,16 @@ func (pc *PersistentConsumerHandler) initPrometheus() {
Help: "The total number of msg insert mysql events", Help: "The total number of msg insert mysql events",
}) })
// msgInsertMysqlEvery := prometheus.NewHistogram(prometheus.HistogramOpts{ // 启动计时器
// requestDurations := prometheus.NewHistogram(prometheus.HistogramOpts{
// Name: "http_request_duration_seconds", // Name: "http_request_duration_seconds",
// Help: "A histogram of the HTTP request durations in seconds.", // Help: "A histogram of the HTTP request durations in seconds.",
// Buckets: []float64{10, 20, 0.25, 0.5, 1, 2.5, 5, 10}, // Buckets: []float64{0.05, 0.1, 0.25, 0.5, 1, 2.5, 5, 10},
// }) // })
// 开始
// timer := prometheus.NewTimer(requestDurations)
// 停止
// timer.ObserveDuration()
} }
func (pc *PersistentConsumerHandler) handleChatWs2Mysql(cMsg *sarama.ConsumerMessage, msgKey string, _ sarama.ConsumerGroupSession) { func (pc *PersistentConsumerHandler) handleChatWs2Mysql(cMsg *sarama.ConsumerMessage, msgKey string, _ sarama.ConsumerGroupSession) {