All Classes and Interfaces
Class
Description
Configuration for field aggregation mappings.
Type of aggregation operation.
Configuration for field aggregation mappings.
Client for interacting with Apicurio Registry v3.
Exception thrown when operations with Apicurio Registry fail.
Artwork or object information.
Artwork or object information.
Binary blob with flexible storage options.
Binary blob with flexible storage options.
Container for one or more binary blobs.
Container for one or more binary blobs.
Collection of multiple blobs.
Collection of multiple blobs.
Capabilities that describe the module's operational characteristics
Capabilities that describe the module's operational characteristics
Enumeration of module capability types
Represents a Creative Commons license condition
Represents a Creative Commons license condition
Represents a Creative Commons license permission
Represents a Creative Commons license permission
Represents a Creative Commons license restriction
Represents a Creative Commons license restriction
Configuration for CEL-based mappings.
Configuration for CEL-based mappings.
Represents a CF coordinate system
Represents a CF coordinate system
Checksum algorithm types for blob integrity verification.
Text content and vector embedding for a single chunk.
Text content and vector embedding for a single chunk.
Comprehensive Climate Forecast (NetCDF) metadata as extracted by Tika from NetCDF scientific data files.
Comprehensive Climate Forecast (NetCDF) metadata as extracted by Tika from NetCDF scientific data files.
Detailed information about a database column
Detailed information about a database column
Entity representing a configuration schema for a service.
Connection information for reaching a service.
Connection information for reaching a service.
Handles health check operations for services registered with Consul
Handles service registration and unregistration with Consul.
Contact information structure for IPTC.
Contact information structure for IPTC.
Comprehensive Creative Commons and Rights metadata as extracted by Tika from various document types.
Comprehensive Creative Commons and Rights metadata as extracted by Tika from various document types.
Comprehensive Database metadata as extracted by Tika from database files.
Comprehensive Database metadata as extracted by Tika from database files.
Database property key-value pair (for Access MDB properties)
Database property key-value pair (for Access MDB properties)
Health check for services that platform-registration-service directly depends on.
Dead Letter Queue message for failed processing attempts.
Dead Letter Queue message for failed processing attempts.
Protobuf type
ai.pipestream.data.v1.DocIdDerivationProtobuf type
ai.pipestream.data.v1.DocIdDerivation
Document ID derivation method and details.
Format-neutral document outline representation.
Format-neutral document outline representation.
Reference to a document stored in the repository (S3 offload).
Reference to a document stored in the repository (S3 offload).
Event published when a document is successfully uploaded to the repository
Event published when a document is successfully uploaded to the repository
Represents Digital Rights Management information
Represents Digital Rights Management information
Dublin Core metadata - the standardized metadata that most documents have.
Dublin Core metadata - the standardized metadata that most documents have.
Comprehensive email metadata as extracted by Tika from email files.
Comprehensive email metadata as extracted by Tika from email files.
Vector embedding for a document or document segment.
Vector embedding for a document or document segment.
Represents a content item in the EPUB spine (reading order)
Essential for proper chunking and content organization
Represents a content item in the EPUB spine (reading order)
Essential for proper chunking and content organization
Represents an embedded resource in the EPUB
Important for understanding content dependencies and processing requirements
Represents an embedded resource in the EPUB
Important for understanding content dependencies and processing requirements
Represents an item in the EPUB manifest
Complete inventory of all resources in the EPUB
Represents an item in the EPUB manifest
Complete inventory of all resources in the EPUB
Comprehensive EPUB metadata as extracted by Tika from EPUB documents.
Comprehensive EPUB metadata as extracted by Tika from EPUB documents.
Represents a Table of Contents entry
Hierarchical structure for navigation and chunking boundaries
Represents a Table of Contents entry
Hierarchical structure for navigation and chunking boundaries
Error information for a failed processing step.
Error information for a failed processing step.
Event metadata wrapper for key-value pairs.
Event metadata wrapper for key-value pairs.
EXIF metadata from camera settings and technical information.
EXIF metadata from camera settings and technical information.
Snapshot of input state when a processing step failed.
Snapshot of input state when a processing step failed.
Reference to a file stored in S3 or external storage.
Reference to a file stored in S3 or external storage.
Protobuf type
ai.pipestream.parsed.data.tika.font.v1.FontBaselineProtobuf type
ai.pipestream.parsed.data.tika.font.v1.FontBaselineProtobuf type
ai.pipestream.parsed.data.tika.font.v1.FontBoundingBoxProtobuf type
ai.pipestream.parsed.data.tika.font.v1.FontBoundingBox
Font metadata extracted from font files (TTF, AFM, etc.)
Based on Tika's Font.java interface, AdobeFontMetricParser, and TrueTypeParser
Font metadata extracted from font files (TTF, AFM, etc.)
Based on Tika's Font.java interface, AdobeFontMetricParser, and TrueTypeParser
Protobuf type
ai.pipestream.parsed.data.tika.font.v1.FontQualityMetricsProtobuf type
ai.pipestream.parsed.data.tika.font.v1.FontQualityMetricsProtobuf type
ai.pipestream.parsed.data.tika.font.v1.FontSpacingProtobuf type
ai.pipestream.parsed.data.tika.font.v1.FontSpacing
Generic metadata for document types that don't have specialized parsers or interfaces.
Generic metadata for document types that don't have specialized parsers or interfaces.
Request to retrieve connector configuration schema from Apicurio Registry.
Request to retrieve connector configuration schema from Apicurio Registry.
Response containing connector configuration schema.
Response containing connector configuration schema.
Request to look up module details.
Request to look up module details.
Complete details for a registered module instance.
Complete details for a registered module instance.
Request to retrieve module configuration schema from Apicurio Registry.
Request to retrieve module configuration schema from Apicurio Registry.
Response containing module configuration schema.
Response containing module configuration schema.
Request to list all schema versions for a module.
Request to list all schema versions for a module.
Response containing all schema versions for a module.
Response containing all schema versions for a module.
Request for module registration, optionally includes test data for health check
Request for module registration, optionally includes test data for health check
Response containing module registration data and health status
Response containing module registration data and health status
Request to look up service details.
Request to look up service details.
Complete details for a registered service instance.
Complete details for a registered service instance.
GPS metadata from EXIF GPS information.
GPS metadata from EXIF GPS information.
Customizes the gRPC server builder to set the HTTP/2 flow control window for optimal large message throughput.
Simple utility to resolve hostname for service registration.
Comprehensive HTML metadata as extracted by Tika from HTML and web documents.
Comprehensive HTML metadata as extracted by Tika from HTML and web documents.
Configuration for hydration/dehydration policies for blob handling.
Configuration for hydration/dehydration policies for blob handling.
Hydration policy options.
Comprehensive image metadata as extracted by Tika from TIFF, EXIF, IPTC, XMP, and GPS.
Comprehensive image metadata as extracted by Tika from TIFF, EXIF, IPTC, XMP, and GPS.
Database index information
Database index information
Ingestion configuration from connector-intake-service.
Ingestion configuration from connector-intake-service.
Mode indicating how a document entered the ingestion pipeline.
Processing intent for a document.
IPTC (International Press Telecommunications Council) metadata.
IPTC (International Press Telecommunications Council) metadata.
Collection of keywords extracted from a document.
Collection of keywords extracted from a document.
Licensor contact information.
Licensor contact information.
Reference to a link discovered within a document.
Reference to a link discovered within a document.
Request to list all registered modules.
Request to list all registered modules.
Response containing list of all registered modules.
Response containing list of all registered modules.
Request to list all registered services.
Request to list all registered services.
Response containing list of all registered services.
Response containing list of all registered services.
Location information with precise semantics.
Location information with precise semantics.
Type of field mapping operation.
Comprehensive media metadata as extracted by Tika from audio and video files.
Comprehensive media metadata as extracted by Tika from audio and video files.
Event published to Kafka when a module is registered.
Event published to Kafka when a module is registered.
Handles module registration operations with proper reactive flow.
Repository for managing service module registrations in MySQL.
Metadata for a single schema version.
Metadata for a single schema version.
Event published to Kafka when a module is unregistered.
Event published to Kafka when a module is unregistered.
Service definition for a pipeline step processor.
Service definition for a pipeline step processor.
Unified registration service for all platform services and modules.
Unified registration service for all platform services and modules.
Represents a NetCDF attribute
Represents a NetCDF attribute
Represents a NetCDF dimension
Represents a NetCDF dimension
Represents model ensemble information
Represents model ensemble information
Represents a valid range for a variable
Represents a valid range for a variable
Represents uncertainty or error information
Represents uncertainty or error information
Represents a NetCDF variable
Represents a NetCDF variable
Node-specific processing configuration.
Node-specific processing configuration.
Comprehensive Office metadata as extracted by Tika from Microsoft Office and OpenDocument files.
Comprehensive Office metadata as extracted by Tika from Microsoft Office and OpenDocument files.
Produces events to Kafka for OpenSearch indexing.
Output hints for downstream processing and routing.
Output hints for downstream processing and routing.
Ownership context for a document.
Ownership context for a document.
Wrapper for parser output metadata.
Wrapper for parser output metadata.
Comprehensive PDF metadata as extracted by Tika from PDF files.
Comprehensive PDF metadata as extracted by Tika from PDF files.
Configuration for document persistence decisions.
Configuration for document persistence decisions.
Core document container for the pipeline processing system.
Core document container for the pipeline processing system.
Service definition for a pipeline step processor.
Service definition for a pipeline step processor.
A stub to allow clients to do limited synchronous rpc calls to service PipeStepProcessorService.
A stub to allow clients to do synchronous rpc calls to service PipeStepProcessorService.
A stub to allow clients to do ListenableFuture-style rpc calls to service PipeStepProcessorService.
Base class for the server implementation of the service PipeStepProcessorService.
A stub to allow clients to do asynchronous rpc calls to service PipeStepProcessorService.
TCP-like packet header for node-to-node document processing.
TCP-like packet header for node-to-node document processing.
Registration event types tracking lifecycle stages.
Main platform registration service implementation.
Unified registration service for all platform services and modules.
Unified registration service for all platform services and modules.
A stub to allow clients to do limited synchronous rpc calls to service PlatformRegistrationService.
A stub to allow clients to do synchronous rpc calls to service PlatformRegistrationService.
A stub to allow clients to do ListenableFuture-style rpc calls to service PlatformRegistrationService.
Base class for the server implementation of the service PlatformRegistrationService.
A stub to allow clients to do asynchronous rpc calls to service PlatformRegistrationService.
PLUS licensing information.
PLUS licensing information.
Configuration for a processing step instance.
Configuration for a processing step instance.
Request message for the ProcessData RPC.
Request message for the ProcessData RPC.
Response message for the ProcessData RPC.
Response message for the ProcessData RPC.
Field mapping configuration for protobuf transformation.
Field mapping configuration for protobuf transformation.
Request to register a service or module with the platform.
Request to register a service or module with the platform.
Response for Register RPC (streaming).
Response for Register RPC (streaming).
Streaming registration event tracking registration progress.
Streaming registration event tracking registration progress.
Service-specific gRPC client factory for platform-registration-service.
Registry information.
Registry information.
Database relationship/foreign key information
Database relationship/foreign key information
Event emitted by the Repository Service's Metadata Indexer
once a document's core metadata has been successfully persisted to the database.
Event emitted by the Repository Service's Metadata Indexer
once a document's core metadata has been successfully persisted to the database.
Type of metadata update operation
Request to resolve service endpoint for dynamic routing.
Request to resolve service endpoint for dynamic routing.
Response from service resolution containing the best available instance.
Response from service resolution containing the best available instance.
Configuration for document retention policies.
Configuration for document retention policies.
Retention policy options.
Represents an entry in the rights audit trail
Represents an entry in the rights audit trail
Comprehensive RTF (Rich Text Format) metadata as extracted by Tika.
Comprehensive RTF (Rich Text Format) metadata as extracted by Tika.
Handles schema retrieval operations from Apicurio Registry with fallback to module direct calls.
Standardized search engine metadata for OOTB indexing.
Standardized search engine metadata for OOTB indexing.
Single section within a document outline.
Single section within a document outline.
Handles self-registration of the platform-registration-service with Consul.
Single semantic chunk with its text and embedding.
Single semantic chunk with its text and embedding.
Complete result of semantic chunking and embedding process.
Complete result of semantic chunking and embedding process.
Handles service discovery and lookup operations.
Contains metadata provided by the pipeline engine for context.
Contains metadata provided by the pipeline engine for context.
Entity representing a registered service module in the system.
Event published to Kafka when a service is registered.
Event published to Kafka when a service is registered.
Handles service registration operations.
Status of a registered service module
Type of service being registered.
Event published to Kafka when a service is unregistered.
Event published to Kafka when a service is unregistered.
Configuration for field splitting mappings.
Configuration for field splitting mappings.
Execution record for a single pipeline processing step.
Execution record for a single pipeline processing step.
Metadata for tracking stream processing history and context.
Metadata for tracking stream processing history and context.
String list helper
String list helper
Detailed information about a database table
Detailed information about a database table
Key-value tag collection for flexible document categorization.
Key-value tag collection for flexible document categorization.
Represents temporal restrictions on usage
Represents temporal restrictions on usage
Base metadata structure for Tika parsing results.
Base metadata structure for Tika parsing results.
Core content - the actual text extracted
Core content - the actual text extracted
Embedded document
Embedded document
Generic metadata entry for properties not covered by the strongly-typed fields.
Generic metadata entry for properties not covered by the strongly-typed fields.
Parse status
Parse status
Protobuf enum
ai.pipestream.parsed.data.tika.v1.TikaParseStatus.Status
Flexible TikaResponse that mirrors how Tika actually stores metadata.
Flexible TikaResponse that mirrors how Tika actually stores metadata.
Configuration for field transformation mappings.
Configuration for field transformation mappings.
Request to unregister a service or module.
Request to unregister a service or module.
Response from unregistration operation.
Response from unregistration operation.
Represents a cookie associated with the archived request/response
Represents a cookie associated with the archived request/response
Represents an embedded resource found within the archived content
Represents an embedded resource found within the archived content
Represents an HTTP header from the archived HTTP response
Represents an HTTP header from the archived HTTP response
Comprehensive WARC (Web ARChive) metadata as extracted by Tika from WARC and ARC files.
Comprehensive WARC (Web ARChive) metadata as extracted by Tika from WARC and ARC files.
Represents a migration event in the archive's history
Represents a migration event in the archive's history
Represents a redirect in the HTTP redirect chain
Represents a redirect in the HTTP redirect chain
Represents a technical property of the archived content
Represents a technical property of the archived content
Request to watch for module registration changes.
Request to watch for module registration changes.
Response for WatchModules RPC (streaming).
Response for WatchModules RPC (streaming).
Request to watch for service registration changes.
Request to watch for service registration changes.
Response for WatchServices RPC (streaming).
Response for WatchServices RPC (streaming).