milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix metric RootCoordInsertChannelTimeTick (#23236) (#23284) 

Signed-off-by: longjiquan <jiquan.long@zilliz.com>
pull/23333/head
Jiquan Long 2023-04-10 11:14:30 +08:00 committed by GitHub
parent 531bc4a297
commit f2f7d8ed53
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
internal/rootcoord/timeticksync.go
View File

@ -306,6 +306,13 @@ func (t *timetickSync) startWatch(wg *sync.WaitGroup) {
// SendTimeTickToChannel send each channel's min timetick to msg stream
func (t *timetickSync) sendTimeTickToChannel(chanNames []string, ts typeutil.Timestamp) error {
func() {
sub := tsoutil.SubByNow(ts)
for _, chanName := range chanNames {
metrics.RootCoordInsertChannelTimeTick.WithLabelValues(chanName).Set(float64(sub))
}
}()
msgPack := msgstream.MsgPack{}
baseMsg := msgstream.BaseMsg{
BeginTimestamp: ts,
@ -329,10 +336,6 @@ func (t *timetickSync) sendTimeTickToChannel(chanNames []string, ts typeutil.Tim
return err
}
sub := tsoutil.SubByNow(ts)
for _, chanName := range chanNames {
metrics.RootCoordInsertChannelTimeTick.WithLabelValues(chanName).Set(float64(sub))
}
return nil
}