Skip to content

Commit 0e9f886

Browse files
andyyang890andyyang890
committed
roachprod/opentelemetry: add new CDC 25.4 metrics to DRT clusters
This patch adds the following metrics to DRT clusters: * changefeed.progress_skew.span * changefeed.progress_skew.table * changefeed.sink_backpressure_nanos * changefeed.stage.frontier_persistence.latency * changefeed.stage.pts.manage.latency * changefeed.stage.pts.manage_error.latency * changefeed.stage.pts.create.latency Release note: None
1 parent 70ad6fb commit 0e9f886

File tree

1 file changed

+22
-0
lines changed

1 file changed

+22
-0
lines changed

‎pkg/roachprod/opentelemetry/cockroachdb_metrics.go‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -405,6 +405,8 @@ var cockroachdbMetrics = map[string]string{
405405
"changefeed_parallel_io_result_queue_nanos_bucket": "changefeed.parallel_io_result_queue_nanos.bucket",
406406
"changefeed_parallel_io_result_queue_nanos_count": "changefeed.parallel_io_result_queue_nanos.count",
407407
"changefeed_parallel_io_result_queue_nanos_sum": "changefeed.parallel_io_result_queue_nanos.sum",
408+
"changefeed_progress_skew_span": "changefeed.progress_skew.span",
409+
"changefeed_progress_skew_table": "changefeed.progress_skew.table",
408410
"changefeed_queue_time_nanos": "changefeed.queue_time",
409411
"changefeed_running": "changefeed.running",
410412
"changefeed_schema_registry_registrations": "changefeed.schema_registry.registrations",
@@ -415,6 +417,10 @@ var cockroachdbMetrics = map[string]string{
415417
"changefeed_sink_batch_hist_nanos_bucket": "changefeed.sink_batch_hist_nanos.bucket",
416418
"changefeed_sink_batch_hist_nanos_count": "changefeed.sink_batch_hist_nanos.count",
417419
"changefeed_sink_batch_hist_nanos_sum": "changefeed.sink_batch_hist_nanos.sum",
420+
"changefeed_sink_backpressure_nanos": "changefeed.sink_backpressure_nanos",
421+
"changefeed_sink_backpressure_nanos_bucket": "changefeed.sink_backpressure_nanos.bucket",
422+
"changefeed_sink_backpressure_nanos_count": "changefeed.sink_backpressure_nanos.count",
423+
"changefeed_sink_backpressure_nanos_sum": "changefeed.sink_backpressure_nanos.sum",
418424
"changefeed_sink_io_inflight": "changefeed.sink_io_inflight",
419425
"changefeed_size_based_flushes": "changefeed.size_based_flushes",
420426
"changefeed_stage_checkpoint_job_progress_latency": "changefeed.stage.checkpoint_job_progress.latency",
@@ -433,6 +439,10 @@ var cockroachdbMetrics = map[string]string{
433439
"changefeed_stage_encode_latency_bucket": "changefeed.stage.encode.latency.bucket",
434440
"changefeed_stage_encode_latency_count": "changefeed.stage.encode.latency.count",
435441
"changefeed_stage_encode_latency_sum": "changefeed.stage.encode.latency.sum",
442+
"changefeed_stage_frontier_persistence_latency": "changefeed.stage.frontier_persistence.latency",
443+
"changefeed_stage_frontier_persistence_latency_bucket": "changefeed.stage.frontier_persistence.latency.bucket",
444+
"changefeed_stage_frontier_persistence_latency_count": "changefeed.stage.frontier_persistence.latency.count",
445+
"changefeed_stage_frontier_persistence_latency_sum": "changefeed.stage.frontier_persistence.latency.sum",
436446
"changefeed_stage_kv_feed_buffer_latency": "changefeed.stage.kv_feed_buffer.latency",
437447
"changefeed_stage_kv_feed_buffer_latency_bucket": "changefeed.stage.kv_feed_buffer.latency.bucket",
438448
"changefeed_stage_kv_feed_buffer_latency_count": "changefeed.stage.kv_feed_buffer.latency.count",
@@ -441,6 +451,18 @@ var cockroachdbMetrics = map[string]string{
441451
"changefeed_stage_kv_feed_wait_for_table_event_latency_bucket": "changefeed.stage.kv_feed_wait_for_table_event.latency.bucket",
442452
"changefeed_stage_kv_feed_wait_for_table_event_latency_count": "changefeed.stage.kv_feed_wait_for_table_event.latency.count",
443453
"changefeed_stage_kv_feed_wait_for_table_event_latency_sum": "changefeed.stage.kv_feed_wait_for_table_event.latency.sum",
454+
"changefeed_stage_pts_create_latency": "changefeed.stage.pts.create.latency",
455+
"changefeed_stage_pts_create_latency_bucket": "changefeed.stage.pts.create.latency.bucket",
456+
"changefeed_stage_pts_create_latency_count": "changefeed.stage.pts.create.latency.count",
457+
"changefeed_stage_pts_create_latency_sum": "changefeed.stage.pts.create.latency.sum",
458+
"changefeed_stage_pts_manage_error_latency": "changefeed.stage.pts.manage_error.latency",
459+
"changefeed_stage_pts_manage_error_latency_bucket": "changefeed.stage.pts.manage_error.latency.bucket",
460+
"changefeed_stage_pts_manage_error_latency_count": "changefeed.stage.pts.manage_error.latency.count",
461+
"changefeed_stage_pts_manage_error_latency_sum": "changefeed.stage.pts.manage_error.latency.sum",
462+
"changefeed_stage_pts_manage_latency": "changefeed.stage.pts.manage.latency",
463+
"changefeed_stage_pts_manage_latency_bucket": "changefeed.stage.pts.manage.latency.bucket",
464+
"changefeed_stage_pts_manage_latency_count": "changefeed.stage.pts.manage.latency.count",
465+
"changefeed_stage_pts_manage_latency_sum": "changefeed.stage.pts.manage.latency.sum",
444466
"changefeed_stage_rangefeed_buffer_checkpoint_latency": "changefeed.stage.rangefeed_buffer_checkpoint.latency",
445467
"changefeed_stage_rangefeed_buffer_checkpoint_latency_bucket": "changefeed.stage.rangefeed_buffer_checkpoint.latency.bucket",
446468
"changefeed_stage_rangefeed_buffer_checkpoint_latency_count": "changefeed.stage.rangefeed_buffer_checkpoint.latency.count",

0 commit comments

Comments
 (0)