Package ai.pipestream.common.util.descriptor

Class ApicurioDescriptorLoader

java.lang.Object

ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader

All Implemented Interfaces:

DescriptorLoader

public class ApicurioDescriptorLoader
extends Object
implements DescriptorLoader

Loads Protocol Buffer descriptors from Apicurio Schema Registry. This is a placeholder implementation for future integration with Apicurio.

When implemented, this will:

• Connect to Apicurio Registry REST API
• Download proto schemas by artifact ID or group
• Cache descriptors locally
• Support schema versioning
• Handle schema evolution

Example future usage:

 ApicurioDescriptorLoader loader = ApicurioDescriptorLoader.builder()
     .registryUrl("http://apicurio-registry:8080/apis/registry/v2")
     .groupId("ai.pipestream.protos")
     .authentication(apiKey)
     .build();
 List<FileDescriptor> descriptors = loader.loadDescriptors();
 

See Also:

• Apicurio Registry

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ApicurioDescriptorLoader.Builder	Builder for ApicurioDescriptorLoader.

Nested classes/interfaces inherited from interface ai.pipestream.common.util.descriptor.DescriptorLoader

DescriptorLoader.DescriptorLoadException

Constructor Summary

Constructors

Constructor	Description
ApicurioDescriptorLoader(String registryUrl, String groupId, String artifactId)	Creates an ApicurioDescriptorLoader (placeholder).

Method Summary

Modifier and Type	Method	Description
static ApicurioDescriptorLoader.Builder	builder()	Creates a new builder.
String	getArtifactId()	Gets the artifact ID.
String	getGroupId()	Gets the group ID.
String	getLoaderType()	Gets a human-readable name for this loader type.
String	getRegistryUrl()	Gets the registry URL.
boolean	isAvailable()	Checks if this loader is available and can load descriptors.
com.google.protobuf.Descriptors.FileDescriptor	loadDescriptor(String fileName)	Loads a specific file descriptor by name.
List<com.google.protobuf.Descriptors.FileDescriptor>	loadDescriptors()	Loads all available file descriptors from this loader's source.

Methods inherited from class java.lang.Object

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

Constructor Details

ApicurioDescriptorLoader

public ApicurioDescriptorLoader(String registryUrl,
 String groupId,
 String artifactId)

Creates an ApicurioDescriptorLoader (placeholder).

Parameters:

registryUrl - The Apicurio registry URL

groupId - The schema group ID

artifactId - Optional specific artifact ID

Method Details

loadDescriptors

public List<com.google.protobuf.Descriptors.FileDescriptor> loadDescriptors()
                                                                     throws DescriptorLoader.DescriptorLoadException

Description copied from interface: DescriptorLoader

Loads all available file descriptors from this loader's source.

Specified by:

loadDescriptors in interface DescriptorLoader

Returns:

A list of FileDescriptors

Throws:

DescriptorLoader.DescriptorLoadException - if loading fails

loadDescriptor

public com.google.protobuf.Descriptors.FileDescriptor loadDescriptor(String fileName)
                                                              throws DescriptorLoader.DescriptorLoadException

Description copied from interface: DescriptorLoader

Loads a specific file descriptor by name.

Specified by:

loadDescriptor in interface DescriptorLoader

Parameters:

fileName - The proto file name (e.g., "my_types.proto")

Returns:

The FileDescriptor, or null if not found

Throws:

DescriptorLoader.DescriptorLoadException - if loading fails

isAvailable

public boolean isAvailable()

Description copied from interface: DescriptorLoader

Checks if this loader is available and can load descriptors. For example, a GoogleDescriptorLoader would return false if the .dsc file is not on classpath.

Specified by:

isAvailable in interface DescriptorLoader

Returns:

true if the loader can load descriptors

getLoaderType

public String getLoaderType()

Description copied from interface: DescriptorLoader

Gets a human-readable name for this loader type.

Specified by:

getLoaderType in interface DescriptorLoader

Returns:

The loader type name

getRegistryUrl

public String getRegistryUrl()

Gets the registry URL.

Returns:

The registry URL

getGroupId

public String getGroupId()

Gets the group ID.

Returns:

The group ID

getArtifactId

public String getArtifactId()

Gets the artifact ID.

Returns:

The artifact ID, or null if loading all artifacts in group

builder

public static ApicurioDescriptorLoader.Builder builder()

Creates a new builder.

Returns:

A new builder instance