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.
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
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.
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.
Health check for services that platform-registration-service directly depends on.
Format-neutral document outline representation.
Format-neutral document outline representation.
Vector embedding for a document or document segment.
Vector embedding for a document or document segment.
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.
Registration event types tracking lifecycle stages.
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.
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.
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.
Processing intent for a document.
Collection of keywords extracted from a document.
Collection of keywords extracted from a document.
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.
Type of field mapping operation.
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.
Node-specific processing configuration.
Node-specific processing configuration.
Produces events to Kafka for OpenSearch indexing.
Wrapper for parser output metadata.
Wrapper for parser output metadata.
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.
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.
Contains configuration specific to this instance of the pipeline step.
Contains configuration specific to this instance of the pipeline step.
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.
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.
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.
Key-value tag collection for flexible document categorization.
Key-value tag collection for flexible document categorization.
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.
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).