Package ai.pipestream.platform.registration.v1

Class PlatformRegistrationServiceBean

java.lang.Object

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

ai.pipestream.platform.registration.v1.PlatformRegistrationServiceBean

All Implemented Interfaces:

io.grpc.BindableService, io.quarkus.grpc.MutinyBean

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/platform/registration/v1/platform_registration.proto")
public class PlatformRegistrationServiceBean
extends MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase
implements io.grpc.BindableService, io.quarkus.grpc.MutinyBean

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<GetConnectorSchemaResponse>	getConnectorSchema(GetConnectorSchemaRequest request)	Get connector schema from Apicurio Registry.
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<ListPlatformModulesResponse>	listPlatformModules(ListPlatformModulesRequest 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<RegisterResponse>	register(RegisterRequest request)	Register a service or module with streaming status updates.
io.smallrye.mutiny.Uni<ResolveServiceResponse>	resolveService(ResolveServiceRequest request)	Resolve service endpoint for dynamic routing.
io.smallrye.mutiny.Uni<UnregisterResponse>	unregister(UnregisterRequest request)	Unregister a service or module 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

Methods inherited from interface io.grpc.BindableService

bindService

Method Details

unregister

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

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Unregister a service or module from Consul and the platform registry.
 

Overrides:

unregister 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

listPlatformModules

public io.smallrye.mutiny.Uni<ListPlatformModulesResponse> listPlatformModules(ListPlatformModulesRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  List all registered modules with schema and capability information.
 

Overrides:

listPlatformModules 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

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

getConnectorSchema

public io.smallrye.mutiny.Uni<GetConnectorSchemaResponse> getConnectorSchema(GetConnectorSchemaRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Get connector schema from Apicurio Registry.
 
  Retrieves either a specific version or the latest schema for a connector.
  Returns JSON Schema used for validating connector configuration.
 

Overrides:

getConnectorSchema in class MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

register

public io.smallrye.mutiny.Multi<RegisterResponse> register(RegisterRequest request)

Description copied from class: MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

  Register a service or module with streaming status updates.
 
  Returns a stream of RegistrationEvent messages tracking progress through
  validation, Consul registration, health check configuration, and completion.
  For modules, also includes schema validation and Apicurio registration.
 

Overrides:

register 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