Module streaming_performance_enhanced 

Enhanced Streaming Performance Module

This module provides advanced streaming performance optimizations including:

• Adaptive buffering and batching for improved throughput
• Event compression and deduplication to reduce overhead
• Connection pooling and reuse for streaming endpoints
• Backpressure management and flow control
• Memory-efficient streaming with intelligent garbage collection

Modules

exposed

Exposed namespace of the module.

orphan

Orphan namespace of the module.

own

Own namespace of the module.

prelude

Prelude to use essentials: use my_module ::prelude :: *.

Structs

CompressedEvent

Compressed event for efficient storage and transmission

ConnectionGuard

RAII guard for connection pool connections

ConnectionPoolStats

Connection pool statistics

EventBatch

Buffered event batch for efficient processing

ProcessingStats

Processing statistics

StreamingBuffer

Enhanced streaming buffer with performance optimizations

StreamingConnectionPool

Connection pool for streaming endpoints

StreamingPerformanceConfig

Configuration for streaming performance optimizations

StreamingPerformanceStats

Statistics for streaming performance monitoring

StreamingProcessor

Enhanced streaming processor with performance optimizations

Functions

configure_streaming_processor

Configure the global streaming processor

flush_events

Flush buffered events from the global processor

get_buffer_stats

Get buffer statistics from the global processor

get_connection_stats

Get connection statistics from the global processor

get_streaming_processor

Get the global streaming processor instance

process_batch

Process multiple events using the global processor

process_event

Convenience functions for global streaming processing