Struct stratum_server::Connection

pub struct Connection<SM: StratumManager> {
    pub id: String,
    pub write_half: Arc<Mutex<WriteHalf<TcpStream>>>,
    pub read_half: Arc<Mutex<BufReader<ReadHalf<TcpStream>>>>,
    pub authorized: Arc<Mutex<bool>>,
    pub data_provider: Arc<SM::DataProvider>,
    pub block_validator: Arc<SM::BlockValidator>,
    pub auth_manager: Arc<SM::AuthManager>,
    pub session_start: SystemTime,
    pub state: Mutex<State>,
    pub subscribed: Arc<Mutex<bool>>,
    pub subscriber_id: Arc<Mutex<String>>,
    pub miner_info: Arc<Mutex<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>>,
}

Fields

id: String

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

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

authorized: Arc<Mutex<bool>>

data_provider: Arc<SM::DataProvider>

block_validator: Arc<SM::BlockValidator>

auth_manager: Arc<SM::AuthManager>

session_start: SystemTime

state: Mutex<State>

subscribed: Arc<Mutex<bool>>

subscriber_id: Arc<Mutex<String>>

miner_info: Arc<Mutex<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>>

Methods

impl<SM> Connection<SM> where
    SM: StratumManager, 

pub fn new(
    addr: SocketAddr,
    rh: BufReader<ReadHalf<TcpStream>>,
    wh: WriteHalf<TcpStream>,
    data_provider: Arc<SM::DataProvider>,
    auth_manager: Arc<SM::AuthManager>,
    block_validator: Arc<SM::BlockValidator>
) -> Self

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

pub async fn handle_requests<'_>(
    &'_ self,
    req: Request<ClientParam<SM::PoolParams, SM::StratumParams>>
) -> Result<()>

pub async fn handle_responses<'_>(
    &'_ self,
    _res: Response<ClientParam<SM::PoolParams, SM::StratumParams>>
) -> Result<()>

pub async fn next_message<'_>(
    &'_ self
) -> Result<ClientPacket<SM::PoolParams, SM::StratumParams>>

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

pub async fn handle_authorize<'_, '_>(
    &'_ self,
    auth: &'_ <SM::PoolParams as PoolParams>::Authorize
) -> Result<()>

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

pub async fn handle_submit<'_, '_>(
    &'_ self,
    share: &'_ <SM::StratumParams as StratumParams>::Submit
) -> Result<()>

pub async fn handle_subscribe<'_, '_>(
    &'_ self,
    subscribe: &'_ <SM::PoolParams as PoolParams>::Subscribe
) -> Result<()>

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

Trait Implementations

impl<SM: Debug + StratumManager> Debug for Connection<SM> where
    SM::DataProvider: Debug,
    SM::BlockValidator: Debug,
    SM::AuthManager: Debug, 

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

Formats the value using the given formatter.