Package ai.pipestream.registration.handlers

Class ModuleRegistrationHandler

java.lang.Object

ai.pipestream.registration.handlers.ModuleRegistrationHandler

@ApplicationScoped
public class ModuleRegistrationHandler
extends Object

Handles module registration operations with proper reactive flow. Updated to use the new VerbNoun proto naming convention.

Constructor Summary

Constructors

Constructor	Description
ModuleRegistrationHandler()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Multi<RegistrationEvent>	registerModule(RegisterModuleRequest request)	Register a module with streaming status updates.
io.smallrye.mutiny.Uni<UnregisterModuleResponse>	unregisterModule(UnregisterModuleRequest request)	Unregister a module

Methods inherited from class java.lang.Object

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

Constructor Details

ModuleRegistrationHandler

public ModuleRegistrationHandler()

Method Details

registerModule

public io.smallrye.mutiny.Multi<RegistrationEvent> registerModule(RegisterModuleRequest request)

Register a module with streaming status updates. Flow: Validate → Consul → Health → Fetch Metadata → Apicurio → Database → OpenSearch Returns Multi which PlatformRegistrationService wraps in RegisterModuleResponse.

unregisterModule

public io.smallrye.mutiny.Uni<UnregisterModuleResponse> unregisterModule(UnregisterModuleRequest request)

Unregister a module