All Classes and Interfaces
Class
Description
Utility class for handling google.protobuf.Any messages.
Runtime configurator for Kafka clients in SmallRye Reactive Messaging.
Loads Protocol Buffer descriptors from Apicurio Schema Registry.
Builder for ApicurioDescriptorLoader.
Qualifier to indicate the composite pipeline configuration validator.
Marker interface for configuration objects that can be validated.
Base interface for all configuration validators in the Rokkon pipeline system.
Event fired when Consul connection status changes.
Simple configuration record for Consul connection.
Result of pipeline configuration validation.
Generic interface for loading Protocol Buffer descriptors from various sources.
Exception thrown when descriptor loading fails.
Registry for managing Protocol Buffer descriptors.
Builder for fluently constructing a DescriptorRegistry.
An empty/no-op implementation of ValidationResult for testing and mocking purposes.
Loads Protocol Buffer descriptors from Google descriptor set files (.dsc).
Annotation for automatic gRPC service registration with enhanced metadata support.
Utility for loading SVG icons from various sources and converting them to base64 data URIs.
Helper class for building mapping UIs and providing field discovery.
JSON export support for MappingHelper.
Extension of ConfigValidator that supports mode-aware validation.
Event fired when a module registration is requested via gRPC.
Event fired when a module registration request has been processed.
A no-op implementation of the ProcessingBuffer interface.
Factory for creating consistently configured ObjectMapper instances.
Marker interface for pipeline cluster configuration objects that can be validated.
Interface for validators that validate PipelineClusterConfig.
Marker interface for pipeline configuration objects that can be validated.
Interface for validators that validate pipeline configurations.
Common constants used across the pipeline system.
Interface for a buffer that stores protobuf messages and can save them to disk.
Annotation to enable automatic processing buffer capture for pipeline methods.
Factory for creating ProcessingBuffer instances.
Implementation of the ProcessingBuffer interface.
Interceptor that automatically captures processing output to buffers based on @ProcessingBuffered annotation.
CDI bean that provides convenient access to processing buffers managed by the interceptor.
Interface for mapping fields between protobuf messages.
A streamlined utility for dynamically mapping fields between Protocol Buffer messages.
Exception thrown when a mapping rule cannot be applied.
Service for extracting OpenAPI schema components from the dynamically generated OpenAPI document.
A CDI event that is fired when the list of registered pipeline services changes.
Collects comprehensive metadata for service registration from annotations,
configuration, and runtime environment.
Utility class for converting between different Protocol Buffer types.
Defines the validation mode for pipeline configurations.
Interface for validation results in the pipeline system.
Factory for creating ValidationResult instances.