Package ai.pipestream.registration.events

package ai.pipestream.registration.events

Classes

Class	Description
OpenSearchEventsProducer	Produces events to Kafka for OpenSearch indexing.
PlatformEventsKeyExtractors	Holder for the UuidKeyExtractor beans that derive deterministic Kafka message keys from platform registration events.
PlatformEventsKeyExtractors.ModuleRegisteredExtractor	Keys ModuleRegistered events by their service ID.
PlatformEventsKeyExtractors.ModuleUnregisteredExtractor	Keys ModuleUnregistered events by their service ID.
PlatformEventsKeyExtractors.ServiceRegisteredExtractor	Keys ServiceRegistered events by their service ID.
PlatformEventsKeyExtractors.ServiceUnregisteredExtractor	Keys ServiceUnregistered events by their service ID.