List of all items

Structs

• config::Config
• config::ConfigLoadOptions
• config::LongPollTimeout
• config::SseReconnectInterval
• handlers::get::ReadQuery
• protocol::producer::ProducerHeaders
• protocol::sse::ControlPayload
• storage::CreateWithDataResult
• storage::Message
• storage::ReadResult
• storage::StreamConfig
• storage::StreamMetadata
• storage::acid::AcidStorage
• storage::file::FileStorage
• storage::memory::InMemoryStorage

Enums

• config::StorageMode
• protocol::error::Error
• protocol::offset::Offset
• storage::CreateStreamResult
• storage::ProducerAppendResult

Traits

• storage::Storage

Functions

• handlers::delete::delete_stream
• handlers::get::read_stream
• handlers::head::stream_metadata
• handlers::health::health_check
• handlers::post::append_data
• handlers::put::create_stream
• middleware::security::add_security_headers
• protocol::cursor::generate
• protocol::headers::normalize_content_type
• protocol::headers::parse_bool
• protocol::headers::parse_expires_at
• protocol::headers::parse_ttl
• protocol::json_mode::is_json_content_type
• protocol::json_mode::process_append
• protocol::json_mode::wrap_read
• protocol::json_mode::wrap_read_iter
• protocol::producer::parse_producer_headers
• protocol::sse::format_control_frame
• protocol::sse::format_data_frame
• protocol::sse::format_data_frames
• protocol::sse::format_keepalive_frame
• protocol::sse::is_binary_content_type
• router::build_router

Type Aliases

• protocol::error::Result

Constants

• protocol::headers::names::PRODUCER_EPOCH
• protocol::headers::names::PRODUCER_EXPECTED_SEQ
• protocol::headers::names::PRODUCER_ID
• protocol::headers::names::PRODUCER_RECEIVED_SEQ
• protocol::headers::names::PRODUCER_SEQ
• protocol::headers::names::STREAM_CLOSED
• protocol::headers::names::STREAM_CURSOR
• protocol::headers::names::STREAM_EXPIRES_AT
• protocol::headers::names::STREAM_NEXT_OFFSET
• protocol::headers::names::STREAM_SEQ
• protocol::headers::names::STREAM_TTL
• protocol::headers::names::STREAM_UP_TO_DATE