bulk-client 0.1.0

High-performance Rust SDK for BULK (HTTP + 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

use serde_json::Value;
use crate::msgs::account::{Fill, LeverageSetting, Margin, OrderState, PositionInfo};
use crate::msgs::md::{Candle, L2Snapshot, Ticker};


// ─────────────────────────────────────────────────────────────────────────────
// Event topics
// ─────────────────────────────────────────────────────────────────────────────


/// Topics to subscribe to
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
#[allow(unused)]
pub enum Topic {
    Ticker,
    Trades,
    L2Snapshot,
    L2Delta,
    Candle,
    Account,
    Margin,
    Position,
    Fill,
    Leverage,
    Order,
    Error,
    /// Connection lifecycle events (connected, disconnected).
    Status
}

// ─────────────────────────────────────────────────────────────────────────────
// Event return types
// ─────────────────────────────────────────────────────────────────────────────

/// Typed event payload emitted to handlers.
#[derive(Debug, Clone)]
#[allow(unused)]
pub enum Event {
    Ticker(Ticker),
    Trades(Vec<Fill>),
    L2Snapshot(L2Snapshot),
    L2Delta(L2Snapshot),
    Candle(Candle),
    Margin(Margin),
    Position(PositionInfo),
    Order(OrderState),
    Fill(Fill),
    Leverage(Vec<LeverageSetting>),
    Error(Value),
    /// Emitted on the [`Topic::Status`] channel when the WebSocket connection
    /// is cleanly established (after the actor sends initial subscriptions).
    Connected,
    /// Emitted on the [`Topic::Status`] channel when the WebSocket connection
    /// is lost for any reason.  The string contains a human-readable cause.
    Disconnected(String),
}

#[allow(unused)]
impl Event {
    pub fn topic(&self) -> Topic {
        match self {
            Event::Ticker(_) => Topic::Ticker,
            Event::Trades(_) => Topic::Trades,
            Event::L2Snapshot(_) => Topic::L2Snapshot,
            Event::L2Delta(_) => Topic::L2Delta,
            Event::Candle(_) => Topic::Candle,
            Event::Margin(_) => Topic::Margin,
            Event::Position(_) => Topic::Position,
            Event::Order(_) => Topic::Order,
            Event::Fill(_) => Topic::Fill,
            Event::Leverage(_) => Topic::Leverage,
            Event::Error(_) => Topic::Error,
            Event::Connected | Event::Disconnected(_) => Topic::Status,
        }
    }
}