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 final 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>

    • register

      public void register(RegisterRequest request, io.grpc.stub.StreamObserver<RegisterResponse> responseObserver)
       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.

    • unregister

      public void unregister(UnregisterRequest request, io.grpc.stub.StreamObserver<UnregisterResponse> responseObserver)
       Unregister a service or 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.

    • listPlatformModules

      public void listPlatformModules(ListPlatformModulesRequest request, io.grpc.stub.StreamObserver<ListPlatformModulesResponse> 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.

    • getConnectorSchema

      public void getConnectorSchema(GetConnectorSchemaRequest request, io.grpc.stub.StreamObserver<GetConnectorSchemaResponse> responseObserver)
       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.