Package ai.pipestream.registration.grpc

Class PlatformRegistrationService

java.lang.Object

ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

ai.pipestream.registration.grpc.PlatformRegistrationService

All Implemented Interfaces:

io.grpc.BindableService

public class PlatformRegistrationService
extends MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

Main platform registration service implementation. Updated to match the new 'VerbNoun' naming convention.

Constructor Summary

Constructors

Constructor	Description
PlatformRegistrationService()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<GetModuleResponse>	getModule(GetModuleRequest request)	Get specific module details by name or Consul service ID.
io.smallrye.mutiny.Uni<GetModuleSchemaResponse>	getModuleSchema(GetModuleSchemaRequest request)	Get module schema from Apicurio Registry.
io.smallrye.mutiny.Uni<GetModuleSchemaVersionsResponse>	getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)	List all available schema versions for a module.
io.smallrye.mutiny.Uni<GetServiceResponse>	getService(GetServiceRequest request)	Get specific service details by name or Consul service ID.
io.smallrye.mutiny.Uni<ListModulesResponse>	listModules(ListModulesRequest request)	List all registered modules with schema and capability information.
io.smallrye.mutiny.Uni<ListServicesResponse>	listServices(ListServicesRequest request)	List all registered services with health status and metadata.
io.smallrye.mutiny.Multi<RegisterModuleResponse>	registerModule(RegisterModuleRequest request)	Register a module (document processor) with streaming status updates.
io.smallrye.mutiny.Multi<RegisterServiceResponse>	registerService(RegisterServiceRequest request)	Register a service with streaming status updates.
io.smallrye.mutiny.Uni<ResolveServiceResponse>	resolveService(ResolveServiceRequest request)	Resolve service endpoint for dynamic routing.
io.smallrye.mutiny.Uni<UnregisterModuleResponse>	unregisterModule(UnregisterModuleRequest request)	Unregister a module from Consul and the platform registry.
io.smallrye.mutiny.Uni<UnregisterServiceResponse>	unregisterService(UnregisterServiceRequest request)	Unregister a service from Consul and the platform registry.
io.smallrye.mutiny.Multi<WatchModulesResponse>	watchModules(WatchModulesRequest request)	Watch for real-time updates to the list of all registered modules.
io.smallrye.mutiny.Multi<WatchServicesResponse>	watchServices(WatchServicesRequest request)	Watch for real-time updates to the list of all healthy services.

Methods inherited from class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

bindService, withCompression

Methods inherited from class java.lang.Object

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

Constructor Details

PlatformRegistrationService

public PlatformRegistrationService()

Method Details

registerService

public io.smallrye.mutiny.Multi<RegisterServiceResponse> registerService(RegisterServiceRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Register a service with streaming status updates.

  Returns a stream of RegistrationEvent messages tracking progress through
  validation, Consul registration, health check configuration, and completion.
 

Overrides:

registerService in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

registerModule

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

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Register a module (document processor) with streaming status updates.

  Extends service registration by adding schema validation, Apicurio registration,
  and module-specific metadata handling.
 

Overrides:

registerModule in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

unregisterService

public io.smallrye.mutiny.Uni<UnregisterServiceResponse> unregisterService(UnregisterServiceRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Unregister a service from Consul and the platform registry.
 

Overrides:

unregisterService in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

unregisterModule

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

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Unregister a module from Consul and the platform registry.
 

Overrides:

unregisterModule in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

listServices

public io.smallrye.mutiny.Uni<ListServicesResponse> listServices(ListServicesRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  List all registered services with health status and metadata.
 

Overrides:

listServices in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

listModules

public io.smallrye.mutiny.Uni<ListModulesResponse> listModules(ListModulesRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  List all registered modules with schema and capability information.
 

Overrides:

listModules in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

getService

public io.smallrye.mutiny.Uni<GetServiceResponse> getService(GetServiceRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Get specific service details by name or Consul service ID.
 

Overrides:

getService in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

getModule

public io.smallrye.mutiny.Uni<GetModuleResponse> getModule(GetModuleRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Get specific module details by name or Consul service ID.
 

Overrides:

getModule in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

resolveService

public io.smallrye.mutiny.Uni<ResolveServiceResponse> resolveService(ResolveServiceRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Resolve service endpoint for dynamic routing.

  Returns the best available instance of a service based on health and load.
  Supports preference criteria like local instances or required capabilities.
 

Overrides:

resolveService in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

watchServices

public io.smallrye.mutiny.Multi<WatchServicesResponse> watchServices(WatchServicesRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Watch for real-time updates to the list of all healthy services.

  The server will send an initial list, and then send a new full
  list whenever any service is registered, unregistered, or changes
  its health status.
 

Overrides:

watchServices in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

watchModules

public io.smallrye.mutiny.Multi<WatchModulesResponse> watchModules(WatchModulesRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Watch for real-time updates to the list of all registered modules.

  The server will send an initial list, and then send a new full
  list whenever any module is registered, unregistered, or changes
  its health status.
 

Overrides:

watchModules in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

getModuleSchema

public io.smallrye.mutiny.Uni<GetModuleSchemaResponse> getModuleSchema(GetModuleSchemaRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Get module schema from Apicurio Registry.

  Retrieves either a specific version or the latest schema for a module.
  Returns JSON Schema used for validating module configuration.
 

Overrides:

getModuleSchema in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

getModuleSchemaVersions

public io.smallrye.mutiny.Uni<GetModuleSchemaVersionsResponse> getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  List all available schema versions for a module.

  Provides detailed version metadata from Apicurio Registry including
  creation timestamps and version-specific descriptions.
 

Overrides:

getModuleSchemaVersions in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase