fugle-marketdata-core 0.6.0

Internal kernel for the Fugle market data SDK. End users should depend on `fugle-marketdata` instead.
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

//! WebSocket client for real-time market data streaming
//!
//! This module provides:
//! - WebSocket connection lifecycle management
//! - Configuration for connection parameters
//! - State machine for connection states
//! - Event notifications for connection events
//! - Channel-specific subscription and parsing

pub mod channels;
pub mod config;
pub mod connection_event;
pub mod factory;
pub mod health_check;
pub mod message;
pub(crate) mod protocol;
pub mod reconnection;
pub mod subscription;
pub mod sync;

#[cfg(feature = "tokio-comp")]
#[cfg_attr(docsrs, doc(cfg(feature = "tokio-comp")))]
pub mod aio;

// Default `WebSocketClient` is the sync implementation. Async users opt in via
// `marketdata_core::aio::WebSocketClient` with `--features tokio-comp`.
pub use channels::StockSubscription;
pub use config::{ConnectionConfig, ConnectionConfigBuilder, DEFAULT_EVENT_BUFFER, DEFAULT_MESSAGE_BUFFER};
pub use factory::WebSocketFactory;
pub use connection_event::{ConnectionEvent, ConnectionState, DisconnectIntent};
pub use health_check::HealthCheckConfig;
pub use message::MessageReceiver;
pub use reconnection::{ReconnectionConfig, ReconnectionManager};
pub use subscription::SubscriptionManager;
pub use sync::WebSocketClient;