Hierarchy For All Packages

Package Hierarchies:

• ai.pipestream.data.module.v1,
• ai.pipestream.data.v1,
• ai.pipestream.dynamic.grpc.server,
• ai.pipestream.dynamic.grpc.util,
• ai.pipestream.platform.registration.client,
• ai.pipestream.platform.registration.v1,
• ai.pipestream.registration.consul,
• ai.pipestream.registration.entity,
• ai.pipestream.registration.events,
• ai.pipestream.registration.grpc,
• ai.pipestream.registration.handlers,
• ai.pipestream.registration.health,
• ai.pipestream.registration.repository,
• ai.pipestream.registration.startup

Class Hierarchy

• java.lang.Object
  • com.google.protobuf.AbstractMessageLite<MessageType,BuilderType> (implements com.google.protobuf.MessageLite)
    • com.google.protobuf.AbstractMessage (implements com.google.protobuf.Message)
      • com.google.protobuf.GeneratedMessage (implements java.io.Serializable)
        • ai.pipestream.data.v1.AggregateConfig (implements ai.pipestream.data.v1.AggregateConfigOrBuilder)
        • ai.pipestream.data.v1.Blob (implements ai.pipestream.data.v1.BlobOrBuilder)
        • ai.pipestream.data.v1.BlobBag (implements ai.pipestream.data.v1.BlobBagOrBuilder)
        • ai.pipestream.data.v1.Blobs (implements ai.pipestream.data.v1.BlobsOrBuilder)
        • ai.pipestream.data.module.v1.Capabilities (implements ai.pipestream.data.module.v1.CapabilitiesOrBuilder)
        • ai.pipestream.data.v1.ChunkEmbedding (implements ai.pipestream.data.v1.ChunkEmbeddingOrBuilder)
        • ai.pipestream.platform.registration.v1.Connectivity (implements ai.pipestream.platform.registration.v1.ConnectivityOrBuilder)
        • ai.pipestream.data.v1.DocOutline (implements ai.pipestream.data.v1.DocOutlineOrBuilder)
        • ai.pipestream.data.v1.Embedding (implements ai.pipestream.data.v1.EmbeddingOrBuilder)
        • ai.pipestream.data.v1.ErrorData (implements ai.pipestream.data.v1.ErrorDataOrBuilder)
        • ai.pipestream.platform.registration.v1.EventMetadata (implements ai.pipestream.platform.registration.v1.EventMetadataOrBuilder)
        • ai.pipestream.data.v1.FailedStepInputState (implements ai.pipestream.data.v1.FailedStepInputStateOrBuilder)
        • ai.pipestream.data.v1.FileStorageReference (implements ai.pipestream.data.v1.FileStorageReferenceOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleRequest (implements ai.pipestream.platform.registration.v1.GetModuleRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleResponse (implements ai.pipestream.platform.registration.v1.GetModuleResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaRequest (implements ai.pipestream.platform.registration.v1.GetModuleSchemaRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaResponse (implements ai.pipestream.platform.registration.v1.GetModuleSchemaResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest (implements ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse (implements ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponseOrBuilder)
        • ai.pipestream.data.module.v1.GetServiceRegistrationRequest (implements ai.pipestream.data.module.v1.GetServiceRegistrationRequestOrBuilder)
        • ai.pipestream.data.module.v1.GetServiceRegistrationResponse (implements ai.pipestream.data.module.v1.GetServiceRegistrationResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.GetServiceRequest (implements ai.pipestream.platform.registration.v1.GetServiceRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetServiceResponse (implements ai.pipestream.platform.registration.v1.GetServiceResponseOrBuilder)
        • ai.pipestream.data.v1.Keywords (implements ai.pipestream.data.v1.KeywordsOrBuilder)
        • ai.pipestream.data.v1.LinkReference (implements ai.pipestream.data.v1.LinkReferenceOrBuilder)
        • ai.pipestream.platform.registration.v1.ListModulesRequest (implements ai.pipestream.platform.registration.v1.ListModulesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.ListModulesResponse (implements ai.pipestream.platform.registration.v1.ListModulesResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.ListServicesRequest (implements ai.pipestream.platform.registration.v1.ListServicesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.ListServicesResponse (implements ai.pipestream.platform.registration.v1.ListServicesResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.ModuleRegistered (implements ai.pipestream.platform.registration.v1.ModuleRegisteredOrBuilder)
        • ai.pipestream.platform.registration.v1.ModuleSchemaVersion (implements ai.pipestream.platform.registration.v1.ModuleSchemaVersionOrBuilder)
        • ai.pipestream.platform.registration.v1.ModuleUnregistered (implements ai.pipestream.platform.registration.v1.ModuleUnregisteredOrBuilder)
        • ai.pipestream.data.v1.NodeProcessingConfig (implements ai.pipestream.data.v1.NodeProcessingConfigOrBuilder)
        • ai.pipestream.data.v1.ParsedMetadata (implements ai.pipestream.data.v1.ParsedMetadataOrBuilder)
        • ai.pipestream.data.v1.PipeDoc (implements ai.pipestream.data.v1.PipeDocOrBuilder)
        • ai.pipestream.data.v1.PipeStream (implements ai.pipestream.data.v1.PipeStreamOrBuilder)
        • ai.pipestream.data.module.v1.ProcessConfiguration (implements ai.pipestream.data.module.v1.ProcessConfigurationOrBuilder)
        • ai.pipestream.data.module.v1.ProcessDataRequest (implements ai.pipestream.data.module.v1.ProcessDataRequestOrBuilder)
        • ai.pipestream.data.module.v1.ProcessDataResponse (implements ai.pipestream.data.module.v1.ProcessDataResponseOrBuilder)
        • ai.pipestream.data.v1.ProcessingMapping (implements ai.pipestream.data.v1.ProcessingMappingOrBuilder)
        • ai.pipestream.platform.registration.v1.RegisterRequest (implements ai.pipestream.platform.registration.v1.RegisterRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.RegisterResponse (implements ai.pipestream.platform.registration.v1.RegisterResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.RegistrationEvent (implements ai.pipestream.platform.registration.v1.RegistrationEventOrBuilder)
        • ai.pipestream.platform.registration.v1.ResolveServiceRequest (implements ai.pipestream.platform.registration.v1.ResolveServiceRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.ResolveServiceResponse (implements ai.pipestream.platform.registration.v1.ResolveServiceResponseOrBuilder)
        • ai.pipestream.data.v1.SearchMetadata (implements ai.pipestream.data.v1.SearchMetadataOrBuilder)
        • ai.pipestream.data.v1.Section (implements ai.pipestream.data.v1.SectionOrBuilder)
        • ai.pipestream.data.v1.SemanticChunk (implements ai.pipestream.data.v1.SemanticChunkOrBuilder)
        • ai.pipestream.data.v1.SemanticProcessingResult (implements ai.pipestream.data.v1.SemanticProcessingResultOrBuilder)
        • ai.pipestream.data.module.v1.ServiceMetadata (implements ai.pipestream.data.module.v1.ServiceMetadataOrBuilder)
        • ai.pipestream.platform.registration.v1.ServiceRegistered (implements ai.pipestream.platform.registration.v1.ServiceRegisteredOrBuilder)
        • ai.pipestream.platform.registration.v1.ServiceUnregistered (implements ai.pipestream.platform.registration.v1.ServiceUnregisteredOrBuilder)
        • ai.pipestream.data.v1.SplitConfig (implements ai.pipestream.data.v1.SplitConfigOrBuilder)
        • ai.pipestream.data.v1.StepExecutionRecord (implements ai.pipestream.data.v1.StepExecutionRecordOrBuilder)
        • ai.pipestream.data.v1.StreamMetadata (implements ai.pipestream.data.v1.StreamMetadataOrBuilder)
        • ai.pipestream.data.v1.Tags (implements ai.pipestream.data.v1.TagsOrBuilder)
        • ai.pipestream.data.v1.TransformConfig (implements ai.pipestream.data.v1.TransformConfigOrBuilder)
        • ai.pipestream.platform.registration.v1.UnregisterRequest (implements ai.pipestream.platform.registration.v1.UnregisterRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.UnregisterResponse (implements ai.pipestream.platform.registration.v1.UnregisterResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchModulesRequest (implements ai.pipestream.platform.registration.v1.WatchModulesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchModulesResponse (implements ai.pipestream.platform.registration.v1.WatchModulesResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchServicesRequest (implements ai.pipestream.platform.registration.v1.WatchServicesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchServicesResponse (implements ai.pipestream.platform.registration.v1.WatchServicesResponseOrBuilder)
  • com.google.protobuf.AbstractMessageLite.Builder<MessageType,BuilderType> (implements com.google.protobuf.MessageLite.Builder)
    • com.google.protobuf.AbstractMessage.Builder<BuilderType> (implements com.google.protobuf.Message.Builder)
      • com.google.protobuf.GeneratedMessage.Builder<BuilderT>
        • ai.pipestream.data.v1.AggregateConfig.Builder (implements ai.pipestream.data.v1.AggregateConfigOrBuilder)
        • ai.pipestream.data.v1.Blob.Builder (implements ai.pipestream.data.v1.BlobOrBuilder)
        • ai.pipestream.data.v1.BlobBag.Builder (implements ai.pipestream.data.v1.BlobBagOrBuilder)
        • ai.pipestream.data.v1.Blobs.Builder (implements ai.pipestream.data.v1.BlobsOrBuilder)
        • ai.pipestream.data.module.v1.Capabilities.Builder (implements ai.pipestream.data.module.v1.CapabilitiesOrBuilder)
        • ai.pipestream.data.v1.ChunkEmbedding.Builder (implements ai.pipestream.data.v1.ChunkEmbeddingOrBuilder)
        • ai.pipestream.platform.registration.v1.Connectivity.Builder (implements ai.pipestream.platform.registration.v1.ConnectivityOrBuilder)
        • ai.pipestream.data.v1.DocOutline.Builder (implements ai.pipestream.data.v1.DocOutlineOrBuilder)
        • ai.pipestream.data.v1.Embedding.Builder (implements ai.pipestream.data.v1.EmbeddingOrBuilder)
        • ai.pipestream.data.v1.ErrorData.Builder (implements ai.pipestream.data.v1.ErrorDataOrBuilder)
        • ai.pipestream.platform.registration.v1.EventMetadata.Builder (implements ai.pipestream.platform.registration.v1.EventMetadataOrBuilder)
        • ai.pipestream.data.v1.FailedStepInputState.Builder (implements ai.pipestream.data.v1.FailedStepInputStateOrBuilder)
        • ai.pipestream.data.v1.FileStorageReference.Builder (implements ai.pipestream.data.v1.FileStorageReferenceOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleRequest.Builder (implements ai.pipestream.platform.registration.v1.GetModuleRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleResponse.Builder (implements ai.pipestream.platform.registration.v1.GetModuleResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaRequest.Builder (implements ai.pipestream.platform.registration.v1.GetModuleSchemaRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaResponse.Builder (implements ai.pipestream.platform.registration.v1.GetModuleSchemaResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest.Builder (implements ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse.Builder (implements ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponseOrBuilder)
        • ai.pipestream.data.module.v1.GetServiceRegistrationRequest.Builder (implements ai.pipestream.data.module.v1.GetServiceRegistrationRequestOrBuilder)
        • ai.pipestream.data.module.v1.GetServiceRegistrationResponse.Builder (implements ai.pipestream.data.module.v1.GetServiceRegistrationResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.GetServiceRequest.Builder (implements ai.pipestream.platform.registration.v1.GetServiceRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.GetServiceResponse.Builder (implements ai.pipestream.platform.registration.v1.GetServiceResponseOrBuilder)
        • ai.pipestream.data.v1.Keywords.Builder (implements ai.pipestream.data.v1.KeywordsOrBuilder)
        • ai.pipestream.data.v1.LinkReference.Builder (implements ai.pipestream.data.v1.LinkReferenceOrBuilder)
        • ai.pipestream.platform.registration.v1.ListModulesRequest.Builder (implements ai.pipestream.platform.registration.v1.ListModulesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.ListModulesResponse.Builder (implements ai.pipestream.platform.registration.v1.ListModulesResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.ListServicesRequest.Builder (implements ai.pipestream.platform.registration.v1.ListServicesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.ListServicesResponse.Builder (implements ai.pipestream.platform.registration.v1.ListServicesResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.ModuleRegistered.Builder (implements ai.pipestream.platform.registration.v1.ModuleRegisteredOrBuilder)
        • ai.pipestream.platform.registration.v1.ModuleSchemaVersion.Builder (implements ai.pipestream.platform.registration.v1.ModuleSchemaVersionOrBuilder)
        • ai.pipestream.platform.registration.v1.ModuleUnregistered.Builder (implements ai.pipestream.platform.registration.v1.ModuleUnregisteredOrBuilder)
        • ai.pipestream.data.v1.NodeProcessingConfig.Builder (implements ai.pipestream.data.v1.NodeProcessingConfigOrBuilder)
        • ai.pipestream.data.v1.ParsedMetadata.Builder (implements ai.pipestream.data.v1.ParsedMetadataOrBuilder)
        • ai.pipestream.data.v1.PipeDoc.Builder (implements ai.pipestream.data.v1.PipeDocOrBuilder)
        • ai.pipestream.data.v1.PipeStream.Builder (implements ai.pipestream.data.v1.PipeStreamOrBuilder)
        • ai.pipestream.data.module.v1.ProcessConfiguration.Builder (implements ai.pipestream.data.module.v1.ProcessConfigurationOrBuilder)
        • ai.pipestream.data.module.v1.ProcessDataRequest.Builder (implements ai.pipestream.data.module.v1.ProcessDataRequestOrBuilder)
        • ai.pipestream.data.module.v1.ProcessDataResponse.Builder (implements ai.pipestream.data.module.v1.ProcessDataResponseOrBuilder)
        • ai.pipestream.data.v1.ProcessingMapping.Builder (implements ai.pipestream.data.v1.ProcessingMappingOrBuilder)
        • ai.pipestream.platform.registration.v1.RegisterRequest.Builder (implements ai.pipestream.platform.registration.v1.RegisterRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.RegisterResponse.Builder (implements ai.pipestream.platform.registration.v1.RegisterResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.RegistrationEvent.Builder (implements ai.pipestream.platform.registration.v1.RegistrationEventOrBuilder)
        • ai.pipestream.platform.registration.v1.ResolveServiceRequest.Builder (implements ai.pipestream.platform.registration.v1.ResolveServiceRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.ResolveServiceResponse.Builder (implements ai.pipestream.platform.registration.v1.ResolveServiceResponseOrBuilder)
        • ai.pipestream.data.v1.SearchMetadata.Builder (implements ai.pipestream.data.v1.SearchMetadataOrBuilder)
        • ai.pipestream.data.v1.Section.Builder (implements ai.pipestream.data.v1.SectionOrBuilder)
        • ai.pipestream.data.v1.SemanticChunk.Builder (implements ai.pipestream.data.v1.SemanticChunkOrBuilder)
        • ai.pipestream.data.v1.SemanticProcessingResult.Builder (implements ai.pipestream.data.v1.SemanticProcessingResultOrBuilder)
        • ai.pipestream.data.module.v1.ServiceMetadata.Builder (implements ai.pipestream.data.module.v1.ServiceMetadataOrBuilder)
        • ai.pipestream.platform.registration.v1.ServiceRegistered.Builder (implements ai.pipestream.platform.registration.v1.ServiceRegisteredOrBuilder)
        • ai.pipestream.platform.registration.v1.ServiceUnregistered.Builder (implements ai.pipestream.platform.registration.v1.ServiceUnregisteredOrBuilder)
        • ai.pipestream.data.v1.SplitConfig.Builder (implements ai.pipestream.data.v1.SplitConfigOrBuilder)
        • ai.pipestream.data.v1.StepExecutionRecord.Builder (implements ai.pipestream.data.v1.StepExecutionRecordOrBuilder)
        • ai.pipestream.data.v1.StreamMetadata.Builder (implements ai.pipestream.data.v1.StreamMetadataOrBuilder)
        • ai.pipestream.data.v1.Tags.Builder (implements ai.pipestream.data.v1.TagsOrBuilder)
        • ai.pipestream.data.v1.TransformConfig.Builder (implements ai.pipestream.data.v1.TransformConfigOrBuilder)
        • ai.pipestream.platform.registration.v1.UnregisterRequest.Builder (implements ai.pipestream.platform.registration.v1.UnregisterRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.UnregisterResponse.Builder (implements ai.pipestream.platform.registration.v1.UnregisterResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchModulesRequest.Builder (implements ai.pipestream.platform.registration.v1.WatchModulesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchModulesResponse.Builder (implements ai.pipestream.platform.registration.v1.WatchModulesResponseOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchServicesRequest.Builder (implements ai.pipestream.platform.registration.v1.WatchServicesRequestOrBuilder)
        • ai.pipestream.platform.registration.v1.WatchServicesResponse.Builder (implements ai.pipestream.platform.registration.v1.WatchServicesResponseOrBuilder)
  • io.grpc.stub.AbstractStub<S>
    • io.grpc.stub.AbstractAsyncStub<S>
      • ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc.PipeStepProcessorServiceStub
      • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceStub
    • io.grpc.stub.AbstractBlockingStub<S>
      • ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc.PipeStepProcessorServiceBlockingStub
      • ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc.PipeStepProcessorServiceBlockingV2Stub
      • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub
      • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingV2Stub
    • io.grpc.stub.AbstractFutureStub<S>
      • ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc.PipeStepProcessorServiceFutureStub
      • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceFutureStub
    • ai.pipestream.data.module.v1.MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub (implements io.quarkus.grpc.MutinyStub)
    • ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub (implements io.quarkus.grpc.MutinyStub)
  • ai.pipestream.registration.repository.ApicurioRegistryClient
  • ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse
  • ai.pipestream.registration.consul.ConsulClientProducer
  • ai.pipestream.registration.consul.ConsulHealthChecker
  • ai.pipestream.registration.consul.ConsulRegistrar
  • ai.pipestream.registration.health.DependentServicesHealthCheck (implements org.eclipse.microprofile.health.HealthCheck)
  • com.google.protobuf.GeneratedFile
    • ai.pipestream.data.v1.PipelineCoreTypesV1Proto
    • ai.pipestream.data.module.v1.PipeStepProcessorServiceProto
    • ai.pipestream.platform.registration.v1.PlatformRegistrationProto
  • ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer (implements io.quarkus.grpc.api.ServerBuilderCustomizer<T>)
  • ai.pipestream.dynamic.grpc.util.HostnameResolver
  • ai.pipestream.registration.handlers.ModuleRegistrationHandler
  • ai.pipestream.registration.repository.ModuleRepository
  • ai.pipestream.data.module.v1.MutinyPipeStepProcessorServiceGrpc (implements io.quarkus.grpc.MutinyGrpc)
  • ai.pipestream.data.module.v1.MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase (implements io.grpc.BindableService)
    • ai.pipestream.data.module.v1.PipeStepProcessorServiceBean (implements io.grpc.BindableService, io.quarkus.grpc.MutinyBean)
  • ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc (implements io.quarkus.grpc.MutinyGrpc)
  • ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase (implements io.grpc.BindableService)
    • ai.pipestream.registration.grpc.PlatformRegistrationService
    • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceBean (implements io.grpc.BindableService, io.quarkus.grpc.MutinyBean)
  • ai.pipestream.registration.events.OpenSearchEventsProducer
  • io.quarkus.hibernate.reactive.panache.PanacheEntityBase
    • ai.pipestream.registration.entity.ConfigSchema
    • ai.pipestream.registration.entity.ServiceModule
  • ai.pipestream.data.module.v1.PipeStepProcessorServiceClient (implements io.quarkus.grpc.MutinyClient<T>, ai.pipestream.data.module.v1.PipeStepProcessorService)
  • ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc
  • ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase (implements io.grpc.BindableService, ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc.AsyncService)
  • ai.pipestream.registration.events.PlatformEventsKeyExtractors
  • ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleRegisteredExtractor (implements ai.pipestream.apicurio.registry.protobuf.UuidKeyExtractor<T>)
  • ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleUnregisteredExtractor (implements ai.pipestream.apicurio.registry.protobuf.UuidKeyExtractor<T>)
  • ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceRegisteredExtractor (implements ai.pipestream.apicurio.registry.protobuf.UuidKeyExtractor<T>)
  • ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceUnregisteredExtractor (implements ai.pipestream.apicurio.registry.protobuf.UuidKeyExtractor<T>)
  • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceClient (implements io.quarkus.grpc.MutinyClient<T>, ai.pipestream.platform.registration.v1.PlatformRegistrationService)
  • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc
  • ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceImplBase (implements io.grpc.BindableService, ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.AsyncService)
  • ai.pipestream.platform.registration.client.RegistrationGrpcClients
  • ai.pipestream.registration.handlers.SchemaRetrievalHandler
  • ai.pipestream.registration.startup.SelfRegistrationService
  • ai.pipestream.registration.handlers.ServiceDiscoveryHandler
  • ai.pipestream.registration.handlers.ServiceRegistrationHandler
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • ai.pipestream.registration.repository.ApicurioRegistryException

Interface Hierarchy

• com.google.protobuf.MessageLiteOrBuilder
  • com.google.protobuf.MessageOrBuilder
    • ai.pipestream.data.v1.AggregateConfigOrBuilder
    • ai.pipestream.data.v1.BlobBagOrBuilder
    • ai.pipestream.data.v1.BlobOrBuilder
    • ai.pipestream.data.v1.BlobsOrBuilder
    • ai.pipestream.data.module.v1.CapabilitiesOrBuilder
    • ai.pipestream.data.v1.ChunkEmbeddingOrBuilder
    • ai.pipestream.platform.registration.v1.ConnectivityOrBuilder
    • ai.pipestream.data.v1.DocOutlineOrBuilder
    • ai.pipestream.data.v1.EmbeddingOrBuilder
    • ai.pipestream.data.v1.ErrorDataOrBuilder
    • ai.pipestream.platform.registration.v1.EventMetadataOrBuilder
    • ai.pipestream.data.v1.FailedStepInputStateOrBuilder
    • ai.pipestream.data.v1.FileStorageReferenceOrBuilder
    • ai.pipestream.platform.registration.v1.GetModuleRequestOrBuilder
    • ai.pipestream.platform.registration.v1.GetModuleResponseOrBuilder
    • ai.pipestream.platform.registration.v1.GetModuleSchemaRequestOrBuilder
    • ai.pipestream.platform.registration.v1.GetModuleSchemaResponseOrBuilder
    • ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequestOrBuilder
    • ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponseOrBuilder
    • ai.pipestream.data.module.v1.GetServiceRegistrationRequestOrBuilder
    • ai.pipestream.data.module.v1.GetServiceRegistrationResponseOrBuilder
    • ai.pipestream.platform.registration.v1.GetServiceRequestOrBuilder
    • ai.pipestream.platform.registration.v1.GetServiceResponseOrBuilder
    • ai.pipestream.data.v1.KeywordsOrBuilder
    • ai.pipestream.data.v1.LinkReferenceOrBuilder
    • ai.pipestream.platform.registration.v1.ListModulesRequestOrBuilder
    • ai.pipestream.platform.registration.v1.ListModulesResponseOrBuilder
    • ai.pipestream.platform.registration.v1.ListServicesRequestOrBuilder
    • ai.pipestream.platform.registration.v1.ListServicesResponseOrBuilder
    • ai.pipestream.platform.registration.v1.ModuleRegisteredOrBuilder
    • ai.pipestream.platform.registration.v1.ModuleSchemaVersionOrBuilder
    • ai.pipestream.platform.registration.v1.ModuleUnregisteredOrBuilder
    • ai.pipestream.data.v1.NodeProcessingConfigOrBuilder
    • ai.pipestream.data.v1.ParsedMetadataOrBuilder
    • ai.pipestream.data.v1.PipeDocOrBuilder
    • ai.pipestream.data.v1.PipeStreamOrBuilder
    • ai.pipestream.data.module.v1.ProcessConfigurationOrBuilder
    • ai.pipestream.data.module.v1.ProcessDataRequestOrBuilder
    • ai.pipestream.data.module.v1.ProcessDataResponseOrBuilder
    • ai.pipestream.data.v1.ProcessingMappingOrBuilder
    • ai.pipestream.platform.registration.v1.RegisterRequestOrBuilder
    • ai.pipestream.platform.registration.v1.RegisterResponseOrBuilder
    • ai.pipestream.platform.registration.v1.RegistrationEventOrBuilder
    • ai.pipestream.platform.registration.v1.ResolveServiceRequestOrBuilder
    • ai.pipestream.platform.registration.v1.ResolveServiceResponseOrBuilder
    • ai.pipestream.data.v1.SearchMetadataOrBuilder
    • ai.pipestream.data.v1.SectionOrBuilder
    • ai.pipestream.data.v1.SemanticChunkOrBuilder
    • ai.pipestream.data.v1.SemanticProcessingResultOrBuilder
    • ai.pipestream.data.module.v1.ServiceMetadataOrBuilder
    • ai.pipestream.platform.registration.v1.ServiceRegisteredOrBuilder
    • ai.pipestream.platform.registration.v1.ServiceUnregisteredOrBuilder
    • ai.pipestream.data.v1.SplitConfigOrBuilder
    • ai.pipestream.data.v1.StepExecutionRecordOrBuilder
    • ai.pipestream.data.v1.StreamMetadataOrBuilder
    • ai.pipestream.data.v1.TagsOrBuilder
    • ai.pipestream.data.v1.TransformConfigOrBuilder
    • ai.pipestream.platform.registration.v1.UnregisterRequestOrBuilder
    • ai.pipestream.platform.registration.v1.UnregisterResponseOrBuilder
    • ai.pipestream.platform.registration.v1.WatchModulesRequestOrBuilder
    • ai.pipestream.platform.registration.v1.WatchModulesResponseOrBuilder
    • ai.pipestream.platform.registration.v1.WatchServicesRequestOrBuilder
    • ai.pipestream.platform.registration.v1.WatchServicesResponseOrBuilder
• io.quarkus.grpc.MutinyService
  • ai.pipestream.data.module.v1.PipeStepProcessorService
  • ai.pipestream.platform.registration.v1.PlatformRegistrationService
• ai.pipestream.data.module.v1.PipeStepProcessorServiceGrpc.AsyncService
• ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.AsyncService

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • ai.pipestream.data.v1.AggregateConfig.AggregationType (implements com.google.protobuf.ProtocolMessageEnum)
    • ai.pipestream.data.v1.Blob.ContentCase (implements com.google.protobuf.Internal.EnumLite)
    • ai.pipestream.data.v1.BlobBag.BlobDataCase (implements com.google.protobuf.Internal.EnumLite)
    • ai.pipestream.data.module.v1.CapabilityType (implements com.google.protobuf.ProtocolMessageEnum)
    • ai.pipestream.data.v1.ChecksumType (implements com.google.protobuf.ProtocolMessageEnum)
    • ai.pipestream.registration.entity.ConfigSchema.SyncStatus
    • ai.pipestream.platform.registration.v1.EventType (implements com.google.protobuf.ProtocolMessageEnum)
    • ai.pipestream.platform.registration.v1.GetModuleRequest.LookupKeyCase (implements com.google.protobuf.Internal.EnumLite)
    • ai.pipestream.platform.registration.v1.GetServiceRequest.LookupKeyCase (implements com.google.protobuf.Internal.EnumLite)
    • ai.pipestream.data.v1.Intent (implements com.google.protobuf.ProtocolMessageEnum)
    • ai.pipestream.data.v1.MappingType (implements com.google.protobuf.ProtocolMessageEnum)
    • ai.pipestream.data.v1.ProcessingMapping.MappingConfigCase (implements com.google.protobuf.Internal.EnumLite)
    • ai.pipestream.platform.registration.v1.RegistrationEvent.EventDataCase (implements com.google.protobuf.Internal.EnumLite)
    • ai.pipestream.registration.entity.ServiceStatus
    • ai.pipestream.platform.registration.v1.ServiceType (implements com.google.protobuf.ProtocolMessageEnum)