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

    • unregisterService

      io.smallrye.mutiny.Uni<UnregisterServiceResponse> unregisterService(UnregisterServiceRequest request)
        Unregister a service from Consul and the platform registry.

    • unregisterModule

      io.smallrye.mutiny.Uni<UnregisterModuleResponse> unregisterModule(UnregisterModuleRequest request)
        Unregister a 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.

    • listModules

      io.smallrye.mutiny.Uni<ListModulesResponse> listModules(ListModulesRequest 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.

    • registerService

      io.smallrye.mutiny.Multi<RegisterServiceResponse> registerService(RegisterServiceRequest request)
        Register a service with streaming status updates.

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

    • registerModule

      io.smallrye.mutiny.Multi<RegisterModuleResponse> registerModule(RegisterModuleRequest request)
        Register a module (document processor) with streaming status updates.

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

    • 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.