Package ai.pipestream.platform.registration.v1

Class PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub

java.lang.Object
io.grpc.stub.AbstractStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub>
io.grpc.stub.AbstractAsyncStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub>
ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub
Enclosing class:
PlatformRegistrationServiceGrpc
public static class PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub extends io.grpc.stub.AbstractAsyncStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub>
A stub to allow clients to do asynchronous rpc calls to service PlatformRegistrationService. 
 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 PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub>

    • registerService

      public void registerService(RegisterServiceRequest request, io.grpc.stub.StreamObserver<RegisterServiceResponse> responseObserver)
       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 void registerModule(RegisterModuleRequest request, io.grpc.stub.StreamObserver<RegisterModuleResponse> responseObserver)
       Register a module (document processor) with streaming status updates.
 Extends service registration by adding schema validation, Apicurio registration,
 and module-specific metadata handling.

    • unregisterService

      public void unregisterService(UnregisterServiceRequest request, io.grpc.stub.StreamObserver<UnregisterServiceResponse> responseObserver)
       Unregister a service from Consul and the platform registry.

    • unregisterModule

      public void unregisterModule(UnregisterModuleRequest request, io.grpc.stub.StreamObserver<UnregisterModuleResponse> responseObserver)
       Unregister a module from Consul and the platform registry.

    • listServices

      public void listServices(ListServicesRequest request, io.grpc.stub.StreamObserver<ListServicesResponse> responseObserver)
       List all registered services with health status and metadata.

    • listModules

      public void listModules(ListModulesRequest request, io.grpc.stub.StreamObserver<ListModulesResponse> responseObserver)
       List all registered modules with schema and capability information.

    • getService

      public void getService(GetServiceRequest request, io.grpc.stub.StreamObserver<GetServiceResponse> responseObserver)
       Get specific service details by name or Consul service ID.

    • getModule

      public void getModule(GetModuleRequest request, io.grpc.stub.StreamObserver<GetModuleResponse> responseObserver)
       Get specific module details by name or Consul service ID.

    • resolveService

      public void resolveService(ResolveServiceRequest request, io.grpc.stub.StreamObserver<ResolveServiceResponse> responseObserver)
       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.

    • watchServices

      public void watchServices(WatchServicesRequest request, io.grpc.stub.StreamObserver<WatchServicesResponse> responseObserver)
       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 void watchModules(WatchModulesRequest request, io.grpc.stub.StreamObserver<WatchModulesResponse> responseObserver)
       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.

    • getModuleSchema

      public void getModuleSchema(GetModuleSchemaRequest request, io.grpc.stub.StreamObserver<GetModuleSchemaResponse> responseObserver)
       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 void getModuleSchemaVersions(GetModuleSchemaVersionsRequest request, io.grpc.stub.StreamObserver<GetModuleSchemaVersionsResponse> responseObserver)
       List all available schema versions for a module.
 Provides detailed version metadata from Apicurio Registry including
 creation timestamps and version-specific descriptions.