Index

C D E G H I K O P R S T W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

C

com.aim2be.platform.dedup - package com.aim2be.platform.dedup

consumerScopeId() - Method in record class com.aim2be.platform.dedup.ProcessedKafkaEventId

Returns the value of the consumerScopeId record component.

countByIdConsumerScopeIdAndIdWeekStart(String, LocalDate) - Method in interface com.aim2be.platform.dedup.ProcessedKafkaEventRepository

Returns the count of dedup rows for the given consumer scope + week.

D

DedupAutoConfiguration - Class in com.aim2be.platform.dedup

Spring Boot auto-configuration for the processed-kafka-events dedup module.

DedupAutoConfiguration() - Constructor for class com.aim2be.platform.dedup.DedupAutoConfiguration

dedupClock() - Method in class com.aim2be.platform.dedup.DedupAutoConfiguration

UTC system clock — used by DedupMetricsBinder to determine the "current" week for the active-partitions gauge.

dedupGuard(ProcessedKafkaEventRepository, DedupMetricsBinder, ObjectProvider<OpenTelemetry>, Clock, DedupProperties) - Method in class com.aim2be.platform.dedup.DedupAutoConfiguration

DedupGuard singleton — the module's public API.

DedupGuard - Class in com.aim2be.platform.dedup

Single public API for consumer-side Kafka dedup, per ADR-0014 D-4.

DedupGuard(ProcessedKafkaEventRepository, DedupMetricsBinder, Supplier<Tracer>, Clock, String) - Constructor for class com.aim2be.platform.dedup.DedupGuard

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(MeterRegistry, ProcessedKafkaEventRepository, Clock) - Method in class com.aim2be.platform.dedup.DedupAutoConfiguration

Metrics binder bean.

DedupMetricsBinder - Class in com.aim2be.platform.dedup

Micrometer binder for the dedup module.

DedupMetricsBinder(MeterRegistry, ProcessedKafkaEventRepository, Clock) - Constructor for class com.aim2be.platform.dedup.DedupMetricsBinder

DedupProperties - Class in com.aim2be.platform.dedup

Type-safe configuration for the processed-kafka-events dedup module.

DedupProperties() - Constructor for class com.aim2be.platform.dedup.DedupProperties

E

equals(Object) - Method in record class com.aim2be.platform.dedup.ProcessedKafkaEventId

Indicates whether some other object is "equal to" this one.

eventId() - Method in record class com.aim2be.platform.dedup.ProcessedKafkaEventId

Returns the value of the eventId record component.

G

getDefaultScopeId() - Method in class com.aim2be.platform.dedup.DedupProperties

getFirstSeenAt() - Method in class com.aim2be.platform.dedup.ProcessedKafkaEvent

getId() - Method in class com.aim2be.platform.dedup.ProcessedKafkaEvent

getOffset() - Method in class com.aim2be.platform.dedup.ProcessedKafkaEvent

getPartition() - Method in class com.aim2be.platform.dedup.ProcessedKafkaEvent

getTopic() - Method in class com.aim2be.platform.dedup.ProcessedKafkaEvent

H

hashCode() - Method in record class com.aim2be.platform.dedup.ProcessedKafkaEventId

Returns a hash code value for this object.

HEADER_EVENT_ID - Static variable in class com.aim2be.platform.dedup.KafkaHeaderUtils

Kafka header carrying the producer-side event_id (the outbox-publisher's UUIDv7).

I

insertOrNothing(String, String, LocalDate, Instant, String, int, long) - Method in interface com.aim2be.platform.dedup.ProcessedKafkaEventRepository

Atomic INSERT-OR-NOTHING into processed_kafka_events.

isEnabled() - Method in class com.aim2be.platform.dedup.DedupProperties

K

KafkaHeaderUtils - Class in com.aim2be.platform.dedup

Shared Kafka header-parsing helpers for the dedup flow.

O

OUTCOME_CLAIMED - Static variable in class com.aim2be.platform.dedup.DedupGuard

Outcome attribute values + metric tag values.

OUTCOME_DUPLICATE - Static variable in class com.aim2be.platform.dedup.DedupGuard

P

ProcessedKafkaEvent - Class in com.aim2be.platform.dedup

Marker row stamped by a Kafka consumer when an event is first observed (per ADR-0014 D-4).

ProcessedKafkaEvent() - Constructor for class com.aim2be.platform.dedup.ProcessedKafkaEvent

JPA-required no-arg constructor.

ProcessedKafkaEvent(ProcessedKafkaEventId, String, int, long) - Constructor for class com.aim2be.platform.dedup.ProcessedKafkaEvent

Convenience constructor for hand-built rows in DedupGuard.tryClaim(java.lang.String, java.lang.String, java.time.Instant, java.lang.String, int, long) / unit tests.

ProcessedKafkaEventId - Record Class in com.aim2be.platform.dedup

Composite primary key for ProcessedKafkaEvent, per ADR-0014 D-4.

ProcessedKafkaEventId(String, String, LocalDate) - Constructor for record class com.aim2be.platform.dedup.ProcessedKafkaEventId

Creates an instance of a ProcessedKafkaEventId record class.

ProcessedKafkaEventRepository - Interface in com.aim2be.platform.dedup

Spring Data repository for ProcessedKafkaEvent.

R

recordClaim(String, String) - Method in class com.aim2be.platform.dedup.DedupMetricsBinder

Increment the im2be_dedup_claims_total counter for the given scope + outcome.

registerGaugeIfAbsent(String) - Method in class com.aim2be.platform.dedup.DedupMetricsBinder

Eagerly register a gauge for a scope ahead of any tryClaim traffic.

resolveEventId(ConsumerRecord<?, ?>) - Static method in class com.aim2be.platform.dedup.KafkaHeaderUtils

Resolves the dedup event_id for a consumed Kafka record.

S

setDefaultScopeId(String) - Method in class com.aim2be.platform.dedup.DedupProperties

setEnabled(boolean) - Method in class com.aim2be.platform.dedup.DedupProperties

T

toString() - Method in record class com.aim2be.platform.dedup.ProcessedKafkaEventId

Returns a string representation of this record class.

tryClaim(String, String, Instant, String, int, long) - Method in class com.aim2be.platform.dedup.DedupGuard

Atomically attempts to mark an event as processed for the given consumer.

tryClaim(String, Instant, String, int, long) - Method in class com.aim2be.platform.dedup.DedupGuard

No-scope convenience overload.

tryClaimSameTx(String, String, Instant, String, int, long) - Method in class com.aim2be.platform.dedup.DedupGuard

At-least-once sibling of DedupGuard.tryClaim(String, String, Instant, String, int, long): the dedup claim JOINS the caller's transaction (Propagation.MANDATORY) instead of committing in a separate one.

tryClaimSameTx(String, Instant, String, int, long) - Method in class com.aim2be.platform.dedup.DedupGuard

No-scope convenience overload of DedupGuard.tryClaimSameTx(String, String, Instant, String, int, long) — the at-least-once (Propagation.MANDATORY) counterpart of the no-scope DedupGuard.tryClaim(String, Instant, String, int, long).

W

weekStart() - Method in record class com.aim2be.platform.dedup.ProcessedKafkaEventId

Returns the value of the weekStart record component.

C D E G H I K O P R S T W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form