maksaska commented on code in PR #11612:
URL: https://github.com/apache/ignite/pull/11612#discussion_r1825744093
##########
modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java:
##########
@@ -183,6 +185,29 @@ public class CdcMain implements Runnable {
private static final IgniteBiPredicate<WALRecord.RecordType, WALPointer>
ACTIVE_RECS =
(type, ptr) -> type == DATA_RECORD_V2 || type == CDC_DATA_RECORD;
+ /** Histogram buckets for duration wal processing in nanoseconds. */
+ public static final long[] HISTOGRAM_BUCKETS = new long[] {
+ NANOSECONDS.convert(1, MILLISECONDS),
+ NANOSECONDS.convert(10, MILLISECONDS),
+ NANOSECONDS.convert(100, MILLISECONDS),
+ NANOSECONDS.convert(250, MILLISECONDS),
+ NANOSECONDS.convert(1000, MILLISECONDS)
+ };
+
+ /** */
+ public static final String EVENTS_CONSUMPTION_TIME =
"EventsConsumptionTime";
+
+ /** */
+ public static final String EVENTS_CONSUMPTION_TIME_DESC =
+ "Time for which this CDC client processed the WAL segment events, in
nanoseconds.";
+
+ /** */
+ public static final String EVENTS_CONSUMPTION_TIME_TOTAL =
"EventsConsumptionTimeTotal";
+
+ /** */
+ public static final String EVENTS_CONSUMPTION_TIME_TOTAL_DESC =
Review Comment:
Fixed it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
