| | | 1 | | using System.Diagnostics.Metrics; |
| | | 2 | | |
| | | 3 | | namespace ProjectTemplate.Infrastructure.Data.Auditing; |
| | | 4 | | |
| | | 5 | | public sealed class ApplicationAuditReconciliationMetrics : IDisposable |
| | | 6 | | { |
| | 1 | 7 | | public static readonly ApplicationAuditReconciliationSummary DisabledSummary = |
| | 1 | 8 | | new(false, null, 0, 0, 0, 0, 0, 0, 0); |
| | | 9 | | |
| | 22 | 10 | | private readonly Meter _meter = new("ProjectTemplate.AuditReconciliation", "1.0.0"); |
| | 22 | 11 | | private ApplicationAuditReconciliationSummary _summary = DisabledSummary; |
| | | 12 | | private long _pendingDeliveryCount; |
| | | 13 | | private double _oldestPendingAgeSeconds; |
| | | 14 | | private long _totalRetryCount; |
| | | 15 | | |
| | 22 | 16 | | public ApplicationAuditReconciliationMetrics() |
| | | 17 | | { |
| | 22 | 18 | | _meter.CreateObservableGauge("ncat.audit.reconciliation.findings.open", |
| | 22 | 19 | | () => _summary.OpenFindingCount); |
| | 22 | 20 | | _meter.CreateObservableGauge("ncat.audit.reconciliation.findings.error", |
| | 22 | 21 | | () => _summary.ErrorFindingCount); |
| | 22 | 22 | | _meter.CreateObservableGauge("ncat.audit.reconciliation.findings.critical", |
| | 22 | 23 | | () => _summary.CriticalFindingCount); |
| | 22 | 24 | | _meter.CreateObservableGauge("ncat.audit.reconciliation.manifest_failures", |
| | 22 | 25 | | () => _summary.ManifestVerificationFailureCount); |
| | 22 | 26 | | _meter.CreateObservableGauge("ncat.audit.reconciliation.missing_completions", |
| | 22 | 27 | | () => _summary.MissingCompletionCount); |
| | 22 | 28 | | _meter.CreateObservableGauge("ncat.audit.reconciliation.stale_delivery", |
| | 22 | 29 | | () => _summary.StaleDeliveryCount); |
| | 22 | 30 | | _meter.CreateObservableGauge("ncat.audit.reconciliation.dead_letters", |
| | 22 | 31 | | () => _summary.DeadLetterCount); |
| | 22 | 32 | | _meter.CreateObservableGauge("ncat.audit.outbox.pending", |
| | 22 | 33 | | () => Interlocked.Read(ref _pendingDeliveryCount)); |
| | 22 | 34 | | _meter.CreateObservableGauge("ncat.audit.outbox.oldest_pending_age_seconds", |
| | 22 | 35 | | () => Volatile.Read(ref _oldestPendingAgeSeconds)); |
| | 22 | 36 | | _meter.CreateObservableGauge("ncat.audit.outbox.retry_count", |
| | 22 | 37 | | () => Interlocked.Read(ref _totalRetryCount)); |
| | 22 | 38 | | } |
| | | 39 | | |
| | 1 | 40 | | public DateTime? LastRunUtc => _summary.LastRunUtc; |
| | | 41 | | |
| | | 42 | | public void Update(ApplicationAuditReconciliationSummary summary) |
| | | 43 | | { |
| | 18 | 44 | | ArgumentNullException.ThrowIfNull(summary); |
| | 18 | 45 | | _summary = summary; |
| | 18 | 46 | | } |
| | | 47 | | |
| | | 48 | | public void UpdateDelivery(ApplicationAuditCompletionOutboxHealth health) |
| | | 49 | | { |
| | 3 | 50 | | ArgumentNullException.ThrowIfNull(health); |
| | 3 | 51 | | Interlocked.Exchange(ref _pendingDeliveryCount, health.BacklogCount); |
| | 3 | 52 | | Volatile.Write(ref _oldestPendingAgeSeconds, health.OldestPendingAge?.TotalSeconds ?? 0); |
| | 3 | 53 | | Interlocked.Exchange(ref _totalRetryCount, health.TotalRetryCount); |
| | 3 | 54 | | } |
| | | 55 | | |
| | | 56 | | public void Dispose() |
| | | 57 | | { |
| | 22 | 58 | | _meter.Dispose(); |
| | 22 | 59 | | } |
| | | 60 | | } |