Package ai.pipestream.platform.registration.v1

Class PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingV2Stub

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

    • register

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,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.

    • unregister

      public UnregisterResponse unregister(UnregisterRequest request) throws io.grpc.StatusException
       Unregister a service or module from Consul and the platform registry.
      Throws:
      io.grpc.StatusException

    • listServices

      public ListServicesResponse listServices(ListServicesRequest request) throws io.grpc.StatusException
       List all registered services with health status and metadata.
      Throws:
      io.grpc.StatusException

    • listPlatformModules

      public ListPlatformModulesResponse listPlatformModules(ListPlatformModulesRequest request) throws io.grpc.StatusException
       List all registered modules with schema and capability information.
      Throws:
      io.grpc.StatusException

    • getService

      public GetServiceResponse getService(GetServiceRequest request) throws io.grpc.StatusException
       Get specific service details by name or Consul service ID.
      Throws:
      io.grpc.StatusException

    • getModule

      public GetModuleResponse getModule(GetModuleRequest request) throws io.grpc.StatusException
       Get specific module details by name or Consul service ID.
      Throws:
      io.grpc.StatusException

    • resolveService

      public ResolveServiceResponse resolveService(ResolveServiceRequest request) throws io.grpc.StatusException
       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.
      Throws:
      io.grpc.StatusException

    • watchServices

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,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

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,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.

    • getModuleSchema

      public GetModuleSchemaResponse getModuleSchema(GetModuleSchemaRequest request) throws io.grpc.StatusException
       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.
      Throws:
      io.grpc.StatusException

    • getModuleSchemaVersions

      public GetModuleSchemaVersionsResponse getModuleSchemaVersions(GetModuleSchemaVersionsRequest request) throws io.grpc.StatusException
       List all available schema versions for a module.
 Provides detailed version metadata from Apicurio Registry including
 creation timestamps and version-specific descriptions.
      Throws:
      io.grpc.StatusException

    • getConnectorSchema

      public GetConnectorSchemaResponse getConnectorSchema(GetConnectorSchemaRequest request) throws io.grpc.StatusException
       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.
      Throws:
      io.grpc.StatusException