shared-infrastructure/com.vertyll.veds.sharedinfrastructure.kafka.contract/ProcessedEventFactory

ProcessedEventFactory

interface ProcessedEventFactory(source)

Persistence-agnostic factory for ProcessedEvent rows, owned by each service's adapter (analogous to OutboxMessageFactory).

Functions

Link copied to clipboard
abstract fun create(eventId: String, consumerGroup: String): ProcessedEvent

Builds a fresh ProcessedEvent for the given eventId / consumerGroup pair. Implementations stamp processedAt with the current instant.

Generated by Dokka
© 2026 Copyright