Class SchemaRetrievalHandler

java.lang.Object
ai.pipestream.registration.handlers.SchemaRetrievalHandler
@ApplicationScoped public class SchemaRetrievalHandler extends Object
Retrieves module configuration schemas from the platform registry (DB, then Apicurio).

Blocking — invoked from virtual threads by the gRPC/REST layers.

  • Constructor Summary

    Constructors
    Constructor
    Description
    SchemaRetrievalHandler()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    ai.pipestream.platform.registration.v1.GetModuleSchemaResponse
    getModuleSchema(ai.pipestream.platform.registration.v1.GetModuleSchemaRequest request)
     
    ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse
    getModuleSchemaVersions(ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest request)
     
    ai.pipestream.platform.registration.v1.GetSchemaArtifactResponse
    getSchemaArtifact(ai.pipestream.platform.registration.v1.GetSchemaArtifactRequest request)
    One door for every named schema artifact.

    Methods inherited from class Object

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

  • Constructor Details

    • SchemaRetrievalHandler

      public SchemaRetrievalHandler()

  • Method Details

    • getModuleSchema

      public ai.pipestream.platform.registration.v1.GetModuleSchemaResponse getModuleSchema(ai.pipestream.platform.registration.v1.GetModuleSchemaRequest request)

    • getSchemaArtifact

      public ai.pipestream.platform.registration.v1.GetSchemaArtifactResponse getSchemaArtifact(ai.pipestream.platform.registration.v1.GetSchemaArtifactRequest request)
      One door for every named schema artifact. Lookup order:
      1. DB ConfigSchema rows keyed by the artifact name (module config schemas AND extra artifacts like chunker-recipe land here at registration);
      2. Apicurio platform schema group (artifacts synced from here, or published by other services under the exact name);
      3. Apicurio descriptor group ("default") — protobuf DESCRIPTOR artifacts the proto pipeline publishes (e.g. "account-events"), served as application/x-protobuf.

    • getModuleSchemaVersions

      public ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsResponse getModuleSchemaVersions(ai.pipestream.platform.registration.v1.GetModuleSchemaVersionsRequest request)