Crate oxirs_stream 

OxiRS Stream - Ultra-High Performance RDF Streaming Platform

Status: Production Release (v0.1.0) Stability: Public APIs are stable. Production-ready with comprehensive testing.

Real-time streaming support with Kafka/NATS/Redis I/O, RDF Patch, SPARQL Update delta, and advanced event processing capabilities.

This crate provides enterprise-grade real-time data streaming capabilities for RDF datasets, supporting multiple messaging backends with high-throughput, low-latency guarantees.

Features

• Multi-Backend Support: Kafka, NATS JetStream, Redis Streams, AWS Kinesis, Memory
• High Performance: 100K+ events/second, <10ms latency, exactly-once delivery
• Advanced Event Processing: Real-time pattern detection, windowing, aggregations
• Enterprise Features: Circuit breakers, connection pooling, health monitoring
• Standards Compliance: RDF Patch protocol, SPARQL Update streaming

Performance Targets

• Throughput: 100K+ events/second sustained
• Latency: P99 <10ms for real-time processing
• Reliability: 99.99% delivery success rate
• Scalability: Linear scaling to 1000+ partitions

Re-exports

pub use backend_optimizer::BackendOptimizer;

pub use backend_optimizer::BackendPerformance;

pub use backend_optimizer::BackendRecommendation;

pub use backend_optimizer::ConsistencyLevel;

pub use backend_optimizer::CostModel;

pub use backend_optimizer::OptimizationDecision;

pub use backend_optimizer::OptimizationStats;

pub use backend_optimizer::OptimizerConfig;

pub use backend_optimizer::PatternType;

pub use backend_optimizer::WorkloadPattern;

pub use backpressure::BackpressureConfig;

pub use backpressure::BackpressureController;

pub use backpressure::BackpressureStats;

pub use backpressure::BackpressureStrategy;

pub use backpressure::FlowControlSignal;

pub use backpressure::RateLimiter as BackpressureRateLimiter;

pub use bridge::BridgeInfo;

pub use bridge::BridgeStatistics;

pub use bridge::BridgeType;

pub use bridge::ExternalMessage;

pub use bridge::ExternalSystemConfig;

pub use bridge::ExternalSystemType;

pub use bridge::MessageBridgeManager;

pub use bridge::MessageTransformer;

pub use bridge::RoutingRule;

pub use circuit_breaker::CircuitBreakerError;

pub use circuit_breaker::CircuitBreakerMetrics;

pub use circuit_breaker::FailureType;

pub use circuit_breaker::SharedCircuitBreakerExt;

pub use connection_pool::ConnectionFactory;

pub use connection_pool::ConnectionPool;

pub use connection_pool::DetailedPoolMetrics;

pub use connection_pool::LoadBalancingStrategy;

pub use connection_pool::PoolConfig;

pub use connection_pool::PoolStats;

pub use connection_pool::PoolStatus;

pub use cqrs::CQRSConfig;

pub use cqrs::CQRSHealthStatus;

pub use cqrs::CQRSSystem;

pub use cqrs::Command;

pub use cqrs::CommandBus;

pub use cqrs::CommandBusMetrics;

pub use cqrs::CommandHandler;

pub use cqrs::CommandResult;

pub use cqrs::Query;

pub use cqrs::QueryBus;

pub use cqrs::QueryBusMetrics;

pub use cqrs::QueryCacheConfig;

pub use cqrs::QueryHandler;

pub use cqrs::QueryResult as CQRSQueryResult;

pub use cqrs::ReadModelManager;

pub use cqrs::ReadModelMetrics;

pub use cqrs::ReadModelProjection;

pub use cqrs::RetryConfig as CQRSRetryConfig;

pub use delta::BatchDeltaProcessor;

pub use delta::DeltaComputer;

pub use delta::DeltaProcessor;

pub use delta::ProcessorStats;

pub use dlq::DeadLetterQueue;

pub use dlq::DlqConfig;

pub use dlq::DlqEventProcessor;

pub use dlq::DlqStats as DlqStatsExport;

pub use dlq::FailedEvent;

pub use dlq::FailureReason;

pub use event::EventCategory;

pub use event::EventMetadata;

pub use event::EventPriority;

pub use event::IsolationLevel;

pub use event::QueryResult as EventQueryResult;

pub use event::SchemaChangeType;

pub use event::SchemaType;

pub use event::SparqlOperationType;

pub use event::StreamEvent;

pub use event_sourcing::EventQuery;

pub use event_sourcing::EventSnapshot;

pub use event_sourcing::EventStore;

pub use event_sourcing::EventStoreConfig;

pub use event_sourcing::PersistenceBackend;

pub use event_sourcing::QueryOrder;

pub use event_sourcing::RetentionPolicy;

pub use event_sourcing::SnapshotConfig;

pub use event_sourcing::StoredEvent;

pub use event_sourcing::TimeRange as EventSourcingTimeRange;

pub use failover::ConnectionEndpoint;

pub use failover::FailoverConfig;

pub use failover::FailoverManager;

pub use graphql_bridge::BridgeConfig;

pub use graphql_bridge::BridgeStats;

pub use graphql_bridge::GraphQLBridge;

pub use graphql_bridge::GraphQLSubscription;

pub use graphql_bridge::GraphQLUpdate;

pub use graphql_bridge::GraphQLUpdateType;

pub use graphql_bridge::SubscriptionFilter;

pub use multi_region_replication::ConflictResolution;

pub use multi_region_replication::ConflictType;

pub use multi_region_replication::GeographicLocation;

pub use multi_region_replication::MultiRegionReplicationManager;

pub use multi_region_replication::RegionConfig;

pub use multi_region_replication::RegionHealth;

pub use multi_region_replication::ReplicatedEvent;

pub use multi_region_replication::ReplicationConfig;

pub use multi_region_replication::ReplicationStats;

pub use multi_region_replication::ReplicationStrategy;

pub use multi_region_replication::VectorClock;

pub use patch::PatchParser;

pub use patch::PatchSerializer;

pub use performance_optimizer::AdaptiveBatcher;

pub use performance_optimizer::AggregationFunction;

pub use performance_optimizer::AutoTuner;

pub use performance_optimizer::BatchPerformancePoint;

pub use performance_optimizer::BatchSizePredictor;

pub use performance_optimizer::BatchingStats;

pub use performance_optimizer::EnhancedMLConfig;

pub use performance_optimizer::MemoryPool;

pub use performance_optimizer::MemoryPoolStats;

pub use performance_optimizer::PerformanceConfig as OptimizerPerformanceConfig;

pub use performance_optimizer::ProcessingResult;

pub use performance_optimizer::ProcessingStats;

pub use performance_optimizer::ProcessingStatus;

pub use performance_optimizer::TuningDecision;

pub use performance_optimizer::ZeroCopyEvent;

pub use schema_registry::CompatibilityMode;

pub use schema_registry::ExternalRegistryConfig;

pub use schema_registry::RegistryAuth;

pub use schema_registry::SchemaDefinition;

pub use schema_registry::SchemaFormat;

pub use schema_registry::SchemaRegistry;

pub use schema_registry::SchemaRegistryConfig;

pub use schema_registry::ValidationResult;

pub use schema_registry::ValidationStats;

pub use sparql_streaming::ContinuousQueryManager;

pub use sparql_streaming::QueryManagerConfig;

pub use sparql_streaming::QueryMetadata;

pub use sparql_streaming::QueryResultChannel;

pub use sparql_streaming::QueryResultUpdate;

pub use sparql_streaming::UpdateType;

pub use store_integration::ChangeDetectionStrategy;

pub use store_integration::ChangeNotification;

pub use store_integration::RealtimeUpdateManager;

pub use store_integration::StoreChangeDetector;

pub use store_integration::UpdateChannel;

pub use store_integration::UpdateFilter;

pub use store_integration::UpdateNotification;

pub use biological_computing::AminoAcid;

pub use biological_computing::BiologicalProcessingStats;

pub use biological_computing::BiologicalStreamProcessor;

pub use biological_computing::Cell;

pub use biological_computing::CellState;

pub use biological_computing::CellularAutomaton;

pub use biological_computing::ComputationalFunction;

pub use biological_computing::DNASequence;

pub use biological_computing::EvolutionaryOptimizer;

pub use biological_computing::FunctionalDomain;

pub use biological_computing::Individual;

pub use biological_computing::Nucleotide;

pub use biological_computing::ProteinStructure;

pub use biological_computing::SequenceMetadata;

pub use consciousness_streaming::ConsciousnessLevel;

pub use consciousness_streaming::ConsciousnessStats;

pub use consciousness_streaming::ConsciousnessStreamProcessor;

pub use consciousness_streaming::DreamSequence;

pub use consciousness_streaming::EmotionalContext;

pub use consciousness_streaming::IntuitiveEngine;

pub use consciousness_streaming::MeditationState;

pub use disaster_recovery::BackupCompression;

pub use disaster_recovery::BackupConfig;

pub use disaster_recovery::BackupEncryption;

pub use disaster_recovery::BackupFrequency;

pub use disaster_recovery::BackupJob;

pub use disaster_recovery::BackupRetentionPolicy;

pub use disaster_recovery::BackupSchedule;

pub use disaster_recovery::BackupStatus;

pub use disaster_recovery::BackupStorage;

pub use disaster_recovery::BackupType;

pub use disaster_recovery::BackupVerification;

pub use disaster_recovery::BackupVerificationResult;

pub use disaster_recovery::BackupWindow;

pub use disaster_recovery::BusinessContinuityConfig;

pub use disaster_recovery::ChecksumAlgorithm;

pub use disaster_recovery::CompressionAlgorithm;

pub use disaster_recovery::DRMetrics;

pub use disaster_recovery::DisasterRecoveryConfig;

pub use disaster_recovery::DisasterRecoveryManager;

pub use disaster_recovery::DisasterScenario;

pub use disaster_recovery::EncryptionAlgorithm as BackupEncryptionAlgorithm;

pub use disaster_recovery::FailoverConfig as DRFailoverConfig;

pub use disaster_recovery::ImpactLevel;

pub use disaster_recovery::KeyDerivationFunction;

pub use disaster_recovery::RecoveryConfig;

pub use disaster_recovery::RecoveryOperation;

pub use disaster_recovery::RecoveryPriority;

pub use disaster_recovery::RecoveryRunbook;

pub use disaster_recovery::RecoveryStatus;

pub use disaster_recovery::RecoveryType;

pub use disaster_recovery::ReplicationConfig as DRReplicationConfig;

pub use disaster_recovery::ReplicationMode as DRReplicationMode;

pub use disaster_recovery::ReplicationTarget as DRReplicationTarget;

pub use disaster_recovery::RunbookExecution;

pub use disaster_recovery::RunbookExecutionStatus;

pub use disaster_recovery::RunbookStep;

pub use disaster_recovery::StorageLocation;

pub use enterprise_audit::ActionResult;

pub use enterprise_audit::AuditEncryptionConfig;

pub use enterprise_audit::AuditEventType;

pub use enterprise_audit::AuditFilterConfig;

pub use enterprise_audit::AuditMetrics;

pub use enterprise_audit::AuditRetentionConfig;

pub use enterprise_audit::AuditSeverity;

pub use enterprise_audit::AuditStorageBackend;

pub use enterprise_audit::AuditStorageConfig;

pub use enterprise_audit::AuditStreamingConfig;

pub use enterprise_audit::AuthType;

pub use enterprise_audit::ComplianceConfig;

pub use enterprise_audit::ComplianceFinding;

pub use enterprise_audit::ComplianceReport;

pub use enterprise_audit::ComplianceStandard;

pub use enterprise_audit::CompressionType as AuditCompressionType;

pub use enterprise_audit::DestinationAuth;

pub use enterprise_audit::DestinationType;

pub use enterprise_audit::EncryptionAlgorithm;

pub use enterprise_audit::EnterpriseAuditConfig;

pub use enterprise_audit::EnterpriseAuditEvent;

pub use enterprise_audit::EnterpriseAuditLogger;

pub use enterprise_audit::FindingType;

pub use enterprise_audit::KeyManagementConfig;

pub use enterprise_audit::KmsType;

pub use enterprise_audit::S3AuditConfig;

pub use enterprise_audit::StreamingDestination;

pub use enterprise_monitoring::Alert;

pub use enterprise_monitoring::AlertCondition;

pub use enterprise_monitoring::AlertManager;

pub use enterprise_monitoring::AlertRule;

pub use enterprise_monitoring::AlertSeverity as MonitoringAlertSeverity;

pub use enterprise_monitoring::AlertingConfig;

pub use enterprise_monitoring::BreachNotificationConfig;

pub use enterprise_monitoring::ComparisonOperator;

pub use enterprise_monitoring::EnterpriseMonitoringConfig;

pub use enterprise_monitoring::EnterpriseMonitoringSystem;

pub use enterprise_monitoring::EscalationLevel;

pub use enterprise_monitoring::EscalationPolicy;

pub use enterprise_monitoring::HealthCheckConfig;

pub use enterprise_monitoring::HealthCheckEndpoint;

pub use enterprise_monitoring::HealthCheckType;

pub use enterprise_monitoring::MeasurementWindow;

pub use enterprise_monitoring::MetricDefinition;

pub use enterprise_monitoring::MetricType;

pub use enterprise_monitoring::MetricValue;

pub use enterprise_monitoring::MetricsCollector;

pub use enterprise_monitoring::MetricsConfig;

pub use enterprise_monitoring::MetricsEndpoint;

pub use enterprise_monitoring::MetricsEndpointType;

pub use enterprise_monitoring::MetricsExportConfig;

pub use enterprise_monitoring::MetricsFormat;

pub use enterprise_monitoring::NotificationChannel;

pub use enterprise_monitoring::ProfilingConfig;

pub use enterprise_monitoring::SlaBreach;

pub use enterprise_monitoring::SlaConfig;

pub use enterprise_monitoring::SlaMeasurement;

pub use enterprise_monitoring::SlaMetricType;

pub use enterprise_monitoring::SlaObjective;

pub use enterprise_monitoring::SlaSeverity;

pub use enterprise_monitoring::SlaStatus;

pub use enterprise_monitoring::SlaTracker;

pub use multi_tenancy::IsolationMode;

pub use multi_tenancy::MultiTenancyConfig;

pub use multi_tenancy::MultiTenancyManager;

pub use multi_tenancy::MultiTenancyMetrics;

pub use multi_tenancy::NamespaceResources;

pub use multi_tenancy::ResourceAllocationStrategy;

pub use multi_tenancy::ResourceType;

pub use multi_tenancy::ResourceUsage;

pub use multi_tenancy::Tenant;

pub use multi_tenancy::TenantLifecycleConfig;

pub use multi_tenancy::TenantNamespace;

pub use multi_tenancy::TenantQuota;

pub use multi_tenancy::TenantStatus;

pub use multi_tenancy::TenantTier;

pub use observability::AlertConfig;

pub use observability::AlertEvent;

pub use observability::AlertSeverity;

pub use observability::AlertType;

pub use observability::BusinessMetrics;

pub use observability::SpanLog;

pub use observability::SpanStatus;

pub use observability::StreamObservability;

pub use observability::StreamingMetrics;

pub use observability::TelemetryConfig;

pub use observability::TraceSpan;

pub use performance_utils::AdaptiveRateLimiter;

pub use performance_utils::IntelligentMemoryPool;

pub use performance_utils::IntelligentPrefetcher;

pub use performance_utils::ParallelStreamProcessor;

pub use performance_utils::PerformanceUtilsConfig;

pub use quantum_communication::BellState;

pub use quantum_communication::EntanglementDistribution;

pub use quantum_communication::QuantumCommConfig;

pub use quantum_communication::QuantumCommSystem;

pub use quantum_communication::QuantumOperation as QuantumCommOperation;

pub use quantum_communication::QuantumSecurityProtocol;

pub use quantum_communication::QuantumState as QuantumCommState;

pub use quantum_communication::Qubit;

pub use quantum_streaming::QuantumEvent;

pub use quantum_streaming::QuantumOperation;

pub use quantum_streaming::QuantumProcessingStats;

pub use quantum_streaming::QuantumState;

pub use quantum_streaming::QuantumStreamProcessor;

pub use reliability::BulkReplayResult;

pub use reliability::DlqStats;

pub use reliability::ReplayStatus;

pub use rsp::RspConfig;

pub use rsp::RspLanguage;

pub use rsp::RspProcessor;

pub use rsp::RspQuery;

pub use rsp::StreamClause;

pub use rsp::StreamDescriptor;

pub use rsp::Window;

pub use rsp::WindowConfig;

pub use rsp::WindowSize;

pub use rsp::WindowStats;

pub use rsp::WindowType;

pub use security::AuditConfig;

pub use security::AuditLogEntry;

pub use security::AuditLogger;

pub use security::AuthConfig;

pub use security::AuthMethod;

pub use security::AuthenticationProvider;

pub use security::AuthorizationProvider;

pub use security::AuthzConfig;

pub use security::Credentials;

pub use security::EncryptionConfig;

pub use security::Permission;

pub use security::RateLimitConfig;

pub use security::RateLimiter;

pub use security::SecurityConfig as StreamSecurityConfig;

pub use security::SecurityContext;

pub use security::SecurityManager;

pub use security::SecurityMetrics;

pub use security::SessionConfig;

pub use security::ThreatAlert;

pub use security::ThreatDetectionConfig;

pub use security::ThreatDetector;

pub use temporal_join::IntervalJoin;

pub use temporal_join::JoinResult;

pub use temporal_join::LateDataConfig;

pub use temporal_join::LateDataStrategy;

pub use temporal_join::TemporalJoin;

pub use temporal_join::TemporalJoinConfig;

pub use temporal_join::TemporalJoinMetrics;

pub use temporal_join::TemporalJoinType;

pub use temporal_join::TemporalWindow;

pub use temporal_join::TimeSemantics;

pub use temporal_join::WatermarkConfig;

pub use temporal_join::WatermarkStrategy;

pub use time_travel::AggregationType;

pub use time_travel::TemporalAggregations;

pub use time_travel::TemporalFilter;

pub use time_travel::TemporalOrdering;

pub use time_travel::TemporalProjection;

pub use time_travel::TemporalQuery;

pub use time_travel::TemporalQueryResult;

pub use time_travel::TemporalResultMetadata;

pub use time_travel::TemporalStatistics;

pub use time_travel::TimePoint;

pub use time_travel::TimeRange as TimeTravelTimeRange;

pub use time_travel::TimeTravelConfig;

pub use time_travel::TimeTravelEngine;

pub use time_travel::TimeTravelMetrics;

pub use time_travel::TimelinePoint;

pub use tls_security::CertRotationConfig;

pub use tls_security::CertificateConfig;

pub use tls_security::CertificateFormat;

pub use tls_security::CertificateInfo;

pub use tls_security::CipherSuite;

pub use tls_security::ExpiryWarning;

pub use tls_security::MutualTlsConfig;

pub use tls_security::OcspConfig;

pub use tls_security::RevocationCheckConfig;

pub use tls_security::SessionResumptionConfig;

pub use tls_security::TlsConfig;

pub use tls_security::TlsManager;

pub use tls_security::TlsMetrics;

pub use tls_security::TlsSessionInfo;

pub use tls_security::TlsVersion;

pub use wasm_edge_computing::EdgeExecutionResult;

pub use wasm_edge_computing::EdgeLocation;

pub use wasm_edge_computing::OptimizationLevel;

pub use wasm_edge_computing::PerformanceProfile;

pub use wasm_edge_computing::PluginCapability;

pub use wasm_edge_computing::PluginSchema;

pub use wasm_edge_computing::ProcessingSpecialization;

pub use wasm_edge_computing::ResourceMetrics;

pub use wasm_edge_computing::SecurityLevel;

pub use wasm_edge_computing::WasmEdgeConfig;

pub use wasm_edge_computing::WasmEdgeProcessor;

pub use wasm_edge_computing::WasmPlugin;

pub use wasm_edge_computing::WasmProcessingResult;

pub use wasm_edge_computing::WasmProcessorStats;

pub use wasm_edge_computing::WasmResourceLimits;

pub use webhook::EventFilter as WebhookEventFilter;

pub use webhook::HttpMethod;

pub use webhook::RateLimit;

pub use webhook::RetryConfig as WebhookRetryConfig;

pub use webhook::WebhookConfig;

pub use webhook::WebhookInfo;

pub use webhook::WebhookManager;

pub use webhook::WebhookMetadata;

pub use webhook::WebhookSecurity;

pub use webhook::WebhookStatistics;

pub use custom_serialization::BenchmarkResults;

pub use custom_serialization::BsonSerializer;

pub use custom_serialization::CustomSerializer;

pub use custom_serialization::FlexBuffersSerializer;

pub use custom_serialization::IonSerializer;

pub use custom_serialization::RonSerializer;

pub use custom_serialization::SerializerBenchmark;

pub use custom_serialization::SerializerBenchmarkSuite;

pub use custom_serialization::SerializerRegistry;

pub use custom_serialization::SerializerStats;

pub use custom_serialization::ThriftSerializer;

pub use end_to_end_encryption::E2EEConfig;

pub use end_to_end_encryption::E2EEEncryptionAlgorithm;

pub use end_to_end_encryption::E2EEManager;

pub use end_to_end_encryption::E2EEStats;

pub use end_to_end_encryption::EncryptedMessage;

pub use end_to_end_encryption::HomomorphicEncryption;

pub use end_to_end_encryption::KeyExchangeAlgorithm;

pub use end_to_end_encryption::KeyPair;

pub use end_to_end_encryption::KeyRotationConfig;

pub use end_to_end_encryption::MultiPartyConfig;

pub use end_to_end_encryption::ZeroKnowledgeProof;

pub use gpu_acceleration::AggregationOp;

pub use gpu_acceleration::GpuBackend;

pub use gpu_acceleration::GpuBuffer;

pub use gpu_acceleration::GpuConfig;

pub use gpu_acceleration::GpuContext;

pub use gpu_acceleration::GpuProcessorConfig;

pub use gpu_acceleration::GpuStats;

pub use gpu_acceleration::GpuStreamProcessor;

pub use ml_integration::AnomalyDetectionAlgorithm;

pub use ml_integration::AnomalyDetectionConfig;

pub use ml_integration::AnomalyDetector;

pub use ml_integration::AnomalyResult;

pub use ml_integration::AnomalyStats;

pub use ml_integration::FeatureConfig;

pub use ml_integration::FeatureExtractor;

pub use ml_integration::FeatureVector;

pub use ml_integration::MLIntegrationManager;

pub use ml_integration::MLModelConfig;

pub use ml_integration::ModelMetrics;

pub use ml_integration::ModelType;

pub use ml_integration::OnlineLearningModel;

pub use ml_integration::PredictionResult;

pub use rate_limiting::QuotaCheckResult;

pub use rate_limiting::QuotaEnforcementMode;

pub use rate_limiting::QuotaLimits;

pub use rate_limiting::QuotaManager;

pub use rate_limiting::QuotaOperation;

pub use rate_limiting::RateLimitAlgorithm;

pub use rate_limiting::RateLimitConfig as AdvancedRateLimitConfig;

pub use rate_limiting::RateLimitMonitoringConfig;

pub use rate_limiting::RateLimitStats as AdvancedRateLimitStats;

pub use rate_limiting::RateLimiter as AdvancedRateLimiter;

pub use rate_limiting::RejectionStrategy;

pub use scalability::AdaptiveBuffer;

pub use scalability::AutoScaler;

pub use scalability::LoadBalancingStrategy as ScalingLoadBalancingStrategy;

pub use scalability::Node as ScalingNode;

pub use scalability::NodeHealth;

pub use scalability::Partition;

pub use scalability::PartitionManager;

pub use scalability::PartitionStrategy;

pub use scalability::ResourceLimits;

pub use scalability::ResourceUsage as ScalingResourceUsage;

pub use scalability::ScalingConfig;

pub use scalability::ScalingDirection;

pub use scalability::ScalingMode;

pub use schema_evolution::CompatibilityCheckResult;

pub use schema_evolution::CompatibilityIssue;

pub use schema_evolution::CompatibilityIssueType;

pub use schema_evolution::CompatibilityMode as SchemaCompatibilityMode;

pub use schema_evolution::DeprecationInfo;

pub use schema_evolution::EvolutionResult;

pub use schema_evolution::FieldDefinition;

pub use schema_evolution::FieldType;

pub use schema_evolution::IssueSeverity;

pub use schema_evolution::MigrationRule;

pub use schema_evolution::MigrationStrategy;

pub use schema_evolution::SchemaChange;

pub use schema_evolution::SchemaDefinition as SchemaEvolutionDefinition;

pub use schema_evolution::SchemaEvolutionManager;

pub use schema_evolution::SchemaFormat as SchemaEvolutionFormat;

pub use schema_evolution::SchemaVersion;

pub use stream_replay::EventProcessor;

pub use stream_replay::ReplayCheckpoint;

pub use stream_replay::ReplayConfig;

pub use stream_replay::ReplayFilter;

pub use stream_replay::ReplayMode;

pub use stream_replay::ReplaySpeed;

pub use stream_replay::ReplayStats;

pub use stream_replay::ReplayStatus as StreamReplayStatus;

pub use stream_replay::ReplayTransformation;

pub use stream_replay::StateSnapshot;

pub use stream_replay::StreamReplayManager;

pub use stream_replay::TransformationType;

pub use transactional_processing::IsolationLevel as TransactionalIsolationLevel;

pub use transactional_processing::LogEntryType;

pub use transactional_processing::TransactionCheckpoint;

pub use transactional_processing::TransactionLogEntry;

pub use transactional_processing::TransactionMetadata;

pub use transactional_processing::TransactionState;

pub use transactional_processing::TransactionalConfig;

pub use transactional_processing::TransactionalProcessor;

pub use transactional_processing::TransactionalStats;

pub use zero_copy::MemoryMappedBuffer;

pub use zero_copy::SharedRefBuffer;

pub use zero_copy::SimdBatchProcessor;

pub use zero_copy::SimdOperation;

pub use zero_copy::SplicedBuffer;

pub use zero_copy::ZeroCopyBuffer;

pub use zero_copy::ZeroCopyConfig;

pub use zero_copy::ZeroCopyManager;

pub use zero_copy::ZeroCopyStats;

pub use numa_processing::CpuAffinityMode;

pub use numa_processing::HugePageSize;

pub use numa_processing::MemoryBandwidthMonitor;

pub use numa_processing::MemoryInterleavePolicy;

pub use numa_processing::NodeBufferStats;

pub use numa_processing::NodeProcessorStats;

pub use numa_processing::NumaAllocationStrategy;

pub use numa_processing::NumaBuffer;

pub use numa_processing::NumaBufferPool;

pub use numa_processing::NumaBufferPoolConfig;

pub use numa_processing::NumaBufferPoolStats;

pub use numa_processing::NumaConfig;

pub use numa_processing::NumaNode;

pub use numa_processing::NumaProcessorStats;

pub use numa_processing::NumaStreamProcessor;

pub use numa_processing::NumaThreadPool;

pub use numa_processing::NumaThreadPoolStats;

pub use numa_processing::NumaTopology;

pub use numa_processing::NumaWorker;

pub use numa_processing::NumaWorkerStats;

pub use numa_processing::WorkerDistributionStrategy;

pub use out_of_order::EmitStrategy;

pub use out_of_order::GapFillingStrategy;

pub use out_of_order::LateEventStrategy;

pub use out_of_order::OrderedEvent;

pub use out_of_order::OutOfOrderConfig;

pub use out_of_order::OutOfOrderHandler;

pub use out_of_order::OutOfOrderHandlerBuilder;

pub use out_of_order::OutOfOrderStats;

pub use out_of_order::SequenceTracker;

pub use out_of_order::Watermark;

pub use performance_profiler::HistogramStats;

pub use performance_profiler::LatencyHistogram;

pub use performance_profiler::OperationTimer;

pub use performance_profiler::PerformanceProfiler;

pub use performance_profiler::PerformanceReport;

pub use performance_profiler::PerformanceSample;

pub use performance_profiler::PerformanceWarning;

pub use performance_profiler::ProfilerBuilder;

pub use performance_profiler::ProfilerConfig;

pub use performance_profiler::ProfilerStats;

pub use performance_profiler::Recommendation;

pub use performance_profiler::RecommendationCategory;

pub use performance_profiler::RecommendationEffort;

pub use performance_profiler::RecommendationImpact;

pub use performance_profiler::Span;

pub use performance_profiler::WarningSeverity;

pub use performance_profiler::WarningThresholds;

pub use performance_profiler::WarningType;

pub use stream_sql::AggregateFunction;

pub use stream_sql::BinaryOperator;

pub use stream_sql::ColumnDefinition;

pub use stream_sql::CreateStreamStatement;

pub use stream_sql::DataType;

pub use stream_sql::Expression;

pub use stream_sql::FromClause;

pub use stream_sql::JoinType;

pub use stream_sql::Lexer;

pub use stream_sql::OrderByItem;

pub use stream_sql::Parser;

pub use stream_sql::QueryResult as StreamSqlQueryResult;

pub use stream_sql::QueryType;

pub use stream_sql::ResultRow;

pub use stream_sql::SelectItem;

pub use stream_sql::SelectStatement;

pub use stream_sql::SqlValue;

pub use stream_sql::StreamMetadata;

pub use stream_sql::StreamSqlConfig;

pub use stream_sql::StreamSqlEngine;

pub use stream_sql::StreamSqlStats;

pub use stream_sql::Token;

pub use stream_sql::UnaryOperator;

pub use stream_sql::WindowSpec;

pub use stream_sql::WindowType as SqlWindowType;

pub use testing_framework::Assertion;

pub use testing_framework::AssertionType;

pub use testing_framework::CapturedEvent;

pub use testing_framework::EventGenerator;

pub use testing_framework::EventMatcher;

pub use testing_framework::GeneratorConfig;

pub use testing_framework::GeneratorType;

pub use testing_framework::MockClock;

pub use testing_framework::PerformanceMetric;

pub use testing_framework::TestFixture;

pub use testing_framework::TestHarness;

pub use testing_framework::TestHarnessBuilder;

pub use testing_framework::TestHarnessConfig;

pub use testing_framework::TestMetrics;

pub use testing_framework::TestReport;

pub use testing_framework::TestStatus;

pub use anomaly_detection::Anomaly;

pub use anomaly_detection::AnomalyAlert;

pub use anomaly_detection::AnomalyConfig;

pub use anomaly_detection::AnomalyDetector as AdaptiveAnomalyDetector;

pub use anomaly_detection::AnomalySeverity;

pub use anomaly_detection::AnomalyStats as AdaptiveAnomalyStats;

pub use anomaly_detection::DetectorType;

pub use anomaly_detection::MultiDimensionalDetector;

pub use migration_tools::APIMapping;

pub use migration_tools::ConceptMapping;

pub use migration_tools::GeneratedFile;

pub use migration_tools::GeneratedFileType;

pub use migration_tools::ManualReviewItem;

pub use migration_tools::MigrationConfig;

pub use migration_tools::MigrationError;

pub use migration_tools::MigrationReport;

pub use migration_tools::MigrationSuggestion;

pub use migration_tools::MigrationTool;

pub use migration_tools::MigrationWarning;

pub use migration_tools::QuickStart;

pub use migration_tools::ReviewPriority;

pub use migration_tools::SourcePlatform;

pub use migration_tools::SuggestionCategory;

pub use online_learning::ABTestConfig;

pub use online_learning::ABTestResult;

pub use online_learning::DriftDetection;

pub use online_learning::ModelCheckpoint;

pub use online_learning::ModelMetrics as OnlineModelMetrics;

pub use online_learning::ModelType as OnlineModelType;

pub use online_learning::OnlineLearningConfig;

pub use online_learning::OnlineLearningModel as StreamOnlineLearningModel;

pub use online_learning::OnlineLearningStats;

pub use online_learning::Prediction;

pub use online_learning::Sample;

pub use online_learning::StreamFeatureExtractor;

pub use stream_versioning::Branch;

pub use stream_versioning::BranchId;

pub use stream_versioning::Change;

pub use stream_versioning::ChangeType;

pub use stream_versioning::Changeset;

pub use stream_versioning::Snapshot;

pub use stream_versioning::StreamVersioning;

pub use stream_versioning::TimeTravelQuery;

pub use stream_versioning::TimeTravelTarget;

pub use stream_versioning::VersionDiff;

pub use stream_versioning::VersionId;

pub use stream_versioning::VersionMetadata;

pub use stream_versioning::VersionedEvent;

pub use stream_versioning::VersioningConfig;

pub use stream_versioning::VersioningStats;

pub use automl_stream::Algorithm;

pub use automl_stream::AutoML;

pub use automl_stream::AutoMLConfig;

pub use automl_stream::AutoMLStats;

pub use automl_stream::HyperParameters;

pub use automl_stream::ModelPerformance;

pub use automl_stream::TaskType;

pub use automl_stream::TrainedModel;

pub use feature_engineering::Feature;

pub use feature_engineering::FeatureExtractionConfig;

pub use feature_engineering::FeatureMetadata;

pub use feature_engineering::FeaturePipeline;

pub use feature_engineering::FeatureSet;

pub use feature_engineering::FeatureStore;

pub use feature_engineering::FeatureTransform;

pub use feature_engineering::FeatureValue;

pub use feature_engineering::ImputationStrategy;

pub use feature_engineering::PipelineStats;

pub use neural_architecture_search::ActivationType;

pub use neural_architecture_search::Architecture;

pub use neural_architecture_search::ArchitecturePerformance;

pub use neural_architecture_search::LayerType;

pub use neural_architecture_search::NASConfig;

pub use neural_architecture_search::NASStats;

pub use neural_architecture_search::ObjectiveWeights;

pub use neural_architecture_search::SearchSpace;

pub use neural_architecture_search::SearchStrategy;

pub use neural_architecture_search::NAS;

pub use predictive_analytics::AccuracyMetrics;

pub use predictive_analytics::ForecastAlgorithm;

pub use predictive_analytics::ForecastResult;

pub use predictive_analytics::ForecastingConfig;

pub use predictive_analytics::PredictiveAnalytics;

pub use predictive_analytics::PredictiveStats;

pub use predictive_analytics::SeasonalityType;

pub use predictive_analytics::TrendDirection;

pub use reinforcement_learning::Action;

pub use reinforcement_learning::Experience;

pub use reinforcement_learning::RLAgent;

pub use reinforcement_learning::RLAlgorithm;

pub use reinforcement_learning::RLConfig;

pub use reinforcement_learning::RLStats;

pub use reinforcement_learning::State as RLState;

pub use utils::create_dev_stream;

pub use utils::create_prod_stream;

pub use utils::BatchProcessor;

pub use utils::EventFilter;

pub use utils::EventSampler;

pub use utils::SimpleRateLimiter;

pub use utils::StreamMultiplexer;

pub use utils::StreamStats;

pub use advanced_scirs2_optimization::AdvancedOptimizerConfig;

pub use advanced_scirs2_optimization::AdvancedStreamOptimizer;

pub use advanced_scirs2_optimization::MovingStats;

pub use advanced_scirs2_optimization::OptimizerMetrics;

pub use cdc_processor::CdcConfig;

pub use cdc_processor::CdcConnector;

pub use cdc_processor::CdcEvent;

pub use cdc_processor::CdcEventBuilder;

pub use cdc_processor::CdcMetrics;

pub use cdc_processor::CdcOperation;

pub use cdc_processor::CdcProcessor;

pub use cdc_processor::CdcSource;

pub use adaptive_load_shedding::DropStrategy;

pub use adaptive_load_shedding::LoadMetrics;

pub use adaptive_load_shedding::LoadSheddingConfig;

pub use adaptive_load_shedding::LoadSheddingManager;

pub use adaptive_load_shedding::LoadSheddingStats;

pub use stream_fusion::FusableChain;

pub use stream_fusion::FusedOperation;

pub use stream_fusion::FusedType;

pub use stream_fusion::FusionAnalysis;

pub use stream_fusion::FusionConfig;

pub use stream_fusion::FusionOptimizer;

pub use stream_fusion::FusionStats;

pub use stream_fusion::Operation;

pub use cep_engine::CepAggregationFunction;

pub use cep_engine::CepConfig;

pub use cep_engine::CepEngine;

pub use cep_engine::CepMetrics;

pub use cep_engine::CepStatistics;

pub use cep_engine::CompleteMatch;

pub use cep_engine::CorrelationFunction;

pub use cep_engine::CorrelationResult;

pub use cep_engine::CorrelationStats;

pub use cep_engine::DetectedPattern;

pub use cep_engine::DetectionAlgorithm;

pub use cep_engine::DetectionStats;

pub use cep_engine::EnrichmentData;

pub use cep_engine::EnrichmentService;

pub use cep_engine::EnrichmentSource;

pub use cep_engine::EnrichmentSourceType;

pub use cep_engine::EnrichmentStats;

pub use cep_engine::EventBuffer;

pub use cep_engine::EventCorrelator;

pub use cep_engine::EventPattern;

pub use cep_engine::FieldPredicate;

pub use cep_engine::PartialMatch;

pub use cep_engine::PatternDetector;

pub use cep_engine::ProcessingRule;

pub use cep_engine::RuleAction;

pub use cep_engine::RuleCondition;

pub use cep_engine::RuleEngine;

pub use cep_engine::RuleExecutionStats;

pub use cep_engine::State;

pub use cep_engine::StateMachine;

pub use cep_engine::TemporalOperator;

pub use cep_engine::TimestampedEvent;

pub use data_quality::AlertCondition as QualityAlertCondition;

pub use data_quality::AlertManager as QualityAlertManager;

pub use data_quality::AlertRule as QualityAlertRule;

pub use data_quality::AlertSeverity as QualityAlertSeverity;

pub use data_quality::AlertStats as QualityAlertStats;

pub use data_quality::AlertType as QualityAlertType;

pub use data_quality::AuditAction;

pub use data_quality::AuditEntry;

pub use data_quality::AuditStats;

pub use data_quality::AuditTrail;

pub use data_quality::CleansingRule;

pub use data_quality::CleansingStats;

pub use data_quality::CorrectionType;

pub use data_quality::DataCleanser;

pub use data_quality::DataCorrection;

pub use data_quality::DataProfiler;

pub use data_quality::DataQualityValidator;

pub use data_quality::DuplicateDetector;

pub use data_quality::DuplicateStats;

pub use data_quality::FailureSeverity;

pub use data_quality::FieldProfile;

pub use data_quality::OutlierMethod;

pub use data_quality::ProfileStats;

pub use data_quality::ProfiledEvent;

pub use data_quality::QualityAlert;

pub use data_quality::QualityConfig;

pub use data_quality::QualityDimension;

pub use data_quality::QualityMetrics;

pub use data_quality::QualityReport;

pub use data_quality::QualityScorer;

pub use data_quality::ScoringStats;

pub use data_quality::ValidationFailure;

pub use data_quality::ValidationResult as QualityValidationResult;

pub use data_quality::ValidationRule;

pub use advanced_sampling::AdvancedSamplingManager;

pub use advanced_sampling::BloomFilter;

pub use advanced_sampling::BloomFilterStats;

pub use advanced_sampling::CountMinSketch;

pub use advanced_sampling::CountMinSketchStats;

pub use advanced_sampling::HyperLogLog;

pub use advanced_sampling::HyperLogLogStats;

pub use advanced_sampling::ReservoirSampler;

pub use advanced_sampling::ReservoirStats;

pub use advanced_sampling::SamplingConfig;

pub use advanced_sampling::SamplingManagerStats;

pub use advanced_sampling::StratifiedSampler;

pub use advanced_sampling::StratifiedStats;

pub use advanced_sampling::TDigest;

pub use advanced_sampling::TDigestStats;

Modules

adaptive_load_shedding

Adaptive Load Shedding

advanced_sampling

Advanced Sampling Techniques for Stream Processing

advanced_scirs2_optimization

Advanced SciRS2-Powered Stream Optimization

anomaly_detection

Anomaly Detection with Adaptive Thresholds

automl_stream

AutoML for Stream Processing

backend

Stream Backend Abstraction

backend_optimizer

Backend Optimization and Selection

backpressure

Backpressure and Flow Control

biological_computing

Biological Computing Integration for RDF Streaming

bridge

Message Queue Bridge Module

cdc_processor

Change Data Capture (CDC) Stream Processor

cep_engine

Complex Event Processing (CEP) Engine

circuit_breaker

Advanced Circuit Breaker Implementation

config

Advanced Configuration Management

connection_pool

Advanced Connection Pool Implementation

consciousness_streaming

Consciousness-Inspired Streaming Engine

consumer

Stream Consumer

cqels

CQELS (Continuous Query Evaluation over Linked Streams)

cqrs

CQRS (Command Query Responsibility Segregation) Implementation

csparql

C-SPARQL (Continuous SPARQL) Extensions

custom_serialization

Custom Serialization Formats

data_quality

Stream Data Quality & Validation Framework

delta

SPARQL Update Delta Support

diagnostics

Stream Diagnostics Tools

disaster_recovery

Disaster Recovery and Backup System

dlq

Dead Letter Queue (DLQ)

end_to_end_encryption

End-to-End Encryption (E2EE)

enterprise_audit

Enterprise Audit Logging System

enterprise_monitoring

Enterprise Monitoring and SLA Tracking

error

Stream Error Types

event

Stream Events

event_sourcing

Event Sourcing Framework

failover

Failover mechanisms for connection pool

feature_engineering

Feature Engineering Pipelines for Stream Processing

gpu_acceleration

GPU Acceleration for Stream Analytics

graphql_bridge

GraphQL Subscription Bridge

graphql_subscriptions

Enhanced GraphQL Subscription System

health_monitor

Connection health monitoring and tracking

join

Stream Join Operations

migration_tools

Migration Tools from Other Streaming Platforms

ml_integration

Machine Learning Integration for Stream Processing

monitoring

Monitoring and Observability

multi_region_replication

Multi-Region Replication

multi_tenancy

Multi-Tenancy Support

neural_architecture_search

Neural Architecture Search for Stream Operators

numa_processing

NUMA-Aware Processing for High-Performance Streaming

observability

Advanced Observability and Telemetry for OxiRS Stream

online_learning

Online Learning for Streaming Data

out_of_order

Out-of-Order Event Handling Optimization

patch

RDF Patch Support

performance_optimizer

Advanced Performance Optimizer

performance_profiler

Performance Profiler and Optimizer

performance_utils

Advanced Performance Utilities for OxiRS Stream

predictive_analytics

Predictive Analytics and Forecasting for Stream Processing

processing

Advanced Event Processing Module

producer

Stream Producer

quantum_communication

Quantum Communication Module

quantum_processing

Quantum processing module - modular quantum computing integration for RDF streams

quantum_streaming

Quantum streaming module components

rate_limiting

Rate Limiting and Quota Management

reconnect

Automatic reconnection logic with exponential backoff

reinforcement_learning

Reinforcement Learning for Stream Processing Optimization

reliability

Reliability Module

rsp

RDF Stream Processing (RSP) Module

scalability

Scalability Features for Stream Processing

schema_evolution

Dynamic Schema Evolution and Migration

schema_registry

Schema Registry for Stream Events

security

Advanced Security Framework

serialization

Event Serialization Module

sparql_streaming

SPARQL Streaming Module

state

Stateful Stream Processing

store_integration

OxiRS Store Integration

stream_fusion

Stream Fusion Optimizer

stream_replay

Stream Replay and Reprocessing

stream_sql

Stream SQL - SQL-like Query Language for Streams

stream_versioning

Stream Versioning and Time-Travel Queries

temporal_join

Temporal Joins for Stream Processing

testing_framework

Stream Testing Framework

time_travel

Time-Travel Query System

tls_security

Enhanced TLS/SSL Security Module

transactional_processing

Transactional Processing with Exactly-Once Semantics

types

Stream Types

utils

Stream Utilities

wasm_edge_computing

WebAssembly Edge Computing Module

webhook

Webhook Integration Module

zero_copy

Zero-Copy Optimizations

Macros

assert_stream_output

Macros for common assertions

Structs

AwsCredentials

AWS credentials configuration

CircuitBreakerConfig

Circuit breaker configuration

ConsumerStats

Consumer statistics for monitoring

MonitoringConfig

Monitoring configuration

NatsJetStreamConfig

NATS JetStream configuration

ProducerStats

Producer statistics for monitoring

PulsarAuthConfig

Pulsar authentication configuration

RdfPatch

RDF patch for atomic updates with full protocol support

RetryConfig

Retry configuration

SaslConfig

SASL authentication configuration

SecurityConfig

Security configuration

Stream

Unified Stream interface that combines producer and consumer functionality

StreamConfig

Enhanced stream configuration with advanced features

StreamConsumer

Enhanced stream consumer for receiving RDF changes with backend support

StreamPerformanceConfig

Performance tuning configuration

StreamProducer

Enhanced stream producer for publishing RDF changes with backend support

Enums

CompressionType

Compression types supported

PatchOperation

RDF patch operations with full protocol support

PulsarAuthMethod

Pulsar authentication methods

SaslMechanism

SASL authentication mechanisms

StreamBackendType

Enhanced streaming backend options

Functions

clear_memory_events

Clear the global memory storage (for testing)

get_memory_events