diff --git a/src/Directory.Packages.props b/src/Directory.Packages.props index b2b400a707..4ed9bbd370 100644 --- a/src/Directory.Packages.props +++ b/src/Directory.Packages.props @@ -64,7 +64,6 @@ - diff --git a/src/ServiceControl.Audit/Auditing/Metrics/IngestionMetrics.cs b/src/ServiceControl.Audit/Auditing/Metrics/IngestionMetrics.cs index 2c79c586d5..f968cebb72 100644 --- a/src/ServiceControl.Audit/Auditing/Metrics/IngestionMetrics.cs +++ b/src/ServiceControl.Audit/Auditing/Metrics/IngestionMetrics.cs @@ -20,7 +20,7 @@ public IngestionMetrics(IMeterFactory meterFactory) batchDuration = meter.CreateHistogram(BatchDurationInstrumentName, unit: "seconds", "Message batch processing duration in seconds"); ingestionDuration = meter.CreateHistogram(MessageDurationInstrumentName, unit: "seconds", description: "Audit message processing duration in seconds"); - consecutiveBatchFailureGauge = meter.CreateGauge($"{InstrumentPrefix}.consecutive_batch_failure_total", description: "Consecutive audit ingestion batch failure"); + consecutiveBatchFailureGauge = meter.CreateObservableGauge($"{InstrumentPrefix}.consecutive_batch_failure_total", () => consecutiveBatchFailures, description: "Consecutive audit ingestion batch failure"); failureCounter = meter.CreateCounter($"{InstrumentPrefix}.failures_total", description: "Audit ingestion failure count"); } @@ -56,14 +56,15 @@ void RecordBatchOutcome(bool success) { consecutiveBatchFailures++; } - - consecutiveBatchFailureGauge.Record(consecutiveBatchFailures); } long consecutiveBatchFailures; readonly Histogram batchDuration; - readonly Gauge consecutiveBatchFailureGauge; +#pragma warning disable IDE0052 + // this can be changed to Gauge once we can use the latest version of System.Diagnostics.DiagnosticSource + readonly ObservableGauge consecutiveBatchFailureGauge; +#pragma warning restore IDE0052 readonly Histogram ingestionDuration; readonly Counter failureCounter; diff --git a/src/ServiceControl.Audit/ServiceControl.Audit.csproj b/src/ServiceControl.Audit/ServiceControl.Audit.csproj index 3d5245157b..ba7d5110d5 100644 --- a/src/ServiceControl.Audit/ServiceControl.Audit.csproj +++ b/src/ServiceControl.Audit/ServiceControl.Audit.csproj @@ -32,7 +32,6 @@ -