Package ai.pipestream.platform.registration.v1

Interface PlatformRegistrationService

All Superinterfaces:
io.quarkus.grpc.MutinyService
All Known Implementing Classes:
PlatformRegistrationServiceClient
@Generated(value="by Mutiny Grpc generator", comments="Source: ai/pipestream/platform/registration/v1/platform_registration.proto") public interface PlatformRegistrationService extends io.quarkus.grpc.MutinyService

  • Method Details

    • unregister

      io.smallrye.mutiny.Uni<UnregisterResponse> unregister(UnregisterRequest request)
        Unregister a service or module from Consul and the platform registry.

    • listServices

      io.smallrye.mutiny.Uni<ListServicesResponse> listServices(ListServicesRequest request)
        List all registered services with health status and metadata.

    • listPlatformModules

      io.smallrye.mutiny.Uni<ListPlatformModulesResponse> listPlatformModules(ListPlatformModulesRequest request)
        List all registered modules with schema and capability information.

    • getService

      io.smallrye.mutiny.Uni<GetServiceResponse> getService(GetServiceRequest request)
        Get specific service details by name or Consul service ID.

    • getModule

      io.smallrye.mutiny.Uni<GetModuleResponse> getModule(GetModuleRequest request)
        Get specific module details by name or Consul service ID.

    • resolveService

      io.smallrye.mutiny.Uni<ResolveServiceResponse> resolveService(ResolveServiceRequest request)
        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.

    • getModuleSchema

      io.smallrye.mutiny.Uni<GetModuleSchemaResponse> getModuleSchema(GetModuleSchemaRequest request)
        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.

    • getModuleSchemaVersions

      io.smallrye.mutiny.Uni<GetModuleSchemaVersionsResponse> getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)
        List all available schema versions for a module.
 
  Provides detailed version metadata from Apicurio Registry including
  creation timestamps and version-specific descriptions.

    • register

      io.smallrye.mutiny.Multi<RegisterResponse> register(RegisterRequest request)
        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.

    • watchServices

      io.smallrye.mutiny.Multi<WatchServicesResponse> watchServices(WatchServicesRequest request)
        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.

    • watchModules

      io.smallrye.mutiny.Multi<WatchModulesResponse> watchModules(WatchModulesRequest request)
        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.