Index (pipeline-commons 0.2.8 API)

A B C D E F G H I L M N P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

add(T) - Method in class ai.pipestream.common.util.NoOpProcessingBuffer: Does nothing.
add(T) - Method in interface ai.pipestream.common.util.ProcessingBuffer: Adds a message to the buffer.
add(T) - Method in class ai.pipestream.common.util.ProcessingBufferImpl
addLoader(DescriptorLoader) - Method in class ai.pipestream.common.util.DescriptorRegistry: Adds a descriptor loader to this registry.
addLoader(DescriptorLoader) - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Adds a descriptor loader.
ai.pipestream.common.config - package ai.pipestream.common.config
ai.pipestream.common.interceptor - package ai.pipestream.common.interceptor
ai.pipestream.common.service - package ai.pipestream.common.service
ai.pipestream.common.util - package ai.pipestream.common.util
ai.pipestream.common.util.descriptor - package ai.pipestream.common.util.descriptor
ai.pipestream.common.validation - package ai.pipestream.common.validation
AnyHandler - Class in ai.pipestream.common.util: Utility class for handling google.protobuf.Any messages.
AnyHandler() - Constructor for class ai.pipestream.common.util.AnyHandler: Creates a new AnyHandler with an empty descriptor registry.
AnyHandler(DescriptorRegistry) - Constructor for class ai.pipestream.common.util.AnyHandler: Creates a new AnyHandler with the specified descriptor registry.
ApicurioDescriptorLoader - Class in ai.pipestream.common.util.descriptor: Loads Protocol Buffer descriptors from Apicurio Schema Registry.
ApicurioDescriptorLoader(String, String, String) - Constructor for class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader: Creates an ApicurioDescriptorLoader (placeholder).
ApicurioDescriptorLoader.Builder - Class in ai.pipestream.common.util.descriptor: Builder for ApicurioDescriptorLoader.
artifactId(String) - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder: Sets a specific artifact ID to load.
authentication(String) - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder: Sets the API key for authentication.
autoLoadDescriptors() - Method in class ai.pipestream.common.util.DescriptorRegistry: Attempts to automatically load descriptors from available loaders.

B

build() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder: Builds the ApicurioDescriptorLoader.
build() - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Builds the DescriptorRegistry.
builder() - Static method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader: Creates a new builder.
builder() - Static method in class ai.pipestream.common.util.DescriptorRegistry: Creates a builder for fluently registering multiple descriptors.
Builder() - Constructor for class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder

C

captureProcessingOutput(InvocationContext) - Method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Intercepts method calls annotated with @ProcessingBuffered.
children - Variable in class ai.pipestream.common.util.MappingHelper.SchemaNode
clear() - Method in class ai.pipestream.common.util.DescriptorRegistry: Clears all registered descriptors except well-known types.
clear() - Method in class ai.pipestream.common.util.NoOpProcessingBuffer: Does nothing.
clear() - Method in interface ai.pipestream.common.util.ProcessingBuffer: Clears all messages from the buffer.
clear() - Method in class ai.pipestream.common.util.ProcessingBufferImpl
clearAllBuffers() - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Clears all buffers.
clearAllBuffers() - Method in class ai.pipestream.common.service.ProcessingBufferManager: Clears all buffers.
combine(ValidationResult) - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Combines this result with another, taking the most restrictive validity.
combine(ValidationResult) - Method in class ai.pipestream.common.validation.EmptyValidationResult
convertToFieldType(Object, Descriptors.FieldDescriptor) - Method in class ai.pipestream.common.util.TypeConverter: Attempts to convert a value to match the expected type of a field.
createBuffer(boolean, int, Class<T>) - Static method in class ai.pipestream.common.util.ProcessingBufferFactory: Creates a ProcessingBuffer instance with the default file system.
createBuffer(boolean, int, Class<T>, FileSystem) - Static method in class ai.pipestream.common.util.ProcessingBufferFactory: Creates a ProcessingBuffer instance with a specific file system.
createBuffer(boolean, int, Class<T>, FileSystem, Path, String, int) - Static method in class ai.pipestream.common.util.ProcessingBufferFactory: Creates a ProcessingBuffer instance with a specific file system and save parameters.
createBuffer(boolean, int, Class<T>, Path, String, int) - Static method in class ai.pipestream.common.util.ProcessingBufferFactory: Creates a ProcessingBuffer instance with the default file system and save parameters.
createBuffer(boolean, Class<T>) - Static method in class ai.pipestream.common.util.ProcessingBufferFactory: Creates a ProcessingBuffer instance with default capacity (100) and the default file system.
createBuffer(boolean, Class<T>, FileSystem) - Static method in class ai.pipestream.common.util.ProcessingBufferFactory: Creates a ProcessingBuffer instance with default capacity (100) and a specific file system.
createTypeUrl(String) - Method in class ai.pipestream.common.util.AnyHandler: Creates a type URL from a type name.

D

DEFAULT_DESCRIPTOR_PATH - Static variable in class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader: Default descriptor path used by grpc-google-descriptor module.
DefaultValidationResult - Record Class in ai.pipestream.common.validation: Result of pipeline configuration validation.
DefaultValidationResult(boolean, List<String>, List<String>) - Constructor for record class ai.pipestream.common.validation.DefaultValidationResult: Ensures immutability of lists
depth - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo
DescriptorLoader - Interface in ai.pipestream.common.util.descriptor: Generic interface for loading Protocol Buffer descriptors from various sources.
DescriptorLoader.DescriptorLoadException - Exception Class in ai.pipestream.common.util.descriptor: Exception thrown when descriptor loading fails.
DescriptorLoadException(String) - Constructor for exception class ai.pipestream.common.util.descriptor.DescriptorLoader.DescriptorLoadException
DescriptorLoadException(String, Throwable) - Constructor for exception class ai.pipestream.common.util.descriptor.DescriptorLoader.DescriptorLoadException
DescriptorRegistry - Class in ai.pipestream.common.util: Registry for managing Protocol Buffer descriptors.
DescriptorRegistry() - Constructor for class ai.pipestream.common.util.DescriptorRegistry: Creates a new empty DescriptorRegistry.
DescriptorRegistry(boolean) - Constructor for class ai.pipestream.common.util.DescriptorRegistry: Creates a DescriptorRegistry with automatic loading enabled.
DescriptorRegistry.RegistryBuilder - Class in ai.pipestream.common.util: Builder for fluently constructing a DescriptorRegistry.

E

EmptyValidationResult - Class in ai.pipestream.common.validation: An empty/no-op implementation of ValidationResult for testing and mocking purposes.
enableCaching(boolean) - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder: Enables or disables local caching of schemas.
equals(Object) - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Indicates whether some other object is "equal to" this one.
error(String) - Static method in class ai.pipestream.common.util.MappingHelper.ValidationResult
ERROR - Enum constant in enum class ai.pipestream.common.util.MappingHelper.ValidationResult.ValidationLevel
errors() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns the value of the errors record component.
errors() - Method in class ai.pipestream.common.validation.EmptyValidationResult
exportSchema(Descriptors.Descriptor, int) - Method in class ai.pipestream.common.util.MappingHelper: Exports a message schema as a tree structure for UI consumption.
extractChunkerConfigSchema() - Method in class ai.pipestream.common.service.SchemaExtractorService: Convenience method to extract the ChunkerConfig schema specifically.
extractChunkerConfigSchemaForValidation() - Method in class ai.pipestream.common.service.SchemaExtractorService: Extracts ChunkerConfig schema and cleans it for JSON Schema v7 validation.
extractParserConfigSchema() - Method in class ai.pipestream.common.service.SchemaExtractorService: Convenience method to extract the ParserConfig schema specifically.
extractParserConfigSchemaForValidation() - Method in class ai.pipestream.common.service.SchemaExtractorService: Extracts ParserConfig schema and cleans it for JSON Schema v7 validation.
extractParserConfigSchemaResolvedForJsonForms() - Method in class ai.pipestream.common.service.SchemaExtractorService: Convenience method for ParserConfig specifically.
extractSchemaByName(String) - Method in class ai.pipestream.common.service.SchemaExtractorService: Extracts a specific schema component from the OpenAPI document by name.
extractSchemaForClass(Class<?>) - Method in class ai.pipestream.common.service.SchemaExtractorService: Convenience method to extract any config schema by inferring the name from a class.
extractSchemaResolvedForJsonForms(String) - Method in class ai.pipestream.common.service.SchemaExtractorService: Extracts a schema and resolves OpenAPI $ref references against components.schemas, returning a JSON Schema object suitable for JSONForms rendering (no x-* extensions, inline referenced schemas).

F

failure(String) - Static method in record class ai.pipestream.common.validation.DefaultValidationResult: Creates an invalid result with a single error.
failure(String) - Static method in class ai.pipestream.common.validation.ValidationResultFactory: Creates an invalid result with a single error.
failure(List<String>) - Static method in record class ai.pipestream.common.validation.DefaultValidationResult: Creates an invalid result with the given errors.
failure(List<String>) - Static method in class ai.pipestream.common.validation.ValidationResultFactory: Creates an invalid result with the given errors.
failure(List<String>, List<String>) - Static method in record class ai.pipestream.common.validation.DefaultValidationResult: Creates an invalid result with errors and warnings.
failure(List<String>, List<String>) - Static method in class ai.pipestream.common.validation.ValidationResultFactory: Creates an invalid result with errors and warnings.
FieldInfo(String, String, String, boolean, boolean, boolean, int) - Constructor for class ai.pipestream.common.util.MappingHelper.FieldInfo
fieldPath - Variable in class ai.pipestream.common.util.MappingHelper.FieldSuggestion
fieldsToJson(List<MappingHelper.FieldInfo>) - Method in class ai.pipestream.common.util.MappingHelperJsonSupport: Exports field information as JSON.
FieldSuggestion(String, int) - Constructor for class ai.pipestream.common.util.MappingHelper.FieldSuggestion
findDescriptor(String) - Method in class ai.pipestream.common.util.DescriptorRegistry: Finds a descriptor by either full or simple name.
findDescriptorByFullName(String) - Method in class ai.pipestream.common.util.DescriptorRegistry: Finds a descriptor by its full name.
findDescriptorBySimpleName(String) - Method in class ai.pipestream.common.util.DescriptorRegistry: Finds a descriptor by its simple name.
fromValue(Value) - Method in class ai.pipestream.common.util.TypeConverter: Converts a protobuf Value to a Java object.

G

getActiveBufferKeys() - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Gets all active buffer keys (method identifiers).
getActiveBufferKeys() - Method in class ai.pipestream.common.service.ProcessingBufferManager: Gets all active buffer keys.
getAllFieldPaths(Descriptors.Descriptor, int) - Method in class ai.pipestream.common.util.MappingHelper: Gets all available field paths for a message type.
getAnyHandler() - Method in interface ai.pipestream.common.util.ProtoFieldMapper
getAnyHandler() - Method in class ai.pipestream.common.util.ProtoFieldMapperImpl: Gets the AnyHandler for this mapper.
getArtifactId() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader: Gets the artifact ID.
getBuffer(String) - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Gets the buffer for a specific method, if it exists.
getBuffer(String) - Method in class ai.pipestream.common.service.ProcessingBufferManager: Gets the buffer for a specific method key.
getBuffer(String, String) - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Gets the buffer for a specific class and method name.
getBuffer(String, String) - Method in class ai.pipestream.common.service.ProcessingBufferManager: Gets the buffer for a specific method.
getBufferStatistics() - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Gets buffer statistics for monitoring.
getBufferStatistics() - Method in class ai.pipestream.common.service.ProcessingBufferManager: Gets buffer statistics for monitoring.
getDescriptorPath() - Method in class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader: Gets the descriptor path being used.
getDescriptorRegistry() - Method in class ai.pipestream.common.util.AnyHandler: Gets the descriptor registry used by this handler.
getDescriptorRegistry() - Method in interface ai.pipestream.common.util.ProtoFieldMapper
getDescriptorRegistry() - Method in class ai.pipestream.common.util.ProtoFieldMapperImpl: Gets the descriptor registry for this mapper.
getFieldInfos(Descriptors.Descriptor, int) - Method in class ai.pipestream.common.util.MappingHelper: Gets detailed information about all fields in a message.
getFullOpenApiDocument() - Method in class ai.pipestream.common.service.SchemaExtractorService: Gets the full OpenAPI document as a JSON string.
getGroupId() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader: Gets the group ID.
getLoaderType() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader
getLoaderType() - Method in interface ai.pipestream.common.util.descriptor.DescriptorLoader: Gets a human-readable name for this loader type.
getLoaderType() - Method in class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader
getName() - Method in class ai.pipestream.common.config.PipelineKafkaConfigSource
getOrdinal() - Method in class ai.pipestream.common.config.PipelineKafkaConfigSource
getProperties() - Method in class ai.pipestream.common.config.PipelineKafkaConfigSource
getPropertyNames() - Method in class ai.pipestream.common.config.PipelineKafkaConfigSource
getRegistryUrl() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader: Gets the registry URL.
getTotalCapturedDocuments() - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Gets the total number of documents across all buffers.
getTotalCapturedDocuments() - Method in class ai.pipestream.common.service.ProcessingBufferManager: Gets the total number of captured documents across all buffers.
getTypeName(Any) - Method in class ai.pipestream.common.util.AnyHandler: Gets the type name from an Any message.
getValue(String) - Method in class ai.pipestream.common.config.PipelineKafkaConfigSource
GoogleDescriptorLoader - Class in ai.pipestream.common.util.descriptor: Loads Protocol Buffer descriptors from Google descriptor set files (.dsc).
GoogleDescriptorLoader() - Constructor for class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader: Creates a loader with the default descriptor path.
GoogleDescriptorLoader(String) - Constructor for class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader: Creates a loader with a custom descriptor path.
GoogleDescriptorLoader(String, ClassLoader) - Constructor for class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader: Creates a loader with a custom descriptor path and class loader.
groupId(String) - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder: Sets the schema group ID.

H

hasDefault - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo
hasErrors() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns true if there are any errors.
hasErrors() - Method in class ai.pipestream.common.validation.EmptyValidationResult
hashCode() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns a hash code value for this object.
hasIssues() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns true if there are any issues (errors or warnings).
hasIssues() - Method in class ai.pipestream.common.validation.EmptyValidationResult
hasWarnings() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns true if there are any warnings.
hasWarnings() - Method in class ai.pipestream.common.validation.EmptyValidationResult

I

instance() - Static method in class ai.pipestream.common.validation.EmptyValidationResult: Get the singleton instance of EmptyValidationResult.
is(Any, Descriptors.Descriptor) - Method in class ai.pipestream.common.util.AnyHandler: Checks if an Any message contains a specific type.
is(Any, String) - Method in class ai.pipestream.common.util.AnyHandler: Checks if an Any message contains a specific type by full name.
isAvailable() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader
isAvailable() - Method in interface ai.pipestream.common.util.descriptor.DescriptorLoader: Checks if this loader is available and can load descriptors.
isAvailable() - Method in class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader
isOpenApiDocumentAvailable() - Method in class ai.pipestream.common.service.SchemaExtractorService: Validates that the OpenAPI document service is available and functional.
isRegistered(String) - Method in class ai.pipestream.common.util.DescriptorRegistry: Checks if a descriptor is registered.
isValid - Variable in class ai.pipestream.common.util.MappingHelper.ValidationResult

L

level - Variable in class ai.pipestream.common.util.MappingHelper.ValidationResult
loadDescriptor(String) - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader
loadDescriptor(String) - Method in interface ai.pipestream.common.util.descriptor.DescriptorLoader: Loads a specific file descriptor by name.
loadDescriptor(String) - Method in class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader
loadDescriptors() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader
loadDescriptors() - Method in interface ai.pipestream.common.util.descriptor.DescriptorLoader: Loads all available file descriptors from this loader's source.
loadDescriptors() - Method in class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader
loadFrom(DescriptorLoader) - Method in class ai.pipestream.common.util.DescriptorRegistry: Loads descriptors from a specific loader and registers them.

M

map(Message, Message.Builder, List<String>) - Method in interface ai.pipestream.common.util.ProtoFieldMapper
map(Message, Message.Builder, List<String>) - Method in class ai.pipestream.common.util.ProtoFieldMapperImpl: Maps fields from a source message to a target message builder based on a list of rules.
MappingException(String, String) - Constructor for exception class ai.pipestream.common.util.ProtoFieldMapperImpl.MappingException: Creates a new MappingException with a message and the rule that caused it.
MappingException(String, Throwable, String) - Constructor for exception class ai.pipestream.common.util.ProtoFieldMapperImpl.MappingException: Creates a new MappingException with a message, cause, and the rule that caused it.
MappingHelper - Class in ai.pipestream.common.util: Helper class for building mapping UIs and providing field discovery.
MappingHelper() - Constructor for class ai.pipestream.common.util.MappingHelper
MappingHelper.FieldInfo - Class in ai.pipestream.common.util
MappingHelper.FieldSuggestion - Class in ai.pipestream.common.util
MappingHelper.SchemaNode - Class in ai.pipestream.common.util
MappingHelper.ValidationResult - Class in ai.pipestream.common.util
MappingHelper.ValidationResult.ValidationLevel - Enum Class in ai.pipestream.common.util
MappingHelperJsonSupport - Class in ai.pipestream.common.util: JSON export support for MappingHelper.
MappingHelperJsonSupport() - Constructor for class ai.pipestream.common.util.MappingHelperJsonSupport
message - Variable in class ai.pipestream.common.util.MappingHelper.ValidationResult
messageToStruct(Message) - Method in class ai.pipestream.common.util.TypeConverter: Converts a protobuf Message to a Struct.

N

name - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo
name - Variable in class ai.pipestream.common.util.MappingHelper.SchemaNode
NoOpProcessingBuffer<T> - Class in ai.pipestream.common.util: A no-op implementation of the ProcessingBuffer interface.
NoOpProcessingBuffer() - Constructor for class ai.pipestream.common.util.NoOpProcessingBuffer: Default constructor for NoOpProcessingBuffer.

P

pack(Message) - Method in class ai.pipestream.common.util.AnyHandler: Packs a message into a google.protobuf.Any.
packStruct(Struct, String) - Method in class ai.pipestream.common.util.AnyHandler: Packs a Struct into an Any with a specified type name.
path - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo
path - Variable in class ai.pipestream.common.util.MappingHelper.SchemaNode
PipelineKafkaConfigSource - Class in ai.pipestream.common.config: Global Kafka Configuration Source.
PipelineKafkaConfigSource() - Constructor for class ai.pipestream.common.config.PipelineKafkaConfigSource
ProcessingBuffer<T> - Interface in ai.pipestream.common.util: Interface for a buffer that stores protobuf messages and can save them to disk.
ProcessingBufferFactory - Class in ai.pipestream.common.util: Factory for creating ProcessingBuffer instances.
ProcessingBufferFactory() - Constructor for class ai.pipestream.common.util.ProcessingBufferFactory: Default constructor for ProcessingBufferFactory.
ProcessingBufferImpl<T> - Class in ai.pipestream.common.util: Implementation of the ProcessingBuffer interface.
ProcessingBufferImpl(int, Class<T>) - Constructor for class ai.pipestream.common.util.ProcessingBufferImpl: Creates a new ProcessingBufferImpl with the specified capacity and message class.
ProcessingBufferImpl(int, Class<T>, FileSystem) - Constructor for class ai.pipestream.common.util.ProcessingBufferImpl: Creates a new ProcessingBufferImpl with the specified capacity, message class, and file system.
ProcessingBufferImpl(int, Class<T>, FileSystem, Path, String, int) - Constructor for class ai.pipestream.common.util.ProcessingBufferImpl: Creates a new ProcessingBufferImpl with the specified capacity, message class, file system, and save parameters.
ProcessingBufferImpl(int, Class<T>, Path, String, int) - Constructor for class ai.pipestream.common.util.ProcessingBufferImpl: Creates a new ProcessingBufferImpl with the specified capacity, message class, and save parameters.
ProcessingBufferInterceptor - Class in ai.pipestream.common.interceptor: Interceptor that automatically captures processing output to buffers based on @ProcessingBuffered annotation.
ProcessingBufferInterceptor() - Constructor for class ai.pipestream.common.interceptor.ProcessingBufferInterceptor
ProcessingBufferManager - Class in ai.pipestream.common.service: CDI bean that provides convenient access to processing buffers managed by the interceptor.
ProcessingBufferManager() - Constructor for class ai.pipestream.common.service.ProcessingBufferManager
ProtoFieldMapper - Interface in ai.pipestream.common.util: Interface for mapping fields between protobuf messages.
ProtoFieldMapperImpl - Class in ai.pipestream.common.util: A streamlined utility for dynamically mapping fields between Protocol Buffer messages.
ProtoFieldMapperImpl() - Constructor for class ai.pipestream.common.util.ProtoFieldMapperImpl: Default constructor for ProtoFieldMapper.
ProtoFieldMapperImpl(DescriptorRegistry) - Constructor for class ai.pipestream.common.util.ProtoFieldMapperImpl: Constructor with custom descriptor registry.
ProtoFieldMapperImpl.MappingException - Exception Class in ai.pipestream.common.util: Exception thrown when a mapping rule cannot be applied.

R

register(Descriptors.Descriptor) - Method in class ai.pipestream.common.util.DescriptorRegistry: Registers a descriptor in the registry.
register(Descriptors.Descriptor) - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Registers a descriptor.
registerFile(Descriptors.FileDescriptor) - Method in class ai.pipestream.common.util.DescriptorRegistry: Registers all message types from a file descriptor.
registerFile(Descriptors.FileDescriptor) - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Registers a file descriptor.
registerFromMessage(Message) - Method in class ai.pipestream.common.util.DescriptorRegistry: Registers a descriptor from a message instance.
registerFromMessage(Message) - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Registers a descriptor from a message instance.
RegistryBuilder() - Constructor for class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder
registryUrl(String) - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder: Sets the Apicurio registry URL.
repeated - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo
repeated - Variable in class ai.pipestream.common.util.MappingHelper.SchemaNode
required - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo

S

saveAllBuffers() - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Saves all buffers to disk using their configured directories and prefixes.
saveAllBuffers() - Method in class ai.pipestream.common.service.ProcessingBufferManager: Saves all buffers to disk.
saveBuffer(String) - Static method in class ai.pipestream.common.interceptor.ProcessingBufferInterceptor: Saves a specific buffer to disk.
saveBuffer(String) - Method in class ai.pipestream.common.service.ProcessingBufferManager: Saves a specific buffer to disk.
saveOnShutdown() - Method in class ai.pipestream.common.util.NoOpProcessingBuffer: Does nothing on shutdown.
saveOnShutdown() - Method in class ai.pipestream.common.util.ProcessingBufferImpl: Saves the buffer contents to disk when the bean is destroyed.
saveToDisk() - Method in class ai.pipestream.common.util.NoOpProcessingBuffer: Does nothing.
saveToDisk() - Method in interface ai.pipestream.common.util.ProcessingBuffer: Saves all messages in the buffer to disk using default parameters.
saveToDisk() - Method in class ai.pipestream.common.util.ProcessingBufferImpl
saveToDisk(String, int) - Method in class ai.pipestream.common.util.NoOpProcessingBuffer
saveToDisk(String, int) - Method in interface ai.pipestream.common.util.ProcessingBuffer: Saves all messages in the buffer to disk to "
saveToDisk(String, int) - Method in class ai.pipestream.common.util.ProcessingBufferImpl
saveToDisk(Path, String, int) - Method in class ai.pipestream.common.util.NoOpProcessingBuffer: Does nothing.
saveToDisk(Path, String, int) - Method in interface ai.pipestream.common.util.ProcessingBuffer: Saves all messages in the buffer to disk.
saveToDisk(Path, String, int) - Method in class ai.pipestream.common.util.ProcessingBufferImpl
SchemaExtractorService - Class in ai.pipestream.common.service: Service for extracting OpenAPI schema components from the dynamically generated OpenAPI document.
SchemaExtractorService() - Constructor for class ai.pipestream.common.service.SchemaExtractorService
SchemaNode(String, String, String) - Constructor for class ai.pipestream.common.util.MappingHelper.SchemaNode
SchemaNode(String, String, String, boolean) - Constructor for class ai.pipestream.common.util.MappingHelper.SchemaNode
schemaToJson(MappingHelper.SchemaNode) - Method in class ai.pipestream.common.util.MappingHelperJsonSupport: Exports schema tree as JSON.
score - Variable in class ai.pipestream.common.util.MappingHelper.FieldSuggestion
searchPaths(String...) - Static method in class ai.pipestream.common.util.descriptor.GoogleDescriptorLoader: Creates a loader that searches for descriptor files in multiple locations.
size() - Method in class ai.pipestream.common.util.DescriptorRegistry: Gets the number of registered descriptors.
size() - Method in class ai.pipestream.common.util.NoOpProcessingBuffer: Always returns 0.
size() - Method in interface ai.pipestream.common.util.ProcessingBuffer: Returns the number of messages in the buffer.
size() - Method in class ai.pipestream.common.util.ProcessingBufferImpl
snapshot() - Method in class ai.pipestream.common.util.NoOpProcessingBuffer: Always returns an empty list since this is a no-op buffer.
snapshot() - Method in interface ai.pipestream.common.util.ProcessingBuffer: Returns a snapshot of all items currently in the buffer.
snapshot() - Method in class ai.pipestream.common.util.ProcessingBufferImpl
structToMessage(Struct, Descriptors.Descriptor) - Method in class ai.pipestream.common.util.TypeConverter: Converts a Struct to a DynamicMessage of the specified type.
success() - Static method in class ai.pipestream.common.util.MappingHelper.ValidationResult
success() - Static method in record class ai.pipestream.common.validation.DefaultValidationResult: Creates a valid result with no errors or warnings.
success() - Static method in class ai.pipestream.common.validation.ValidationResultFactory: Creates a valid result with no errors or warnings.
SUCCESS - Enum constant in enum class ai.pipestream.common.util.MappingHelper.ValidationResult.ValidationLevel
successWithWarnings(List<String>) - Static method in record class ai.pipestream.common.validation.DefaultValidationResult: Creates a valid result with warnings.
successWithWarnings(List<String>) - Static method in class ai.pipestream.common.validation.ValidationResultFactory: Creates a valid result with warnings.
suggestionsToJson(List<MappingHelper.FieldSuggestion>) - Method in class ai.pipestream.common.util.MappingHelperJsonSupport: Exports field suggestions as JSON.
suggestTargetFields(String, Descriptors.Descriptor, Descriptors.Descriptor) - Method in class ai.pipestream.common.util.MappingHelper: Finds compatible target fields for a given source field.

T

toString() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns a string representation of this record class.
toString() - Method in class ai.pipestream.common.validation.EmptyValidationResult
toValue(Object) - Method in class ai.pipestream.common.util.TypeConverter: Converts a Java object to a protobuf Value.
type - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo
type - Variable in class ai.pipestream.common.util.MappingHelper.SchemaNode
TypeConverter - Class in ai.pipestream.common.util: Utility class for converting between different Protocol Buffer types.
TypeConverter() - Constructor for class ai.pipestream.common.util.TypeConverter

U

unpack(Any) - Method in class ai.pipestream.common.util.AnyHandler: Unpacks an Any message to a concrete message type.
unpackSafe(Any) - Method in class ai.pipestream.common.util.AnyHandler: Safely unpacks an Any, returning null if unpacking fails.
unpackToDynamic(Any, Descriptors.Descriptor) - Method in class ai.pipestream.common.util.AnyHandler: Unpacks an Any message to a DynamicMessage using the provided descriptor.
unpackToStruct(Any) - Method in class ai.pipestream.common.util.AnyHandler: Unpacks an Any to a Struct representation.

V

valid() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns the value of the valid record component.
valid() - Method in class ai.pipestream.common.validation.EmptyValidationResult
validateRule(String, Descriptors.Descriptor, Descriptors.Descriptor) - Method in class ai.pipestream.common.util.MappingHelper: Validates a mapping rule without executing it.
ValidationResultFactory - Class in ai.pipestream.common.validation: Factory for creating ValidationResult instances.
validationToJson(MappingHelper.ValidationResult) - Method in class ai.pipestream.common.util.MappingHelperJsonSupport: Exports validation result as JSON.
valueOf(String) - Static method in enum class ai.pipestream.common.util.MappingHelper.ValidationResult.ValidationLevel: Returns the enum constant of this class with the specified name.
values() - Static method in enum class ai.pipestream.common.util.MappingHelper.ValidationResult.ValidationLevel: Returns an array containing the constants of this enum class, in the order they are declared.

W

warning(String) - Static method in class ai.pipestream.common.util.MappingHelper.ValidationResult
WARNING - Enum constant in enum class ai.pipestream.common.util.MappingHelper.ValidationResult.ValidationLevel
warnings() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns the value of the warnings record component.
warnings() - Method in class ai.pipestream.common.validation.EmptyValidationResult
withAutoLoad() - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Enables automatic loading of descriptors from available loaders.
withAutoLoad() - Static method in interface ai.pipestream.common.util.ProtoFieldMapper
withAutoLoad() - Static method in class ai.pipestream.common.util.ProtoFieldMapperImpl: Creates a ProtoFieldMapper with auto-loading enabled.
withGoogleDescriptorLoader() - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Adds the default Google descriptor loader.
withGoogleDescriptorLoader(String) - Method in class ai.pipestream.common.util.DescriptorRegistry.RegistryBuilder: Adds a Google descriptor loader with a custom path.

A B C D E F G H I L M N P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form