List of all items
Structs
- application::commands::ActivateSessionCommand
- application::commands::AdjustPriorityThresholdCommand
- application::commands::BatchGenerateFramesCommand
- application::commands::CancelStreamCommand
- application::commands::CloseSessionCommand
- application::commands::CompleteStreamCommand
- application::commands::CreateSessionCommand
- application::commands::CreateStreamCommand
- application::commands::FailStreamCommand
- application::commands::GenerateFramesCommand
- application::commands::StartStreamCommand
- application::commands::UpdateStreamConfigCommand
- application::dto::event_dto::EventIdDto
- application::dto::event_dto::PerformanceMetricsDto
- application::dto::json_path_dto::JsonPathDto
- application::dto::priority_dto::PriorityDto
- application::dto::session_id_dto::SessionIdDto
- application::dto::stream_id_dto::StreamIdDto
- application::handlers::command_handlers::CommandValidator
- application::handlers::command_handlers::SessionCommandHandler
- application::handlers::query_handlers::EventQueryHandler
- application::handlers::query_handlers::SessionQueryHandler
- application::handlers::query_handlers::StreamQueryHandler
- application::handlers::query_handlers::SystemQueryHandler
- application::queries::EventsResponse
- application::queries::FramesResponse
- application::queries::GetActiveSessionsQuery
- application::queries::GetSessionEventsQuery
- application::queries::GetSessionHealthQuery
- application::queries::GetSessionQuery
- application::queries::GetSessionStatsQuery
- application::queries::GetStreamEventsQuery
- application::queries::GetStreamFramesQuery
- application::queries::GetStreamQuery
- application::queries::GetStreamsForSessionQuery
- application::queries::GetSystemStatsQuery
- application::queries::HealthResponse
- application::queries::SearchSessionsQuery
- application::queries::SessionFilters
- application::queries::SessionResponse
- application::queries::SessionsResponse
- application::queries::StreamResponse
- application::queries::StreamsResponse
- application::queries::SystemStatsResponse
- application::services::event_service::EventService
- application::services::optimization_service::OptimizationMetrics
- application::services::optimization_service::OptimizationService
- application::services::optimization_service::OptimizationStrategy
- application::services::optimization_service::StrategyAdjustmentRecommendation
- application::services::optimization_service::UseCaseOptimizationResult
- application::services::performance_analysis_service::AlertingThresholds
- application::services::performance_analysis_service::AnalysisConfig
- application::services::performance_analysis_service::BatchSizeRecommendation
- application::services::performance_analysis_service::ErrorAnalysis
- application::services::performance_analysis_service::FrameDistributionAnalysis
- application::services::performance_analysis_service::LatencyAnalysis
- application::services::performance_analysis_service::OptimizationRecommendation
- application::services::performance_analysis_service::PerformanceAnalysisReport
- application::services::performance_analysis_service::PerformanceAnalysisService
- application::services::performance_analysis_service::PerformanceIssue
- application::services::performance_analysis_service::ResourceAnalysis
- application::services::performance_analysis_service::ThroughputAnalysis
- application::services::prioritization_service::CustomPriorityRules
- application::services::prioritization_service::PerformanceContext
- application::services::prioritization_service::PrioritizationService
- application::services::prioritization_service::PriorityAdjustment
- application::services::prioritization_service::PriorityCalculationResult
- application::services::prioritization_service::StreamingMetrics
- application::services::session_service::SessionCompletionResult
- application::services::session_service::SessionService
- application::services::session_service::SessionShutdownResult
- application::services::session_service::SessionWithHealth
- application::services::session_service::SessionsOverview
- application::services::stream_orchestrator::AdaptiveFrameResult
- application::services::stream_orchestrator::CrossStreamFrameResult
- application::services::stream_orchestrator::PriorityAdjustment
- application::services::stream_orchestrator::PriorityAdjustmentResult
- application::services::stream_orchestrator::StreamOrchestrator
- application::services::stream_orchestrator::StreamOrchestratorFactory
- application::services::streaming_service::AdaptiveFrameResult
- application::services::streaming_service::CrossStreamFrameResult
- application::services::streaming_service::FrameDistribution
- application::services::streaming_service::OptimizationMetrics
- application::services::streaming_service::OptimizationStrategy
- application::services::streaming_service::PerformanceContext
- application::services::streaming_service::PriorityAdjustment
- application::services::streaming_service::PriorityAdjustmentResult
- application::services::streaming_service::StreamingMetrics
- application::services::streaming_service::StreamingService
- application::services::streaming_service::UseCaseOptimizationResult
- compression::CompressedData
- compression::CompressionConfig
- compression::SchemaAnalyzer
- compression::SchemaCompressor
- config::ParserConfig
- config::PjsConfig
- config::SimdConfig
- config::StreamingConfig
- domain::aggregates::stream_session::SessionConfig
- domain::aggregates::stream_session::SessionHealth
- domain::aggregates::stream_session::SessionStats
- domain::aggregates::stream_session::StreamSession
- domain::entities::frame::Frame
- domain::entities::frame::FramePatch
- domain::entities::stream::Stream
- domain::entities::stream::StreamConfig
- domain::entities::stream::StreamStats
- domain::events::EventId
- domain::events::InMemoryEventStore
- domain::events::PerformanceMetrics
- domain::events::PriorityDistribution
- domain::events::PriorityPercentages
- domain::ports::SystemTimeProvider
- domain::ports::repositories::CacheStatistics
- domain::ports::repositories::FrameQueryResult
- domain::ports::repositories::Pagination
- domain::ports::repositories::SessionHealthSnapshot
- domain::ports::repositories::SessionQueryCriteria
- domain::ports::repositories::SessionQueryResult
- domain::ports::repositories::StreamFilter
- domain::ports::repositories::StreamMetadata
- domain::ports::repositories::StreamStatistics
- domain::ports::writer::ConnectionMetrics
- domain::ports::writer::WriterConfig
- domain::ports::writer::WriterMetrics
- domain::services::connection_manager::ConnectionManager
- domain::services::connection_manager::ConnectionState
- domain::services::connection_manager::ConnectionStatistics
- domain::services::priority_service::PriorityRulesSummary
- domain::services::priority_service::PriorityService
- domain::services::priority_service::UsageStatistics
- domain::services::streaming_orchestrator::MockEventPublisher
- domain::services::streaming_orchestrator::MockEventRepository
- domain::services::streaming_orchestrator::MockMetricsCollector
- domain::services::streaming_orchestrator::StreamingOrchestrator
- domain::services::streaming_orchestrator::StreamingOrchestratorFactory
- domain::services::streaming_orchestrator::StreamingPerformanceMetrics
- domain::services::streaming_orchestrator::StreamingStats
- domain::value_objects::JsonPath
- domain::value_objects::Priority
- domain::value_objects::SessionId
- domain::value_objects::StreamId
- frame::Frame
- frame::FrameFlags
- frame::FrameHeader
- infrastructure::adapters::event_publisher::CompositeEventPublisher
- infrastructure::adapters::event_publisher::InMemoryEventPublisher
- infrastructure::adapters::event_publisher::StoredEvent
- infrastructure::adapters::json_adapter::JsonAdapter
- infrastructure::adapters::memory_repository::ConcurrentMemoryRepository
- infrastructure::adapters::memory_repository::InMemoryStreamRepository
- infrastructure::adapters::memory_repository::InMemoryStreamStore
- infrastructure::adapters::memory_repository::RepositoryStatistics
- infrastructure::adapters::metrics_collector::CompositeMetricsCollector
- infrastructure::adapters::metrics_collector::InMemoryMetricsCollector
- infrastructure::adapters::metrics_collector::PerformanceMetrics
- infrastructure::adapters::metrics_collector::SessionMetrics
- infrastructure::adapters::metrics_collector::StreamMetrics
- infrastructure::adapters::metrics_collector::TimestampedMetrics
- infrastructure::adapters::repository_adapters::InMemoryCache
- infrastructure::adapters::repository_adapters::InMemoryFrameRepository
- infrastructure::adapters::repository_adapters::InMemorySessionTransaction
- infrastructure::adapters::repository_adapters::InMemoryStreamSessionRepository
- infrastructure::adapters::tokio_writer::TokioConnectionMonitor
- infrastructure::adapters::tokio_writer::TokioFrameWriter
- infrastructure::adapters::tokio_writer::TokioStreamWriter
- infrastructure::adapters::tokio_writer::TokioWriterFactory
- infrastructure::integration::object_pool::CleaningPooledObject
- infrastructure::integration::object_pool::GlobalPoolStats
- infrastructure::integration::object_pool::GlobalPools
- infrastructure::integration::object_pool::ObjectPool
- infrastructure::integration::object_pool::PoolStats
- infrastructure::integration::object_pool::PooledObject
- infrastructure::integration::object_pool::pooled_builders::PooledResponseBuilder
- infrastructure::integration::object_pool::pooled_builders::PooledSSEBuilder
- infrastructure::integration::simd_acceleration::SerializationStats
- infrastructure::integration::simd_acceleration::SimdConfig
- infrastructure::integration::simd_acceleration::SimdFrameSerializer
- infrastructure::integration::simd_acceleration::SimdJsonProcessor
- infrastructure::integration::simd_acceleration::SimdStreamBuffer
- infrastructure::integration::simd_acceleration::SimdStreamProcessor
- infrastructure::integration::streaming_adapter::UniversalRequest
- infrastructure::integration::streaming_adapter::UniversalResponse
- infrastructure::integration::universal_adapter::AdapterConfig
- infrastructure::integration::universal_adapter::UniversalAdapter
- infrastructure::integration::universal_adapter::UniversalAdapterBuilder
- infrastructure::repositories::memory::MemoryRepository
- infrastructure::services::timeout_monitor::TimeoutMonitor
- parser::Parser
- parser::buffer_pool::AlignedBuffer
- parser::buffer_pool::BufferPool
- parser::buffer_pool::CleanupStats
- parser::buffer_pool::PoolConfig
- parser::buffer_pool::PoolStats
- parser::buffer_pool::PooledBuffer
- parser::scanner::Range
- parser::scanner::ScanResult
- parser::scanner::StringLocation
- parser::simd::ArrayStats
- parser::simd::KeyScanResult
- parser::simd::SimdClassifier
- parser::simd::SimdNumericOps
- parser::simd_zero_copy::SimdParseResult
- parser::simd_zero_copy::SimdParsingStats
- parser::simd_zero_copy::SimdZeroCopyConfig
- parser::simd_zero_copy::SimdZeroCopyParser
- parser::simple::ParseConfig
- parser::simple::ParseStats
- parser::simple::SimpleParser
- parser::sonic::LazyFrame
- parser::sonic::SonicConfig
- parser::sonic::SonicParser
- parser::sonic::SonicStats
- parser::value::FieldRange
- parser::value::LazyArray
- parser::value::LazyArrayIter
- parser::value::LazyObject
- parser::zero_copy::IncrementalParser
- parser::zero_copy::MemoryUsage
- parser::zero_copy::ZeroCopyParser
- semantic::ColumnMeta
- semantic::ProcessingHints
- semantic::SemanticMeta
- stream::StreamConfig
- stream::StreamFrame
- stream::StreamProcessor
- stream::StreamStats
- stream::compression_integration::CompressedFrame
- stream::compression_integration::CompressionStats
- stream::compression_integration::DecompressionMetadata
- stream::compression_integration::DecompressionStats
- stream::compression_integration::StreamingCompressor
- stream::compression_integration::StreamingDecompressor
- stream::priority::JsonPatch
- stream::priority::JsonPath
- stream::priority::PriorityStreamer
- stream::priority::StreamerConfig
- stream::priority::StreamingPlan
- stream::reconstruction::JsonReconstructor
- stream::reconstruction::ReconstructionStats
Enums
- application::ApplicationError
- application::dto::event_dto::DomainEventDto
- application::queries::SessionSortField
- application::queries::SortOrder
- application::services::optimization_service::AdjustmentType
- application::services::optimization_service::StreamingUseCase
- application::services::performance_analysis_service::ErrorSeverity
- application::services::performance_analysis_service::ImplementationEffort
- application::services::performance_analysis_service::IssueSeverity
- application::services::performance_analysis_service::RecommendationPriority
- application::services::prioritization_service::PrioritizationStrategy
- application::services::streaming_service::StreamingUseCase
- application::shared::AdjustmentUrgency
- compression::CompressionStrategy
- domain::DomainError
- domain::aggregates::stream_session::SessionState
- domain::entities::frame::FrameType
- domain::entities::frame::PatchOperation
- domain::entities::stream::StreamState
- domain::events::DomainEvent
- domain::ports::repositories::SortOrder
- domain::ports::repositories::StreamStatus
- domain::ports::writer::BackpressureStrategy
- domain::ports::writer::ConnectionState
- domain::services::connection_manager::ConnectionEvent
- domain::value_objects::JsonData
- domain::value_objects::PathSegment
- error::Error
- infrastructure::integration::streaming_adapter::IntegrationError
- infrastructure::integration::streaming_adapter::ResponseBody
- infrastructure::integration::streaming_adapter::StreamingFormat
- parser::ValueType
- parser::buffer_pool::BufferSize
- parser::simd::ValueClass
- parser::value::JsonValue
- parser::zero_copy::LazyJsonValue
- semantic::AccessPattern
- semantic::ColumnType
- semantic::CompressionHint
- semantic::NumericDType
- semantic::ProcessingStrategy
- semantic::SemanticType
- stream::ProcessResult
- stream::priority::PatchOperation
- stream::priority::PathSegment
- stream::priority::PriorityStreamFrame
- stream::reconstruction::ProcessResult
Traits
- application::dto::priority_dto::FromDto
- application::dto::priority_dto::ToDto
- application::handlers::CommandHandler
- application::handlers::QueryHandler
- domain::events::EventStore
- domain::events::EventSubscriber
- domain::ports::EventPublisher
- domain::ports::FrameSink
- domain::ports::FrameSource
- domain::ports::MetricsCollector
- domain::ports::StreamRepository
- domain::ports::StreamStore
- domain::ports::TimeProvider
- domain::ports::repositories::CacheExtensions
- domain::ports::repositories::CacheRepository
- domain::ports::repositories::EventRepository
- domain::ports::repositories::FrameRepository
- domain::ports::repositories::SessionTransaction
- domain::ports::repositories::StreamDataRepository
- domain::ports::repositories::StreamSessionRepository
- domain::ports::writer::ConnectionMonitor
- domain::ports::writer::FrameWriter
- domain::ports::writer::StreamWriter
- domain::ports::writer::WriterFactory
- infrastructure::integration::streaming_adapter::StreamingAdapter
- infrastructure::integration::streaming_adapter::StreamingAdapterExt
- parser::scanner::JsonScanner
- parser::zero_copy::LazyParser
Functions
- infrastructure::integration::object_pool::get_byte_vec
- infrastructure::integration::object_pool::get_cow_hashmap
- infrastructure::integration::object_pool::get_global_pool_stats
- infrastructure::integration::object_pool::get_string_hashmap
- infrastructure::integration::object_pool::get_string_vec
- infrastructure::integration::streaming_adapter::streaming_helpers::default_auto_stream_response
- infrastructure::integration::streaming_adapter::streaming_helpers::default_error_response
- infrastructure::integration::streaming_adapter::streaming_helpers::default_health_response
- infrastructure::integration::streaming_adapter::streaming_helpers::default_json_response
- infrastructure::integration::streaming_adapter::streaming_helpers::default_middleware
- infrastructure::integration::streaming_adapter::streaming_helpers::default_sse_response
- parser::buffer_pool::global_buffer_pool
- parser::buffer_pool::initialize_global_buffer_pool