digdigdig3 0.3.1

Unified async Rust API for 47 exchange connectors (REST + WebSocket). The core layer — pure ExchangeHub + connectors. Higher-level builder, persistence, replay, OB tracker live in `digdigdig3-station`.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! # WebSocket Framework — Wave 0 Foundation
//!
//! Replaces duplicated per-exchange connect/ping/reconnect/dispatch loops with
//! a single generic `UniversalWsTransport<P: WsProtocol>`.
//!
//! Each exchange shrinks to a thin declarative shim (`WsProtocol` impl) providing:
//! - Endpoint URL
//! - Ping frame
//! - Subscribe/unsubscribe frames
//! - Topic extractor
//! - `TopicRegistry` mapping topic → parser
//!
//! The framework owns ALL connection lifecycle, ping scheduling, subscription replay,
//! frame routing, and unmatched-frame logging. Silent drops are architecturally
//! impossible: unmatched topic → `tracing::warn!`, never `Ok(None)`.

// base_websocket.rs is kept on disk but not compiled — Wave 2 will remove it.
// mod base_websocket;

pub mod capability_provider;
pub mod protocol;
pub mod reconnect;
pub mod stream_kind;
pub mod stream_spec;
pub mod support_level;
pub mod topic_registry;
pub mod transport;

pub use capability_provider::CapabilityProvider;
pub use protocol::WsProtocol;
pub use reconnect::ReconnectConfig;
pub use stream_kind::{KlineInterval, StreamKind};
pub use stream_spec::StreamSpec;
pub use support_level::SupportLevel;
pub use topic_registry::{
    ParserFn, RegistryEntry, RegistryKey, TopicKey, TopicPattern, TopicRegistry,
    TopicRegistryBuilder, topic_pattern_matches,
};
pub use transport::{UniversalWsTransport, decode_binary_default};