balter-runtime 0.3.1

A load/stress testing framework.
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

use std::sync::PoisonError;
use thiserror::Error;

#[derive(Debug, Error)]
pub enum GossipError {
    #[error("Invalid WebSocket message type")]
    InvalidType,

    #[error("Error in Axum: {0}")]
    Axum(#[from] axum::Error),

    #[error("Error in Tungstenite: {0}")]
    Tungstenite(#[from] tungstenite::Error),

    #[error("Error deserializing with Bincode: {0}")]
    Bincode(#[from] Box<bincode::ErrorKind>),

    #[error("Stream ended too early")]
    NoData,

    #[error("GossipData Mutex is poisoned")]
    PoisonData,

    #[error("Error in parsing URL. This is a bug in Balter. {0}")]
    UrlError(#[from] url::ParseError),

    #[error("Peer to share work with is busy. Retries not implemented yet.")]
    PeerBusy,
}

impl<T> From<PoisonError<T>> for GossipError {
    fn from(_err: PoisonError<T>) -> Self {
        Self::PoisonData
    }
}