atelier_data 0.0.15

Data Artifacts and I/O for the atelier-rs engine
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

//! Communication clients for exchange connectivity.
//!
//! This module provides generic transport clients ([`WssClient`](crate::clients::WssClient), [`HttpClient`](crate::clients::HttpClient))
//! and the reconnection infrastructure ([`reconnect`](crate::clients::reconnect)) used by higher-level
//! workers.
//!
//! Exchange-specific clients (e.g. `BybitWssClient`) live in [`crate::sources`]
//! and build on top of the types defined here.  Reconnection is **not** handled
//! inside the clients themselves — it is the caller's responsibility, typically
//! via a [`ReconnectPolicy`](crate::clients::reconnect::ReconnectPolicy).

/// Policy for disconnections
pub mod disconnect;
/// Http client implementation
pub mod http;
/// Policy for reconnecting
pub mod reconnect;
/// RPC client implementation
pub mod rpc;
/// WSS client implementation
pub mod wss;

/// Connection lifecycle manager with state tracking and reconnection.
pub mod connection_manager;
/// Formal connection state machine for the data worker WSS lifecycle.
pub mod connection_state;

pub use http::http_client::HttpClient;
pub use wss::wss_client::WssClient;

// TODO : macro in tracing [instrument]