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

enhance: Align the monitoring of last_replicated_time_tick with wal_last_confirm_time_tick (#46469)

Browse Source 
issue: https://github.com/milvus-io/milvus/issues/46116

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
This commit is contained in:
yihao.dai 2025-12-21 19:03:17 +08:00 committed by GitHub
parent 9345caa135
commit d03b9cc052
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/cdc/replication/replicatestream/metrics.go
View File

@ -23,6 +23,7 @@ import (
"github.com/milvus-io/milvus/pkg/v2/proto/streamingpb"
"github.com/milvus-io/milvus/pkg/v2/streaming/util/message"
"github.com/milvus-io/milvus/pkg/v2/util/timerecord"
"github.com/milvus-io/milvus/pkg/v2/util/tsoutil"
"github.com/milvus-io/milvus/pkg/v2/util/typeutil"
)
@ -90,7 +91,7 @@ func (m *replicateMetrics) OnConfirmed(msg message.ImmutableMessage) {
metrics.CDCLastReplicatedTimeTick.WithLabelValues(
m.replicateInfo.GetSourceChannelName(),
m.replicateInfo.GetTargetChannelName(),
).Set(float64(msg.TimeTick()))
).Set(tsoutil.PhysicalTimeSeconds(msg.TimeTick()))
}
func (m *replicateMetrics) OnInitiate() {

4
pkg/metrics/cdc_metrics.go
View File

@ -33,7 +33,7 @@ const (
// CDC metric labels
CDCLabelTargetCluster = "target_cluster"
CDCLabelSourceChannelName = "source_channel_name"
CDCLabelSourceChannelName = WALChannelLabelName
CDCLabelTargetChannelName = "target_channel_name"
CDCLabelMsgType = msgTypeLabelName
CDCLabelConnectionStatus = "connection_status"
@ -87,7 +87,7 @@ var CDCLastReplicatedTimeTick = prometheus.NewGaugeVec(
Namespace: milvusNamespace,
Subsystem: typeutil.CDCRole,
Name: CDCMetricLastReplicatedTimeTick,
Help: "The time tick of the last replicated message",
Help: "The time tick in seconds of the last replicated message",
}, []string{
CDCLabelSourceChannelName,
CDCLabelTargetChannelName,