Class PlatformRegistrationService

java.lang.Object
ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase
ai.pipestream.registration.grpc.PlatformRegistrationService
All Implemented Interfaces:
ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.AsyncService, io.grpc.BindableService
public class PlatformRegistrationService extends ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase
Main platform registration service implementation.

Implements the blocking (StreamObserver) gRPC contract and runs every RPC on a Quarkus virtual thread (RunOnVirtualThread). Handlers are plain blocking code; the few genuinely async dependencies (Consul, Vert.x HTTP) are bridged to blocking on the virtual thread, so no work ever pins the Vert.x event loop and there is no reactive plumbing here.

  • Constructor Summary

    Constructors
    Constructor
    Description
    PlatformRegistrationService()
    Creates the gRPC service bean.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    getModule(ai.pipestream.platform.registration.v1.GetModuleRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetModuleResponse> responseObserver)
     
    void
    getModuleSchema(ai.pipestream.platform.registration.v1.GetModuleSchemaRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetModuleSchemaResponse> responseObserver)
     
    void
    getModuleSchemaVersions(ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse> responseObserver)
     
    void
    getSchemaArtifact(ai.pipestream.platform.registration.v1.GetSchemaArtifactRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetSchemaArtifactResponse> responseObserver)
     
    void
    getService(ai.pipestream.platform.registration.v1.GetServiceRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetServiceResponse> responseObserver)
     
    void
    getTypeDescriptor(ai.pipestream.platform.registration.v1.GetTypeDescriptorRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetTypeDescriptorResponse> responseObserver)
     
    void
    getTypeMetadata(ai.pipestream.platform.registration.v1.GetTypeMetadataRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetTypeMetadataResponse> responseObserver)
     
    void
    listPlatformModules(ai.pipestream.platform.registration.v1.ListPlatformModulesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ListPlatformModulesResponse> responseObserver)
     
    void
    listServices(ai.pipestream.platform.registration.v1.ListServicesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ListServicesResponse> responseObserver)
     
    void
    listTypeDescriptors(ai.pipestream.platform.registration.v1.ListTypeDescriptorsRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ListTypeDescriptorsResponse> responseObserver)
     
    void
    promoteTypeMetadata(ai.pipestream.platform.registration.v1.PromoteTypeMetadataRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.PromoteTypeMetadataResponse> responseObserver)
     
    void
    register(ai.pipestream.platform.registration.v1.RegisterRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.RegisterResponse> responseObserver)
     
    void
    resolveService(ai.pipestream.platform.registration.v1.ResolveServiceRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ResolveServiceResponse> responseObserver)
     
    void
    saveTypeMetadata(ai.pipestream.platform.registration.v1.SaveTypeMetadataRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.SaveTypeMetadataResponse> responseObserver)
     
    void
    unregister(ai.pipestream.platform.registration.v1.UnregisterRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.UnregisterResponse> responseObserver)
     
    void
    watchModules(ai.pipestream.platform.registration.v1.WatchModulesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.WatchModulesResponse> responseObserver)
     
    void
    watchServices(ai.pipestream.platform.registration.v1.WatchServicesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.WatchServicesResponse> responseObserver)
     

    Methods inherited from class ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    bindService

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.AsyncService

    getConnectorSchema, updateTags

  • Constructor Details

    • PlatformRegistrationService

      public PlatformRegistrationService()
      Creates the gRPC service bean. The per-RPC handlers it delegates to are supplied by CDI field injection.

  • Method Details

    • register

      public void register(ai.pipestream.platform.registration.v1.RegisterRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.RegisterResponse> responseObserver)

    • unregister

      public void unregister(ai.pipestream.platform.registration.v1.UnregisterRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.UnregisterResponse> responseObserver)

    • listServices

      public void listServices(ai.pipestream.platform.registration.v1.ListServicesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ListServicesResponse> responseObserver)

    • listPlatformModules

      public void listPlatformModules(ai.pipestream.platform.registration.v1.ListPlatformModulesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ListPlatformModulesResponse> responseObserver)

    • getService

      public void getService(ai.pipestream.platform.registration.v1.GetServiceRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetServiceResponse> responseObserver)

    • getModule

      public void getModule(ai.pipestream.platform.registration.v1.GetModuleRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetModuleResponse> responseObserver)

    • resolveService

      public void resolveService(ai.pipestream.platform.registration.v1.ResolveServiceRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ResolveServiceResponse> responseObserver)

    • watchServices

      public void watchServices(ai.pipestream.platform.registration.v1.WatchServicesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.WatchServicesResponse> responseObserver)

    • watchModules

      public void watchModules(ai.pipestream.platform.registration.v1.WatchModulesRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.WatchModulesResponse> responseObserver)

    • getModuleSchema

      public void getModuleSchema(ai.pipestream.platform.registration.v1.GetModuleSchemaRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetModuleSchemaResponse> responseObserver)

    • getSchemaArtifact

      public void getSchemaArtifact(ai.pipestream.platform.registration.v1.GetSchemaArtifactRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetSchemaArtifactResponse> responseObserver)

    • getModuleSchemaVersions

      public void getModuleSchemaVersions(ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse> responseObserver)

    • getTypeDescriptor

      public void getTypeDescriptor(ai.pipestream.platform.registration.v1.GetTypeDescriptorRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetTypeDescriptorResponse> responseObserver)

    • listTypeDescriptors

      public void listTypeDescriptors(ai.pipestream.platform.registration.v1.ListTypeDescriptorsRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.ListTypeDescriptorsResponse> responseObserver)

    • getTypeMetadata

      public void getTypeMetadata(ai.pipestream.platform.registration.v1.GetTypeMetadataRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.GetTypeMetadataResponse> responseObserver)

    • saveTypeMetadata

      public void saveTypeMetadata(ai.pipestream.platform.registration.v1.SaveTypeMetadataRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.SaveTypeMetadataResponse> responseObserver)

    • promoteTypeMetadata

      public void promoteTypeMetadata(ai.pipestream.platform.registration.v1.PromoteTypeMetadataRequest request, io.grpc.stub.StreamObserver<ai.pipestream.platform.registration.v1.PromoteTypeMetadataResponse> responseObserver)