List of all items

Structs

• buffer_pool::BufferPool
• events::EventAlias
• events::EventAliasOwned
• exchange::CategoryRateLimiter
• exchange::ConcurrentRateLimiter
• exchange::ExchangeConfig
• exchange::ExchangeInfo
• exchange::FetchMarketsParams
• exchange::FetchResult
• exchange::KalshiCredentials
• exchange::PolymarketCredentials
• exchange::RateLimiter
• exchange::TradesRequest
• exchange::manifest::EndpointRateLimit
• exchange::manifest::ExchangeManifest
• exchange::manifest::PaginationConfig
• exchange::manifest::RateLimitConfig
• models::CreateOrderRequest
• models::CryptoPrice
• models::DepthBuckets
• models::Event
• models::Fill
• models::FixedPrice
• models::LevelCount
• models::Market
• models::MarketLineage
• models::MarketTrade
• models::MaxGap
• models::Order
• models::Orderbook
• models::OrderbookImpact
• models::OrderbookMicrostructure
• models::OrderbookStats
• models::Outcome
• models::Position
• models::PriceLevel
• models::PriceLevelChange
• models::PublicTrade
• models::RestPriceLevel
• models::Series
• models::SettlementSource
• models::SportResult
• timing::TimingGuard
• websocket::ActivityFill
• websocket::ActivityTrade
• websocket::AtomicWebSocketState
• websocket::ndjson::NdjsonWriter
• websocket::stream::SessionStream
• websocket::stream::UpdateStream
• websocket::stream::WsDispatcher
• websocket::stream::WsDispatcherConfig

Enums

• error::ExchangeError
• error::NetworkError
• error::OpenPxError
• error::SigningError
• error::WebSocketError
• exchange::MarketStatusFilter
• exchange::manifest::PaginationStyle
• exchange::manifest::RateLimitCategory
• models::CryptoPriceSource
• models::LiquidityRole
• models::MarketStatus
• models::MarketType
• models::OrderOutcome
• models::OrderSide
• models::OrderStatus
• models::OrderType
• models::PriceLevelSide
• websocket::WebSocketState
• websocket::events::InvalidationReason
• websocket::events::SessionEvent
• websocket::events::WsUpdate
• ws_decoder::WsFrame

Traits

• exchange::Exchange
• exchange::MarketFetcher
• websocket::OrderBookWebSocket

Macros

• define_exchange_error
• timed

Functions

• events::aliases_for_event_id
• events::canonical_event_id
• events::default_event_id
• exchange::normalizers::coerce_iso8601_datetime
• exchange::normalizers::coerce_to_float
• exchange::normalizers::coerce_to_int
• exchange::normalizers::coerce_to_string
• exchange::normalizers::coerce_unix_millis_datetime
• exchange::normalizers::coerce_unix_secs_datetime
• exchange::normalizers::get_nested
• models::apply_ask_delta
• models::apply_ask_level
• models::apply_bid_delta
• models::apply_bid_level
• models::insert_ask
• models::insert_bid
• models::orderbook_impact
• models::orderbook_microstructure
• models::orderbook_stats
• models::sort_asks
• models::sort_bids
• price_fixed::parse_level
• price_fixed::parse_price_str
• price_fixed::parse_qty_str
• utils::clamp_price
• utils::is_valid_price
• utils::mid_price
• utils::pick_active_and_next
• utils::pick_active_market
• utils::round_to_tick_size
• utils::spread_bps
• websocket::events::now_pair
• websocket::stall_watchdog
• ws_decoder::decode_frame
• ws_decoder::decode_value

Type Aliases

• exchange::CheckpointCallback
• hash::FastHashMap
• hash::FastHashSet
• models::ChangeVec
• price_fixed::Price
• price_fixed::Qty
• websocket::CryptoPriceStream
• websocket::SportsStream

Constants

• exchange::manifests::KALSHI_MANIFEST
• exchange::manifests::POLYMARKET_MANIFEST
• http::HTTP2_INITIAL_STREAM_WINDOW_BYTES
• http::HTTP2_KEEP_ALIVE_INTERVAL
• http::POOL_MAX_IDLE_PER_HOST
• price_fixed::SCALE_FACTOR
• timing::exchange::HTTP_REQUEST
• timing::exchange::PARSE_RESPONSE
• timing::exchange::SIGN_REQUEST
• timing::exchange::WS_RECEIVE
• timing::exchange::WS_SEND
• websocket::WS_CRYPTO_PING_INTERVAL
• websocket::WS_MAX_RECONNECT_ATTEMPTS
• websocket::WS_PING_INTERVAL
• websocket::WS_RECONNECT_BASE_DELAY
• websocket::WS_RECONNECT_MAX_DELAY
• websocket::WS_STALL_CHECK_INTERVAL
• websocket::WS_STALL_TIMEOUT