quantoxide 0.5.3

Rust framework for developing, backtesting, and deploying Bitcoin futures trading strategies.
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

use std::result;

use thiserror::Error;
use tokio::sync::broadcast::error::RecvError;

use lnm_sdk::api_v2::{WsConnectionStatus, error::WebSocketApiError};

use crate::db::error::DbError;

#[derive(Error, Debug)]
#[non_exhaustive]
pub enum RealTimeCollectionError {
    #[error("[WebSocketApi] {0}")]
    WebSocketApi(#[from] WebSocketApiError),

    #[error("BadConnectionUpdate error: {0}")]
    BadConnectionUpdate(WsConnectionStatus),

    #[error("[Db] {0}")]
    Db(#[from] DbError),

    #[error("RecvLagged error, skipped: {skipped}")]
    WebSocketRecvLagged { skipped: u64 },

    #[error("RecvLagged error")]
    WebSocketRecvClosed,

    #[error("Shutdown signal channel error: {0}")]
    ShutdownSignalRecv(RecvError),
}

pub(super) type Result<T> = result::Result<T, RealTimeCollectionError>;