Package ai.pipestream.registration.grpc

Class PlatformRegistrationService

java.lang.Object
ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase
ai.pipestream.registration.grpc.PlatformRegistrationService
All Implemented Interfaces:
io.grpc.BindableService
public class PlatformRegistrationService extends ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase
Main platform registration service implementation

  • Constructor Summary

    Constructors
    Constructor
    Description
    PlatformRegistrationService()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleDetails>
    getModule(ai.pipestream.platform.registration.ServiceLookupRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleSchemaResponse>
    getModuleSchema(ai.pipestream.platform.registration.GetModuleSchemaRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceDetails>
    getService(ai.pipestream.platform.registration.ServiceLookupRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleListResponse>
    listModules(com.google.protobuf.Empty request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceListResponse>
    listServices(com.google.protobuf.Empty request)
     
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.RegistrationEvent>
    registerModule(ai.pipestream.platform.registration.ModuleRegistrationRequest request)
     
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.RegistrationEvent>
    registerService(ai.pipestream.platform.registration.ServiceRegistrationRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceResolveResponse>
    resolveService(ai.pipestream.platform.registration.ServiceResolveRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.UnregisterResponse>
    unregisterModule(ai.pipestream.platform.registration.UnregisterRequest request)
     
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.UnregisterResponse>
    unregisterService(ai.pipestream.platform.registration.UnregisterRequest request)
     
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.ModuleListResponse>
    watchModules(com.google.protobuf.Empty request)
     
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.ServiceListResponse>
    watchServices(com.google.protobuf.Empty request)
     

    Methods inherited from class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    bindService, getModuleSchemaVersions, 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

    • registerService

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.RegistrationEvent> registerService(ai.pipestream.platform.registration.ServiceRegistrationRequest request)
      Overrides:
      registerService in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • registerModule

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.RegistrationEvent> registerModule(ai.pipestream.platform.registration.ModuleRegistrationRequest request)
      Overrides:
      registerModule in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • unregisterService

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.UnregisterResponse> unregisterService(ai.pipestream.platform.registration.UnregisterRequest request)
      Overrides:
      unregisterService in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • unregisterModule

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.UnregisterResponse> unregisterModule(ai.pipestream.platform.registration.UnregisterRequest request)
      Overrides:
      unregisterModule in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • listServices

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceListResponse> listServices(com.google.protobuf.Empty request)
      Overrides:
      listServices in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • listModules

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleListResponse> listModules(com.google.protobuf.Empty request)
      Overrides:
      listModules in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • getService

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceDetails> getService(ai.pipestream.platform.registration.ServiceLookupRequest request)
      Overrides:
      getService in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • getModule

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleDetails> getModule(ai.pipestream.platform.registration.ServiceLookupRequest request)
      Overrides:
      getModule in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • resolveService

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceResolveResponse> resolveService(ai.pipestream.platform.registration.ServiceResolveRequest request)
      Overrides:
      resolveService in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • watchServices

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.ServiceListResponse> watchServices(com.google.protobuf.Empty request)
      Overrides:
      watchServices in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • watchModules

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.ModuleListResponse> watchModules(com.google.protobuf.Empty request)
      Overrides:
      watchModules in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase

    • getModuleSchema

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleSchemaResponse> getModuleSchema(ai.pipestream.platform.registration.GetModuleSchemaRequest request)
      Overrides:
      getModuleSchema in class ai.pipestream.platform.registration.MutinyPlatformRegistrationGrpc.PlatformRegistrationImplBase