Package ai.pipestream.platform.registration.v1

Class MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub

java.lang.Object
io.grpc.stub.AbstractStub<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub>
ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub
All Implemented Interfaces:
io.quarkus.grpc.MutinyStub
Enclosing class:
MutinyPlatformRegistrationServiceGrpc
public static class MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub extends io.grpc.stub.AbstractStub<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub> implements io.quarkus.grpc.MutinyStub
  Unified registration service for all platform services and modules.

  Provides centralized service discovery via Consul with health monitoring,
  module schema management via Apicurio Registry, and real-time event streaming
  for registration lifecycle tracking.

  • Method Details

    • build

      protected MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub>

    • unregisterService

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

    • unregisterModule

      public io.smallrye.mutiny.Uni<UnregisterModuleResponse> unregisterModule(UnregisterModuleRequest request)
        Unregister a module from Consul and the platform registry.

    • listServices

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

    • listModules

      public io.smallrye.mutiny.Uni<ListModulesResponse> listModules(ListModulesRequest request)
        List all registered modules with schema and capability information.

    • getService

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

    • getModule

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

    • resolveService

      public 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

      public 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

      public 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

      public 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

      public 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

      public 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

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