admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 01:58:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add indexCountLabel for metric QueryNodeNumEntities (#21081)

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

Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
This commit is contained in:
zhenshan.cao 2022-12-10 23:45:20 +08:00 committed by GitHub
parent 699b63fb42
commit abc2adb1f8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 0 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, collectionIDLabelName,
partitionIDLabelName, partitionIDLabelName,
segmentStateLabelName, segmentStateLabelName,
indexCountLabelName,
}) })
// QueryNodeConsumeCounter counts the bytes QueryNode consumed from message storage. // QueryNodeConsumeCounter counts the bytes QueryNode consumed from message storage.

2
internal/querynode/meta_replica.go
View File

@ -634,6 +634,7 @@ func (replica *metaReplica) addSegmentPrivate(segment *Segment) error {
fmt.Sprint(segment.collectionID), fmt.Sprint(segment.collectionID),
fmt.Sprint(segment.partitionID), fmt.Sprint(segment.partitionID),
segType.String(), segType.String(),
fmt.Sprint(segment.indexedFieldInfos.Len()),
).Add(float64(rowCount)) ).Add(float64(rowCount))
} }
return nil return nil
@ -742,6 +743,7 @@ func (replica *metaReplica) removeSegmentPrivate(segmentID UniqueID, segType seg
fmt.Sprint(segment.collectionID), fmt.Sprint(segment.collectionID),
fmt.Sprint(segment.partitionID), fmt.Sprint(segment.partitionID),
segType.String(), segType.String(),
fmt.Sprint(segment.indexedFieldInfos.Len()),
).Sub(float64(rowCount)) ).Sub(float64(rowCount))
} }
} }

1
internal/querynode/segment.go
View File

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