File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
src/ServiceControl.Audit/Auditing Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -210,6 +210,7 @@ async Task Loop()
210210 while ( channel . Reader . TryRead ( out var context ) )
211211 {
212212 contexts . Add ( context ) ;
213+ auditMessageSize . Record ( context . Body . Length / 1024.0 ) ;
213214 }
214215
215216 auditBatchSize . Record ( contexts . Count ) ;
@@ -258,6 +259,7 @@ async Task Loop()
258259 readonly Channel < MessageContext > channel ;
259260 readonly Histogram < long > auditBatchSize = AuditMetrics . Meter . CreateHistogram < long > ( $ "{ AuditMetrics . Prefix } .batch_size_audits") ;
260261 readonly Histogram < double > auditBatchDuration = AuditMetrics . Meter . CreateHistogram < double > ( $ "{ AuditMetrics . Prefix } .batch_duration_audits", unit : "ms" ) ;
262+ readonly Histogram < double > auditMessageSize = AuditMetrics . Meter . CreateHistogram < double > ( $ "{ AuditMetrics . Prefix } .audit_message_size", unit : "kilobytes" ) ;
261263 readonly Counter < long > receivedAudits = AuditMetrics . Meter . CreateCounter < long > ( $ "{ AuditMetrics . Prefix } .received_audits") ;
262264 readonly Watchdog watchdog ;
263265 readonly Task ingestionWorker ;
You can’t perform that action at this time.
0 commit comments