List of all items

Structs

• DomainFrame
• JsonPath
• Priority
• PriorityDistribution
• PriorityPercentages
• SchemaId
• Stream
• application::commands::BatchGenerateFramesCommand
• application::commands::CloseSessionCommand
• application::commands::CompleteStreamCommand
• application::commands::CreateSessionCommand
• application::commands::CreateStreamCommand
• application::commands::GenerateFramesCommand
• application::commands::StartStreamCommand
• application::dto::id_dto::IdDto
• application::dto::priority_dto::PriorityDto
• application::dto::schema_dto::SchemaMetadataDto
• application::dto::schema_dto::SchemaRegistrationDto
• application::dto::schema_dto::ValidationErrorDto
• application::dto::schema_dto::ValidationRequestDto
• application::dto::schema_dto::ValidationResultDto
• application::handlers::command_handlers::CommandValidator
• application::handlers::command_handlers::SessionCommandHandler
• application::handlers::query_handlers::SessionQueryHandler
• application::handlers::query_handlers::StreamQueryHandler
• application::handlers::query_handlers::SystemQueryHandler
• application::queries::FramesResponse
• application::queries::GetActiveSessionsQuery
• application::queries::GetSessionHealthQuery
• application::queries::GetSessionQuery
• application::queries::GetSessionStatsQuery
• 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::SessionStatsResponse
• application::queries::SessionsResponse
• application::queries::StreamResponse
• application::queries::StreamsResponse
• application::queries::SystemStatsResponse
• compression::CompressedData
• compression::CompressionConfig
• compression::SchemaAnalyzer
• compression::SchemaCompressor
• compression::secure::DecompressionContextStats
• compression::secure::SecureCompressedData
• compression::secure::SecureCompressor
• compression::secure::SecureDecompressionContext
• compression::zstd::ZstdDictCompressor
• compression::zstd::ZstdDictionary
• config::ParserConfig
• config::PjsConfig
• config::SimdConfig
• config::StreamingConfig
• config::security::BufferLimits
• config::security::JsonLimits
• config::security::NetworkLimits
• config::security::RateLimitingConfig
• config::security::SecurityConfig
• config::security::SessionLimits
• domain::Frame
• domain::Id
• domain::JsonPath
• domain::Priority
• domain::SchemaId
• domain::SessionMarker
• domain::Stream
• domain::StreamMarker
• domain::aggregates::stream_session::SessionConfig
• domain::aggregates::stream_session::SessionHealth
• domain::aggregates::stream_session::SessionStats
• domain::aggregates::stream_session::StreamSession
• domain::entities::Frame
• domain::entities::Stream
• 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::PriorityDistribution
• domain::ports::SystemTimeProvider
• domain::ports::dictionary_store::NoopDictionaryStore
• domain::ports::gat::FrameStorePage
• domain::ports::gat::PriorityDistribution
• domain::ports::repositories::CacheStatistics
• domain::ports::repositories::FrameQueryResult
• domain::ports::repositories::Pagination
• domain::ports::repositories::PriorityDistribution
• 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::gat_orchestrator::GatOrchestratorFactory
• domain::services::gat_orchestrator::GatStreamingOrchestrator
• domain::services::gat_orchestrator::HealthStatus
• domain::services::gat_orchestrator::OrchestratorConfig
• domain::services::gat_orchestrator::StreamingStats
• domain::services::validation_service::ValidationService
• domain::value_objects::DepthGuard
• domain::value_objects::Id
• domain::value_objects::JsonPath
• domain::value_objects::Priority
• domain::value_objects::SchemaId
• domain::value_objects::SessionMarker
• domain::value_objects::StreamMarker
• infrastructure::adapters::event_publisher::InMemoryEventPublisher
• infrastructure::adapters::event_publisher::StoredEvent
• infrastructure::adapters::frame_store::InMemoryFrameStore
• infrastructure::adapters::gat_memory_repository::GatInMemoryStreamRepository
• infrastructure::adapters::gat_memory_repository::GatInMemoryStreamStore
• infrastructure::adapters::generic_store::InMemoryStore
• 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::bounded_channel::BudgetPermit
• infrastructure::bounded_channel::ByteBoundedSender
• infrastructure::bounded_channel::Envelope
• infrastructure::bounded_channel::SendError
• infrastructure::http::auth::ApiKeyAuthLayer
• infrastructure::http::auth::ApiKeyAuthService
• infrastructure::http::auth::ApiKeyConfig
• infrastructure::http::axum_adapter::CreateSessionRequest
• infrastructure::http::axum_adapter::CreateSessionResponse
• infrastructure::http::axum_adapter::FrameQueryParams
• infrastructure::http::axum_adapter::GenerateFramesRequest
• infrastructure::http::axum_adapter::GenerateFramesResponse
• infrastructure::http::axum_adapter::HttpServerConfig
• infrastructure::http::axum_adapter::PaginationParams
• infrastructure::http::axum_adapter::PjsAppState
• infrastructure::http::axum_adapter::SearchSessionsParams
• infrastructure::http::axum_adapter::SessionHealthResponse
• infrastructure::http::axum_adapter::StartStreamRequest
• infrastructure::http::axum_adapter::StreamParams
• infrastructure::http::axum_extension::HttpExtensionConfig
• infrastructure::http::axum_extension::PjsExtension
• infrastructure::http::axum_extension::PjsStreamingRequest
• infrastructure::http::axum_extension::StreamRequest
• infrastructure::http::axum_extension::StreamResponse
• infrastructure::http::middleware::CircuitBreakerMiddleware
• infrastructure::http::middleware::ContentValidationConfig
• infrastructure::http::middleware::PjsMiddleware
• infrastructure::http::middleware::PjsMiddlewareService
• infrastructure::http::middleware::RateLimitConfig
• infrastructure::http::middleware::RateLimitMiddleware
• infrastructure::http::middleware::RateLimitService
• infrastructure::http::middleware::TrustedProxyConfig
• infrastructure::http::serve::ConnectionLimits
• infrastructure::http::streaming::BatchFrameStream
• infrastructure::repositories::dictionary_store::InMemoryDictionaryStore
• infrastructure::schema_repository::SchemaRepository
• infrastructure::websocket::AdaptiveStreamController
• infrastructure::websocket::ClientMetrics
• infrastructure::websocket::StreamOptions
• infrastructure::websocket::WebSocketStreamSession
• infrastructure::websocket::client::PjsWebSocketClient
• infrastructure::websocket::client::StreamStats
• infrastructure::websocket::security::SecureWebSocketHandler
• infrastructure::websocket::server::AxumWebSocketTransport
• parser::aligned_alloc::AlignedAllocator
• 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::simd::ArrayStats
• parser::simd::KeyScanResult
• parser::simd::SimdClassifier
• parser::simd::SimdNumericOps
• parser::zero_copy::IncrementalParser
• parser::zero_copy::MemoryUsage
• parser::zero_copy::ZeroCopyParser
• prelude::DomainFrame
• prelude::JsonPath
• prelude::Priority
• prelude::PriorityDistribution
• prelude::PriorityPercentages
• prelude::SchemaId
• prelude::Stream
• security::DepthTracker
• security::SecurityValidator
• security::compression_bomb::CompressionBombConfig
• security::compression_bomb::CompressionBombDetector
• security::compression_bomb::CompressionBombProtector
• security::compression_bomb::CompressionStats
• security::rate_limit::RateLimitConfig
• security::rate_limit::RateLimitGuard
• security::rate_limit::RateLimitStats
• security::rate_limit::WebSocketRateLimiter
• 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::PriorityStreamer
• stream::priority::StreamerConfig
• stream::priority::StreamingPlan
• stream::reconstruction::JsonReconstructor
• stream::reconstruction::ReconstructionStats

Enums

• DomainError
• DomainEvent
• JsonData
• PathSegment
• Schema
• SchemaType
• SchemaValidationError
• application::ApplicationError
• application::dto::schema_dto::SchemaDefinitionDto
• application::queries::SortOrder
• application::shared::AdjustmentUrgency
• compression::CompressionStrategy
• compression::secure::ByteCodec
• compression::secure::CompressionQuality
• config::ConfigError
• domain::DomainError
• domain::DomainEvent
• domain::JsonData
• domain::PathSegment
• domain::Schema
• domain::SessionState
• domain::entities::frame::FrameType
• domain::entities::frame::PatchOperation
• domain::entities::stream::StreamState
• domain::events::DomainEvent
• domain::events::SessionState
• domain::ports::repositories::FrameSortField
• domain::ports::repositories::SessionSortField
• domain::ports::repositories::SortOrder
• domain::ports::repositories::StreamStatus
• domain::ports::writer::BackpressureStrategy
• domain::ports::writer::ConnectionState
• domain::value_objects::BackpressureSignal
• domain::value_objects::JsonData
• domain::value_objects::PathSegment
• domain::value_objects::Schema
• domain::value_objects::SchemaType
• domain::value_objects::SchemaValidationError
• error::Error
• infrastructure::bounded_channel::TrySendError
• infrastructure::http::auth::AuthConfigError
• infrastructure::http::axum_adapter::PjsError
• infrastructure::http::axum_extension::StreamExtensionError
• infrastructure::http::streaming::StreamFormat
• infrastructure::http::streaming::StreamTransportError
• infrastructure::websocket::WsMessage
• parser::ValueType
• parser::buffer_pool::BufferSize
• parser::buffer_pool::SimdType
• parser::simd::ValueClass
• parser::zero_copy::LazyJsonValue
• prelude::DomainError
• prelude::DomainEvent
• prelude::JsonData
• prelude::PathSegment
• prelude::Schema
• prelude::SchemaType
• prelude::SchemaValidationError
• security::compression_bomb::CompressionBombError
• security::rate_limit::RateLimitError
• stream::ProcessResult
• stream::priority::PatchOperation
• stream::priority::PriorityStreamFrame
• stream::reconstruction::ProcessResult

Traits

• application::handlers::CommandHandlerGat
• application::handlers::QueryHandlerGat
• domain::IdMarker
• domain::events::EventStore
• domain::events::EventSubscriber
• domain::ports::TimeProvider
• domain::ports::dictionary_store::DictionaryStore
• domain::ports::gat::CacheGat
• domain::ports::gat::ConnectionMonitorGat
• domain::ports::gat::EventPublisherGat
• domain::ports::gat::EventStoreGat
• domain::ports::gat::FrameRepositoryGat
• domain::ports::gat::FrameSinkGat
• domain::ports::gat::FrameSinkGatExt
• domain::ports::gat::FrameSourceGat
• domain::ports::gat::FrameStoreGat
• domain::ports::gat::FrameWriterGat
• domain::ports::gat::MetricsCollectorGat
• domain::ports::gat::SessionMetricsGat
• domain::ports::gat::SessionTransactionGat
• domain::ports::gat::StreamRepositoryGat
• domain::ports::gat::StreamStoreGat
• domain::ports::gat::WriterFactoryGat
• domain::ports::repositories::CacheExtensions
• domain::value_objects::IdMarker
• infrastructure::http::axum_extension::PjsResponseExt
• infrastructure::websocket::WebSocketTransport
• parser::zero_copy::LazyParser

Macros

• domain::macros::gat_port
• gat_port
• pjs_endpoint

Functions

• domain::value_objects::enter_deserialize_depth
• global_alloc::global_allocator_name
• infrastructure::bounded_channel::byte_bounded_channel
• infrastructure::http::axum_adapter::create_pjs_router
• infrastructure::http::axum_adapter::create_pjs_router_with_auth
• infrastructure::http::axum_adapter::create_pjs_router_with_config
• infrastructure::http::axum_adapter::create_pjs_router_with_rate_limit
• infrastructure::http::axum_adapter::create_pjs_router_with_rate_limit_and_auth
• infrastructure::http::axum_adapter::create_pjs_router_with_rate_limit_and_config
• infrastructure::http::handlers::dictionary::get_session_dictionary
• infrastructure::http::middleware::compression_middleware
• infrastructure::http::middleware::content_validation_middleware
• infrastructure::http::middleware::health_check_middleware
• infrastructure::http::middleware::security_middleware
• infrastructure::http::middleware::websocket_upgrade_middleware
• infrastructure::http::serve::serve_with_limits
• infrastructure::http::streaming::create_streaming_response
• infrastructure::http::streaming::create_streaming_response_with_content_type
• infrastructure::websocket::server::create_websocket_router
• parser::aligned_alloc::aligned_allocator
• parser::buffer_pool::global_buffer_pool
• parser::buffer_pool::initialize_global_buffer_pool

Type Aliases

• DomainResult
• SchemaValidationResult
• SessionId
• StreamId
• application::ApplicationResult
• application::dto::id_dto::SessionIdDto
• application::dto::id_dto::StreamIdDto
• domain::DomainResult
• domain::SessionId
• domain::StreamId
• domain::ports::dictionary_store::DictionaryFuture
• domain::ports::repositories::FramePagination
• domain::ports::repositories::SessionPagination
• domain::value_objects::SchemaValidationResult
• domain::value_objects::SessionId
• domain::value_objects::StreamId
• error::Result
• infrastructure::adapters::generic_store::SessionStore
• infrastructure::adapters::generic_store::StreamStore
• prelude::DomainResult
• prelude::SessionId
• prelude::StreamId

Constants

• compression::zstd::DEFAULT_LEVEL
• compression::zstd::MAX_DICT_SIZE
• compression::zstd::N_TRAIN
• config::security::MAX_SAFE_JSON_DEPTH
• domain::config::limits::DEFAULT_FRAME_HISTORY_PER_STREAM
• domain::config::limits::MAX_FRAMES_PER_REQUEST
• domain::config::limits::MAX_PAGINATION_LIMIT
• domain::config::limits::MAX_PAGINATION_OFFSET
• domain::config::limits::MAX_SESSION_TIMEOUT_SECONDS
• domain::value_objects::MAX_DESERIALIZE_DEPTH
• infrastructure::adapters::limits::MAX_HEALTH_METRICS
• infrastructure::adapters::limits::MAX_RESULTS_LIMIT
• infrastructure::adapters::limits::MAX_SCAN_LIMIT
• security::rate_limit::DEFAULT_CLEANUP_INTERVAL
• security::rate_limit::MAX_TRACKED_CLIENTS