digdigdig3 0.1.29

Unified async Rust API for 44 exchange connectors — crypto, stocks, forex. REST + WebSocket.
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

//! # ExchangeIdentity - базовый трейт идентификации биржи
//!
//! Этот трейт является корнем иерархии и должен быть реализован ВСЕМИ коннекторами.
//! НЕ требует авторизации.
//!
//! ## Реализация
//! - Binance: ✅
//! - Bybit: ✅
//! - OKX: ✅
//! - Hyperliquid: ✅

use crate::core::types::{
    AccountType, ConnectorStats, ExchangeId, ExchangeType, RateLimitCapabilities,
};

/// Базовая идентификация биржи
///
/// Этот трейт определяет минимальный набор методов для идентификации биржи.
/// Все коннекторы ДОЛЖНЫ реализовывать этот трейт.
///
/// # Примечания
/// - НЕ требует авторизации
/// - Все методы синхронные (не async)
/// - Должен быть Send + Sync для многопоточного использования
pub trait ExchangeIdentity: Send + Sync {
    /// Уникальный идентификатор биржи
    ///
    /// # Возвращает
    /// `ExchangeId` enum значение (Binance, Bybit, OKX, Hyperliquid, etc.)
    fn exchange_id(&self) -> ExchangeId;

    /// Человекочитаемое имя биржи
    ///
    /// # Дефолтная реализация
    /// Делегирует в `exchange_id().as_str()`
    fn exchange_name(&self) -> &'static str {
        self.exchange_id().as_str()
    }

    /// Работаем ли с тестовой сетью
    ///
    /// # Возвращает
    /// - `true` - тестнет/демо режим
    /// - `false` - продакшн
    fn is_testnet(&self) -> bool;

    /// Список поддерживаемых типов аккаунтов
    ///
    /// # Примеры
    /// - Binance: [Spot, Margin, FuturesCross, FuturesIsolated]
    /// - Bybit: [Spot, FuturesCross, FuturesIsolated]
    /// - OKX: [Spot, Margin, FuturesCross, FuturesIsolated]
    /// - Hyperliquid: [Spot, FuturesCross]
    fn supported_account_types(&self) -> Vec<AccountType>;

    /// Тип биржи (централизованная, децентрализованная, гибрид)
    ///
    /// # Дефолтная реализация
    /// Делегирует в `exchange_id().exchange_type()`
    fn exchange_type(&self) -> ExchangeType {
        self.exchange_id().exchange_type()
    }

    /// Runtime metrics snapshot for this connector.
    ///
    /// Returns HTTP request/error counters, last latency, and rate-limiter
    /// utilization. The default implementation returns zeroed metrics.
    /// Override this in connectors that have an `HttpClient` to expose live data.
    fn metrics(&self) -> ConnectorStats {
        ConnectorStats::default()
    }

    /// Static rate limit capabilities for this exchange.
    ///
    /// Returns the compile-time descriptor used to build runtime limiters.
    /// Default is `permissive()` (unlimited) — override in each connector.
    fn rate_limit_capabilities(&self) -> RateLimitCapabilities {
        RateLimitCapabilities::permissive()
    }
}