Package ai.pipestream.registration.events

Class OpenSearchEventsProducer

java.lang.Object

ai.pipestream.registration.events.OpenSearchEventsProducer

@ApplicationScoped
public class OpenSearchEventsProducer
extends Object

Produces events to Kafka for OpenSearch indexing. Only emits on successful registration/unregistration. Key: UUID (auto-configured by quarkus-apicurio-registry-protobuf extension) Value: Protobuf events (auto-serialized by extension)

Constructor Summary

Constructors

Constructor	Description
OpenSearchEventsProducer()

Method Summary

Modifier and Type	Method	Description
void	emitModuleRegistered(String serviceId, String moduleName, String host, int port, String version, String schemaId, String apicurioArtifactId)
void	emitModuleUnregistered(String serviceId, String moduleName)
void	emitServiceRegistered(String serviceId, String serviceName, String host, int port, String version)
void	emitServiceUnregistered(String serviceId, String serviceName)

Methods inherited from class java.lang.Object

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

Constructor Details

OpenSearchEventsProducer

public OpenSearchEventsProducer()

Method Details

emitServiceRegistered

public void emitServiceRegistered(String serviceId,
 String serviceName,
 String host,
 int port,
 String version)

emitServiceUnregistered

public void emitServiceUnregistered(String serviceId,
 String serviceName)

emitModuleRegistered

public void emitModuleRegistered(String serviceId,
 String moduleName,
 String host,
 int port,
 String version,
 String schemaId,
 String apicurioArtifactId)

emitModuleUnregistered

public void emitModuleUnregistered(String serviceId,
 String moduleName)