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 via KeyExtractors) 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)	Emits a ModuleRegistered event to Kafka for OpenSearch indexing.
void	emitModuleUnregistered(String serviceId, String moduleName)	Emits a ModuleUnregistered event to Kafka for OpenSearch indexing.
void	emitServiceRegistered(String serviceId, String serviceName, String host, int port, String version)	Emits a ServiceRegistered event to Kafka for OpenSearch indexing.
void	emitServiceUnregistered(String serviceId, String serviceName)	Emits a ServiceUnregistered event to Kafka for OpenSearch indexing.

Methods inherited from class 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)

Emits a ServiceRegistered event to Kafka for OpenSearch indexing.

Parameters:

serviceId - the service ID

serviceName - the service name

host - the host

port - the port

version - the version

emitServiceUnregistered

public void emitServiceUnregistered(String serviceId,
 String serviceName)

Emits a ServiceUnregistered event to Kafka for OpenSearch indexing.

Parameters:

serviceId - the service ID

serviceName - the service name

emitModuleRegistered

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

Emits a ModuleRegistered event to Kafka for OpenSearch indexing.

Parameters:

serviceId - the service ID

moduleName - the module name

host - the host

port - the port

version - the version

schemaId - the schema ID

apicurioArtifactId - the Apicurio artifact ID

emitModuleUnregistered

public void emitModuleUnregistered(String serviceId,
 String moduleName)

Emits a ModuleUnregistered event to Kafka for OpenSearch indexing.

Parameters:

serviceId - the service ID

moduleName - the module name