Package ai.pipestream.registration.grpc

Class PlatformRegistrationService

java.lang.Object
ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase
ai.pipestream.registration.grpc.PlatformRegistrationService
All Implemented Interfaces:
io.grpc.BindableService
public class PlatformRegistrationService extends ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase
Main platform registration service implementation. Updated to use the unified Register/Unregister API from the new proto definition.

  • Constructor Summary

    Constructors
    Constructor
    Description
    PlatformRegistrationService()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleResponse>
    getModule(ai.pipestream.platform.registration.v1.GetModuleRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleSchemaResponse>
    getModuleSchema(ai.pipestream.platform.registration.v1.GetModuleSchemaRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse>
    getModuleSchemaVersions(ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetServiceResponse>
    getService(ai.pipestream.platform.registration.v1.GetServiceRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ListPlatformModulesResponse>
    listPlatformModules(ai.pipestream.platform.registration.v1.ListPlatformModulesRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ListServicesResponse>
    listServices(ai.pipestream.platform.registration.v1.ListServicesRequest request)
     
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.RegisterResponse>
    register(ai.pipestream.platform.registration.v1.RegisterRequest request)
    Unified registration method - routes based on ServiceType.
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ResolveServiceResponse>
    resolveService(ai.pipestream.platform.registration.v1.ResolveServiceRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.UnregisterResponse>
    unregister(ai.pipestream.platform.registration.v1.UnregisterRequest request)
    Unified unregistration method.
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.WatchModulesResponse>
    watchModules(ai.pipestream.platform.registration.v1.WatchModulesRequest request)
     
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.WatchServicesResponse>
    watchServices(ai.pipestream.platform.registration.v1.WatchServicesRequest request)
     

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

    bindService, getConnectorSchema, updateTags, withCompression

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • PlatformRegistrationService

      public PlatformRegistrationService()

  • Method Details

    • register

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.RegisterResponse> register(ai.pipestream.platform.registration.v1.RegisterRequest request)
      Unified registration method - routes based on ServiceType. Replaces the old separate registerService/registerModule methods.
      Overrides:
      register in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • unregister

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.UnregisterResponse> unregister(ai.pipestream.platform.registration.v1.UnregisterRequest request)
      Unified unregistration method. Replaces the old separate unregisterService/unregisterModule methods. Routes to appropriate handler based on looking up the service in Consul. For simplicity, we try service unregistration first.
      Overrides:
      unregister in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • listServices

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ListServicesResponse> listServices(ai.pipestream.platform.registration.v1.ListServicesRequest request)
      Overrides:
      listServices in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • listPlatformModules

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ListPlatformModulesResponse> listPlatformModules(ai.pipestream.platform.registration.v1.ListPlatformModulesRequest request)
      Overrides:
      listPlatformModules in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • getService

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetServiceResponse> getService(ai.pipestream.platform.registration.v1.GetServiceRequest request)
      Overrides:
      getService in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • getModule

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleResponse> getModule(ai.pipestream.platform.registration.v1.GetModuleRequest request)
      Overrides:
      getModule in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • resolveService

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ResolveServiceResponse> resolveService(ai.pipestream.platform.registration.v1.ResolveServiceRequest request)
      Overrides:
      resolveService in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • watchServices

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.WatchServicesResponse> watchServices(ai.pipestream.platform.registration.v1.WatchServicesRequest request)
      Overrides:
      watchServices in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • watchModules

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.WatchModulesResponse> watchModules(ai.pipestream.platform.registration.v1.WatchModulesRequest request)
      Overrides:
      watchModules in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • getModuleSchema

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleSchemaResponse> getModuleSchema(ai.pipestream.platform.registration.v1.GetModuleSchemaRequest request)
      Overrides:
      getModuleSchema in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase

    • getModuleSchemaVersions

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse> getModuleSchemaVersions(ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest request)
      Overrides:
      getModuleSchemaVersions in class ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase