@@ -265,12 +265,12 @@ async Task Loop()
265265 readonly IAuditIngestionUnitOfWorkFactory unitOfWorkFactory ;
266266 readonly Settings settings ;
267267 readonly Channel < MessageContext > channel ;
268- readonly Histogram < long > auditBatchSize = Telemetry . Meter . CreateHistogram < long > ( Telemetry . CreateInstrumentName ( "ingestion. " , "batch_size" ) ) ;
269- readonly Histogram < double > auditBatchDuration = Telemetry . Meter . CreateHistogram < double > ( Telemetry . CreateInstrumentName ( "ingestion. " , "batch_duration" ) , unit : "ms" ) ;
270- readonly Histogram < double > messageSize = Telemetry . Meter . CreateHistogram < double > ( Telemetry . CreateInstrumentName ( "ingestion. " , "message_size" ) , unit : "kilobytes" ) ;
271- readonly Counter < long > ingestedMessagesCounter = Telemetry . Meter . CreateCounter < long > ( Telemetry . CreateInstrumentName ( "ingestion. " , "count" ) ) ;
272- readonly Histogram < long > consecutiveBatchFailuresCounter = Telemetry . Meter . CreateHistogram < long > ( Telemetry . CreateInstrumentName ( "ingestion. " , "consecutive_batch_failures" ) , unit : "count" ) ;
273- readonly Histogram < double > ingestionDuration = Telemetry . Meter . CreateHistogram < double > ( Telemetry . CreateInstrumentName ( "ingestion. " , "duration" ) , unit : "ms" ) ;
268+ readonly Histogram < long > auditBatchSize = Telemetry . Meter . CreateHistogram < long > ( Telemetry . CreateInstrumentName ( "ingestion" , "batch_size" ) ) ;
269+ readonly Histogram < double > auditBatchDuration = Telemetry . Meter . CreateHistogram < double > ( Telemetry . CreateInstrumentName ( "ingestion" , "batch_duration" ) , unit : "ms" ) ;
270+ readonly Histogram < double > messageSize = Telemetry . Meter . CreateHistogram < double > ( Telemetry . CreateInstrumentName ( "ingestion" , "message_size" ) , unit : "kilobytes" ) ;
271+ readonly Counter < long > ingestedMessagesCounter = Telemetry . Meter . CreateCounter < long > ( Telemetry . CreateInstrumentName ( "ingestion" , "count" ) ) ;
272+ readonly Histogram < long > consecutiveBatchFailuresCounter = Telemetry . Meter . CreateHistogram < long > ( Telemetry . CreateInstrumentName ( "ingestion" , "consecutive_batch_failures" ) , unit : "count" ) ;
273+ readonly Histogram < double > ingestionDuration = Telemetry . Meter . CreateHistogram < double > ( Telemetry . CreateInstrumentName ( "ingestion" , "duration" ) , unit : "ms" ) ;
274274 readonly Watchdog watchdog ;
275275 readonly Task ingestionWorker ;
276276 readonly IHostApplicationLifetime applicationLifetime ;
0 commit comments