Package com.aim2be.platform.dedup

Class DedupMetricsBinder

java.lang.Object

com.aim2be.platform.dedup.DedupMetricsBinder

public class DedupMetricsBinder
extends Object

Micrometer binder for the dedup module.

Metrics published:

• im2be_dedup_claims_total — counter, tags consumer_scope_id, outcome ∈ claimed | duplicate. One increment per DedupGuard.tryClaim(java.lang.String, java.lang.String, java.time.Instant, java.lang.String, int, long) call.
• im2be_dedup_active_partitions_total — gauge per consumer_scope_id. Polls ProcessedKafkaEventRepository.countByIdConsumerScopeIdAndIdWeekStart(java.lang.String, java.time.LocalDate) for the current week (per the binder's Clock). Operationally surfaces how full the live dedup partition is — valuable for capacity planning and for verifying pg_partman retention is keeping pace.

Counter and gauge instances are lazily created per consumer_scope_id and cached for the lifetime of the binder. Cardinality is bounded by the number of distinct logical consumers (8 services on day 1; up to ~32 in the per-pod broadcast scenario per ADR-0014 §L-12 — well within Prometheus' recommended series-per-metric budget).

Constructor Summary

Constructors

Constructor	Description
DedupMetricsBinder(io.micrometer.core.instrument.MeterRegistry registry, ProcessedKafkaEventRepository repository, Clock clock)

Method Summary

Modifier and Type	Method	Description
void	recordClaim(String consumerScopeId, String outcome)	Increment the im2be_dedup_claims_total counter for the given scope + outcome.
void	registerGaugeIfAbsent(String consumerScopeId)	Eagerly register a gauge for a scope ahead of any tryClaim traffic.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DedupMetricsBinder

public DedupMetricsBinder(io.micrometer.core.instrument.MeterRegistry registry,
 ProcessedKafkaEventRepository repository,
 Clock clock)

Parameters:

registry - Micrometer registry to publish into (must not be null)

repository - repository for the gauge's count-by-week query (must not be null)

clock - clock used to determine the "current" week for the gauge; pass Clock.systemUTC() in production, a fixed clock in tests

Method Details

recordClaim

public void recordClaim(String consumerScopeId,
 String outcome)

Increment the im2be_dedup_claims_total counter for the given scope + outcome. Called once per DedupGuard.tryClaim(java.lang.String, java.lang.String, java.time.Instant, java.lang.String, int, long) invocation.

Parameters:

consumerScopeId - logical consumer identity

outcome - DedupGuard.OUTCOME_CLAIMED or DedupGuard.OUTCOME_DUPLICATE

registerGaugeIfAbsent

public void registerGaugeIfAbsent(String consumerScopeId)

Eagerly register a gauge for a scope ahead of any tryClaim traffic. Useful in tests or in services that want the gauge visible at startup.

Parameters:

consumerScopeId - scope to register