Index (pipeline-commons 0.2.11 API)

A B C D E F G H I J L M N O 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.api.annotation - package ai.pipestream.api.annotation
ai.pipestream.api.constants - package ai.pipestream.api.constants
ai.pipestream.api.events - package ai.pipestream.api.events
ai.pipestream.api.json - package ai.pipestream.api.json
ai.pipestream.api.registration - package ai.pipestream.api.registration
ai.pipestream.api.validation - package ai.pipestream.api.validation
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.
ApicurioConfigurator - Class in ai.pipestream.common.interceptor: Runtime configurator for Kafka clients in SmallRye Reactive Messaging.
ApicurioConfigurator() - Constructor for class ai.pipestream.common.interceptor.ApicurioConfigurator
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.
APPLICATION - Enum constant in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.ServiceType
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.api.registration.ServiceMetadataCollector.HealthCheckConfig.Builder
build() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
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.
buildConsulKey(String, String...) - Static method in class ai.pipestream.api.constants.PipelineConstants: Build a Consul key path with the application name prefix.
builder() - Static method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig
builder() - Static method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
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.api.registration.ServiceMetadataCollector.HealthCheckConfig.Builder
Builder() - Constructor for class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
Builder() - Constructor for class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader.Builder

C

capabilities() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Service capabilities - what this service can do
capabilities(Set<String>) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
capacity() - Element in annotation interface ai.pipestream.api.annotation.ProcessingBuffered: Buffer capacity override.
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.
collectServiceMetadata(Class<?>, GrpcServiceRegistration) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector: Collect comprehensive service metadata from annotation and configuration
combine(ValidationResult) - Method in interface ai.pipestream.api.validation.ValidationResult: Combines this result with another, taking the most restrictive validity.
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
Composite - Annotation Interface in ai.pipestream.api.validation: Qualifier to indicate the composite pipeline configuration validator.
Configuration Applied - Search tag in class ai.pipestream.common.interceptor.ApicurioConfigurator: Section
Configuration Strategy - Search tag in ai.pipestream.common.interceptor.ApicurioConfigurator.customize(String, Config, Map<String, Object>): Section
ConfigValidatable - Interface in ai.pipestream.api.validation: Marker interface for configuration objects that can be validated.
ConfigValidator<T> - Interface in ai.pipestream.api.validation: Base interface for all configuration validators in the Rokkon pipeline system.
connected() - Method in record class ai.pipestream.api.events.ConsulConnectionEvent.ConsulConnectionConfig: Returns the value of the connected record component.
CONNECTED - Enum constant in enum class ai.pipestream.api.events.ConsulConnectionEvent.Type
CONNECTION_FAILED - Enum constant in enum class ai.pipestream.api.events.ConsulConnectionEvent.Type
CONSUL_CLUSTERS_KEY - Static variable in class ai.pipestream.api.constants.PipelineConstants
CONSUL_CONFIG_KEY - Static variable in class ai.pipestream.api.constants.PipelineConstants
CONSUL_DEFINITIONS_KEY - Static variable in class ai.pipestream.api.constants.PipelineConstants
CONSUL_ENABLED_MODULES_KEY - Static variable in class ai.pipestream.api.constants.PipelineConstants
CONSUL_KEY_SEPARATOR - Static variable in class ai.pipestream.api.constants.PipelineConstants
CONSUL_MODULES_KEY - Static variable in class ai.pipestream.api.constants.PipelineConstants
CONSUL_PIPELINES_KEY - Static variable in class ai.pipestream.api.constants.PipelineConstants
CONSUL_REGISTERED_KEY - Static variable in class ai.pipestream.api.constants.PipelineConstants
ConsulConnectionConfig(String, int, boolean) - Constructor for record class ai.pipestream.api.events.ConsulConnectionEvent.ConsulConnectionConfig: Creates an instance of a ConsulConnectionConfig record class.
ConsulConnectionEvent - Class in ai.pipestream.api.events: Event fired when Consul connection status changes.
ConsulConnectionEvent(ConsulConnectionEvent.Type, ConsulConnectionEvent.ConsulConnectionConfig, String) - Constructor for class ai.pipestream.api.events.ConsulConnectionEvent
ConsulConnectionEvent.ConsulConnectionConfig - Record Class in ai.pipestream.api.events: Simple configuration record for Consul connection.
ConsulConnectionEvent.Type - Enum Class in ai.pipestream.api.events
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.
create(String, String, String, int, String, String, Map<String, String>, String, int, String, String) - Static method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent
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.
createConfiguredMapper() - Static method in class ai.pipestream.api.json.ObjectMapperFactory: Creates a fully configured ObjectMapper with all standard settings.
createMinimalMapper() - Static method in class ai.pipestream.api.json.ObjectMapperFactory: Creates a minimal ObjectMapper without ordering or special naming.
createTypeUrl(String) - Method in class ai.pipestream.common.util.AnyHandler: Creates a type URL from a type name.
customize(String, Config, Map<String, Object>) - Method in class ai.pipestream.common.interceptor.ApicurioConfigurator: Customizes Kafka client configuration for a specific channel.

D

DEFAULT_APP_NAME - Static variable in class ai.pipestream.api.constants.PipelineConstants
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
deregisterAfter(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig.Builder
description() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Human-readable description of the service
description(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
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.
DESIGN - Enum constant in enum class ai.pipestream.api.validation.ValidationMode: Design mode - applies structural and logical validation.
directory() - Element in annotation interface ai.pipestream.api.annotation.ProcessingBuffered: Buffer save directory override.
DISCONNECTED - Enum constant in enum class ai.pipestream.api.events.ConsulConnectionEvent.Type

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.
enabled() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Whether registration is enabled.
enabled() - Element in annotation interface ai.pipestream.api.annotation.ProcessingBuffered: Whether buffer capture is enabled.
endpoint(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig.Builder
engineHost() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the engineHost record component.
enginePort() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the enginePort record component.
equals(Object) - Method in record class ai.pipestream.api.events.ConsulConnectionEvent.ConsulConnectionConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Indicates whether some other object is "equal to" this one.
error() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns the value of the error record component.
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 interface ai.pipestream.api.validation.ValidationResult: Returns the list of validation errors.
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(String, String) - Static method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent
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.
getCapabilities() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getConfig() - Method in class ai.pipestream.api.events.ConsulConnectionEvent
getDefaultServiceIcon() - Method in class ai.pipestream.api.registration.IconResourceLoader: Get a default icon as base64 data URI for services without custom icons
getDeregisterAfter() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig
getDescription() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
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.
getEndpoint() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig
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.
getGrpcPort() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getHealthChecks() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getHost() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getIconSvgBase64() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getInterval() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig
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
getMessage() - Method in class ai.pipestream.api.events.ConsulConnectionEvent
getMetadata() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getPort() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getPriority() - Method in interface ai.pipestream.api.validation.ConfigValidator: Returns the priority of this validator (lower numbers = higher priority).
getRegisteredAt() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getRegisteredBy() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getRegistryUrl() - Method in class ai.pipestream.common.util.descriptor.ApicurioDescriptorLoader: Gets the registry URL.
getServiceId() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getServiceName() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getServiceNames() - Method in class ai.pipestream.api.events.ServiceListUpdatedEvent
getServiceType() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getTags() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
getTimeout() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig
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.
getType() - Method in class ai.pipestream.api.events.ConsulConnectionEvent
getType() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig
getTypeName(Any) - Method in class ai.pipestream.common.util.AnyHandler: Gets the type name from an Any message.
getValidatorName() - Method in interface ai.pipestream.api.validation.ConfigValidator: Returns the name of this validator for error reporting.
getVersion() - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata
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.
GRPC - Enum constant in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.HealthCheckType
grpcPort(int) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
GrpcServiceRegistration - Annotation Interface in ai.pipestream.api.annotation: Annotation for automatic gRPC service registration with enhanced metadata support.
GrpcServiceRegistration.HealthCheckType - Enum Class in ai.pipestream.api.annotation
GrpcServiceRegistration.ServiceType - Enum Class in ai.pipestream.api.annotation

H

hasDefault - Variable in class ai.pipestream.common.util.MappingHelper.FieldInfo
hasErrors() - Method in interface ai.pipestream.api.validation.ValidationResult: Returns true if there are any errors.
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.api.events.ConsulConnectionEvent.ConsulConnectionConfig: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.common.validation.DefaultValidationResult: Returns a hash code value for this object.
hasIssues() - Method in interface ai.pipestream.api.validation.ValidationResult: Returns true if there are any issues (errors or warnings).
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 interface ai.pipestream.api.validation.ValidationResult: Returns true if there are any warnings.
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
healthChecks() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Health check types to register
healthChecks(List<ServiceMetadataCollector.HealthCheckConfig>) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
host() - Method in record class ai.pipestream.api.events.ConsulConnectionEvent.ConsulConnectionConfig: Returns the value of the host record component.
host() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the host record component.
host(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
HTTP - Enum constant in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.HealthCheckType

I

iconPath() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Path to SVG icon for UI display.
IconResourceLoader - Class in ai.pipestream.api.registration: Utility for loading SVG icons from various sources and converting them to base64 data URIs.
IconResourceLoader() - Constructor for class ai.pipestream.api.registration.IconResourceLoader
iconSvgBase64(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
implementationId() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the implementationId record component.
INFRASTRUCTURE - Enum constant in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.ServiceType
instance() - Static method in class ai.pipestream.common.validation.EmptyValidationResult: Get the singleton instance of EmptyValidationResult.
interval(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig.Builder
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
isDesign() - Method in enum class ai.pipestream.api.validation.ValidationMode: Checks if this is design mode.
isOpenApiDocumentAvailable() - Method in class ai.pipestream.common.service.SchemaExtractorService: Validates that the OpenAPI document service is available and functional.
isProduction() - Method in enum class ai.pipestream.api.validation.ValidationMode: Checks if this is production mode.
isRegistered(String) - Method in class ai.pipestream.common.util.DescriptorRegistry: Checks if a descriptor is registered.
isTesting() - Method in enum class ai.pipestream.api.validation.ValidationMode: Checks if this is testing mode.
isValid - Variable in class ai.pipestream.common.util.MappingHelper.ValidationResult

J

jsonSchema() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the jsonSchema record component.

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.
loadIcon(String) - Method in class ai.pipestream.api.registration.IconResourceLoader: Load an SVG icon from the specified path and return as base64 data URI.
Logging - Search tag in class ai.pipestream.common.interceptor.ApicurioConfigurator: Section

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
message() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns the value of the message record component.
messageToStruct(Message) - Method in class ai.pipestream.common.util.TypeConverter: Converts a protobuf Message to a Struct.
metadata() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Additional metadata as key=value pairs
metadata() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the metadata record component.
metadata(Map<String, String>) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
ModeAwareValidator<T> - Interface in ai.pipestream.api.validation: Extension of ConfigValidator that supports mode-aware validation.
MODULE - Enum constant in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.ServiceType
MODULE_LABEL_PREFIX - Static variable in class ai.pipestream.api.constants.PipelineConstants
moduleId() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns the value of the moduleId record component.
moduleName() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the moduleName record component.
moduleName() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns the value of the moduleName record component.
ModuleRegistrationRequestEvent - Record Class in ai.pipestream.api.events: Event fired when a module registration is requested via gRPC.
ModuleRegistrationRequestEvent(String, String, String, int, String, String, Map<String, String>, String, int, String, String) - Constructor for record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Creates an instance of a ModuleRegistrationRequestEvent record class.
ModuleRegistrationResponseEvent - Record Class in ai.pipestream.api.events: Event fired when a module registration request has been processed.
ModuleRegistrationResponseEvent(String, boolean, String, String, String, String) - Constructor for record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Creates an instance of a ModuleRegistrationResponseEvent record class.

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.

O

ObjectMapperFactory - Class in ai.pipestream.api.json: Factory for creating consistently configured ObjectMapper instances.
ObjectMapperFactory() - Constructor for class ai.pipestream.api.json.ObjectMapperFactory

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
PipelineClusterConfigValidatable - Interface in ai.pipestream.api.validation: Marker interface for pipeline cluster configuration objects that can be validated.
PipelineClusterConfigValidator - Interface in ai.pipestream.api.validation: Interface for validators that validate PipelineClusterConfig.
PipelineConfigValidatable - Interface in ai.pipestream.api.validation: Marker interface for pipeline configuration objects that can be validated.
PipelineConfigValidator - Interface in ai.pipestream.api.validation: Interface for validators that validate pipeline configurations.
PipelineConstants - Class in ai.pipestream.api.constants: Common constants used across the pipeline system.
port() - Method in record class ai.pipestream.api.events.ConsulConnectionEvent.ConsulConnectionConfig: Returns the value of the port record component.
port() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the port record component.
port(int) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
prefix() - Element in annotation interface ai.pipestream.api.annotation.ProcessingBuffered: Buffer file prefix for saved files.
ProcessingBuffer<T> - Interface in ai.pipestream.common.util: Interface for a buffer that stores protobuf messages and can save them to disk.
ProcessingBuffered - Annotation Interface in ai.pipestream.api.annotation: Annotation to enable automatic processing buffer capture for pipeline methods.
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
produceObjectMapper() - Method in class ai.pipestream.api.json.ObjectMapperFactory: Bean producer method for CDI injection.
PRODUCTION - Enum constant in enum class ai.pipestream.api.validation.ValidationMode: Production mode - applies full validation suite.
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.
Purpose - Search tag in class ai.pipestream.common.interceptor.ApicurioConfigurator: Section

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.
registeredAt(Instant) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
registeredBy(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
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
requestId() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the requestId record component.
requestId() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns the value of the requestId record component.
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.
serviceId(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
ServiceListUpdatedEvent - Class in ai.pipestream.api.events: A CDI event that is fired when the list of registered pipeline services changes.
ServiceListUpdatedEvent(Set<String>) - Constructor for class ai.pipestream.api.events.ServiceListUpdatedEvent: Constructs a new event.
ServiceMetadataCollector - Class in ai.pipestream.api.registration: Collects comprehensive metadata for service registration from annotations, configuration, and runtime environment.
ServiceMetadataCollector() - Constructor for class ai.pipestream.api.registration.ServiceMetadataCollector
ServiceMetadataCollector.HealthCheckConfig - Class in ai.pipestream.api.registration
ServiceMetadataCollector.HealthCheckConfig.Builder - Class in ai.pipestream.api.registration
ServiceMetadataCollector.ServiceMetadata - Class in ai.pipestream.api.registration
ServiceMetadataCollector.ServiceMetadata.Builder - Class in ai.pipestream.api.registration
serviceName() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Service name for registration.
serviceName(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
serviceType() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Service type - distinguishes applications from pipeline modules
serviceType() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the serviceType record component.
serviceType(GrpcServiceRegistration.ServiceType) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
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() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns the value of the success record component.
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(String, String, String, String) - Static method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent
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.
supportedModes() - Method in interface ai.pipestream.api.validation.ConfigValidator: Returns the set of validation modes this validator supports.

T

tags() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Tags for service discovery
tags(Set<String>) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder
TCP - Enum constant in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.HealthCheckType
TESTING - Enum constant in enum class ai.pipestream.api.validation.ValidationMode: Testing mode - applies minimal validation.
Thread Safety - Search tag in class ai.pipestream.common.interceptor.ApicurioConfigurator: Section
timeout(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig.Builder
toString() - Method in record class ai.pipestream.api.events.ConsulConnectionEvent.ConsulConnectionConfig: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.api.events.ModuleRegistrationResponseEvent: Returns a string representation of this record class.
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
type() - Element in annotation interface ai.pipestream.api.annotation.ProcessingBuffered: The type of protobuf message to capture from the ProcessResponse.
type(GrpcServiceRegistration.HealthCheckType) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.HealthCheckConfig.Builder
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 interface ai.pipestream.api.validation.ValidationResult: Returns whether the validation was successful.
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
validate(T) - Method in interface ai.pipestream.api.validation.ConfigValidator: Validates the given configuration object and returns a validation result.
validate(T) - Method in interface ai.pipestream.api.validation.ModeAwareValidator: Default implementation delegates to mode-aware validate with PRODUCTION mode.
validate(T, ValidationMode) - Method in interface ai.pipestream.api.validation.ModeAwareValidator: Validates the given configuration object using the specified validation mode.
validateRule(String, Descriptors.Descriptor, Descriptors.Descriptor) - Method in class ai.pipestream.common.util.MappingHelper: Validates a mapping rule without executing it.
validateWithId(String, PipelineConfigValidatable) - Method in interface ai.pipestream.api.validation.PipelineConfigValidator: Validates a pipeline configuration with its ID.
ValidationMode - Enum Class in ai.pipestream.api.validation: Defines the validation mode for pipeline configurations.
ValidationResult - Interface in ai.pipestream.api.validation: Interface for validation results in the pipeline system.
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.api.annotation.GrpcServiceRegistration.HealthCheckType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.ServiceType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.api.events.ConsulConnectionEvent.Type: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.api.validation.ValidationMode: Returns the enum constant of this class with the specified name.
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.api.annotation.GrpcServiceRegistration.HealthCheckType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipestream.api.annotation.GrpcServiceRegistration.ServiceType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipestream.api.events.ConsulConnectionEvent.Type: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipestream.api.validation.ValidationMode: Returns an array containing the constants of this enum class, in the order they are declared.
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.
version() - Element in annotation interface ai.pipestream.api.annotation.GrpcServiceRegistration: Service version.
version() - Method in record class ai.pipestream.api.events.ModuleRegistrationRequestEvent: Returns the value of the version record component.
version(String) - Method in class ai.pipestream.api.registration.ServiceMetadataCollector.ServiceMetadata.Builder

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 interface ai.pipestream.api.validation.ValidationResult: Returns the list of validation warnings.
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
Why This Approach - Search tag in ai.pipestream.common.interceptor.ApicurioConfigurator.customize(String, Config, Map<String, Object>): Section
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 J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form