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

Add indexCountLabel for metric QueryNodeNumEntities (#21081) (#21121) 

Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>

Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
pull/21114/head
zhenshan.cao 2022-12-11 01:01:20 +08:00 committed by GitHub
parent 41f7b10abb
commit 8d55a2cefa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/metrics/querynode_metrics.go
View File

@ -323,6 +323,7 @@ var (
collectionIDLabelName,
partitionIDLabelName,
segmentStateLabelName,
indexCountLabelName,
})
// QueryNodeConsumeCounter counts the bytes QueryNode consumed from message storage.

6
internal/querynode/meta_replica.go
View File

@ -631,7 +631,8 @@ func (replica *metaReplica) addSegmentPrivate(segment *Segment) error {
fmt.Sprint(Params.QueryNodeCfg.GetNodeID()),
fmt.Sprint(segment.collectionID),
fmt.Sprint(segment.partitionID),
string(segType),
segType.String(),
fmt.Sprint(segment.indexedFieldInfos.Len()),
).Add(float64(rowCount))
}
return nil
@ -739,7 +740,8 @@ func (replica *metaReplica) removeSegmentPrivate(segmentID UniqueID, segType seg
fmt.Sprint(Params.QueryNodeCfg.GetNodeID()),
fmt.Sprint(segment.collectionID),
fmt.Sprint(segment.partitionID),
string(segType),
segType.String(),
fmt.Sprint(segment.indexedFieldInfos.Len()),
).Sub(float64(rowCount))
}
}

1
internal/querynode/segment.go
View File

@ -709,6 +709,7 @@ func (s *Segment) segmentInsert(offset int64, entityIDs []UniqueID, timestamps [
fmt.Sprint(s.collectionID),
fmt.Sprint(s.partitionID),
s.segmentType.String(),
fmt.Sprint(0),
).Add(float64(numOfRow))
s.setRecentlyModified(true)
return nil