Uses of Interface
com.aim2be.platform.dedup.ProcessedKafkaEventRepository

Uses of ProcessedKafkaEventRepository in com.aim2be.platform.dedup

Methods in com.aim2be.platform.dedup with parameters of type ProcessedKafkaEventRepository

Modifier and Type	Method	Description
DedupGuard	DedupAutoConfiguration.dedupGuard(ProcessedKafkaEventRepository repository, DedupMetricsBinder metrics, org.springframework.beans.factory.ObjectProvider<io.opentelemetry.api.OpenTelemetry> otelProvider, Clock clock, DedupProperties props)	DedupGuard singleton — the module's public API.
DedupMetricsBinder	DedupAutoConfiguration.dedupMetricsBinder(io.micrometer.core.instrument.MeterRegistry registry, ProcessedKafkaEventRepository repository, Clock clock)	Metrics binder bean.

Constructors in com.aim2be.platform.dedup with parameters of type ProcessedKafkaEventRepository

Modifier	Constructor	Description
	DedupGuard(ProcessedKafkaEventRepository repository, DedupMetricsBinder metrics, Supplier<io.opentelemetry.api.trace.Tracer> tracerSupplier, Clock clock, String defaultScopeId)	Constructs a guard wired to a JPA repository, a Micrometer binder, a deferred OTel tracer supplier (re-resolved per tryClaim call so a late-registered OTel SDK is honoured), a clock for firstSeenAt stamping, and an optional default scope id used by DedupGuard.tryClaim(String, Instant, String, int, long) (the no-scope overload).
	DedupMetricsBinder(io.micrometer.core.instrument.MeterRegistry registry, ProcessedKafkaEventRepository repository, Clock clock)