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 unified RegisterRequest from the new proto API.

Constructor Summary

Constructors

Constructor	Description
ModuleRegistrationHandler()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Multi<RegistrationEvent>	registerModule(RegisterRequest request)	Register a module with streaming status updates.
io.smallrye.mutiny.Uni<UnregisterResponse>	unregisterModule(UnregisterRequest request)	Unregister a module using the unified UnregisterRequest

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(RegisterRequest request)

Register a module with streaming status updates. Expects RegisterRequest with type=SERVICE_TYPE_MODULE. Flow: Validate → Consul → Health → Fetch Metadata → Apicurio → Database → OpenSearch Returns Multi<RegistrationEvent> which PlatformRegistrationService wraps in RegisterResponse.

unregisterModule

public io.smallrye.mutiny.Uni<UnregisterResponse> unregisterModule(UnregisterRequest request)

Unregister a module using the unified UnregisterRequest