Package ai.pipestream.registration.handlers

Class ServiceRegistrationHandler

java.lang.Object

ai.pipestream.registration.handlers.ServiceRegistrationHandler

@ApplicationScoped
public class ServiceRegistrationHandler
extends Object

Handles service registration operations. Updated to use the unified RegisterRequest from the new proto API.

Constructor Summary

Constructors

Constructor	Description
ServiceRegistrationHandler()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ServiceRegistrationHandler

public ServiceRegistrationHandler()

Method Details

registerService

public io.smallrye.mutiny.Multi<RegistrationEvent> registerService(RegisterRequest request)

Register a service with streaming status updates. Expects RegisterRequest with type=SERVICE_TYPE_SERVICE. Returns Multi<RegistrationEvent> which PlatformRegistrationService wraps in RegisterResponse.

unregisterService

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

Unregister a service using the unified UnregisterRequest