Struct stratum_server::Connection

pub struct Connection {
    pub id: ID,
    pub write_half: Arc<Mutex<WriteHalf<TcpStream>>>,
    pub read_half: Arc<Mutex<BufReader<ReadHalf<TcpStream>>>>,
    pub authorized: Arc<Mutex<bool>>,
    pub session_start: SystemTime,
    pub connection_state: Mutex<ConnectionState>,
    pub subscribed: Arc<Mutex<bool>>,
    pub subscriber_id: Arc<Mutex<String>>,
    pub miner_info: Arc<RwLock<MinerInfo>>,
    pub difficulty: Arc<Mutex<f64>>,
    pub submissions: Arc<Mutex<u64>>,
    pub last_retarget: Arc<Mutex<SystemTime>>,
    pub next_difficulty: Arc<Mutex<f64>>,
    pub job_stats: Arc<Mutex<JobStats>>,
    pub options: Arc<MinerOptions>,
    pub stats: Arc<Mutex<MinerStats>>,
    pub needs_ban: Arc<Mutex<bool>>,
    pub var_diff: bool,
    pub ban_stats: Arc<Mutex<BanStats>>,
    pub classic: Arc<Mutex<bool>>,
    pub last_message_id: Arc<Mutex<ID>>,
}

Fields

id: ID

write_half: Arc<Mutex<WriteHalf<TcpStream>>>

read_half: Arc<Mutex<BufReader<ReadHalf<TcpStream>>>>

authorized: Arc<Mutex<bool>>

session_start: SystemTime

connection_state: Mutex<ConnectionState>

subscribed: Arc<Mutex<bool>>

subscriber_id: Arc<Mutex<String>>

miner_info: Arc<RwLock<MinerInfo>>

difficulty: Arc<Mutex<f64>>

submissions: Arc<Mutex<u64>>

last_retarget: Arc<Mutex<SystemTime>>

next_difficulty: Arc<Mutex<f64>>

job_stats: Arc<Mutex<JobStats>>

options: Arc<MinerOptions>

stats: Arc<Mutex<MinerStats>>

needs_ban: Arc<Mutex<bool>>

var_diff: bool

ban_stats: Arc<Mutex<BanStats>>

classic: Arc<Mutex<bool>>

last_message_id: Arc<Mutex<ID>>

Implementations

impl Connection

pub fn new(
    addr: SocketAddr,
    rh: BufReader<ReadHalf<TcpStream>>,
    wh: WriteHalf<TcpStream>,
    var_diff: bool,
    initial_difficulty: f64
) -> Self

pub async fn is_disconnected<'_>(&'_ self) -> bool

pub async fn next_message<'_>(&'_ self) -> Result<(String, Map<String, Value>)>

pub async fn shutdown<'_>(&'_ self) -> Result<()>

pub async fn handle_unknown<'_, '_>(&'_ self, _msg: &'_ Value) -> Result<()>

pub async fn disconnect<'_>(&'_ self)

pub async fn ban<'_>(&'_ self)

pub async fn needs_ban<'_>(&'_ self) -> bool

pub async fn get_stats<'_>(&'_ self) -> MinerStats

Trait Implementations

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.