Struct stratum_server::Connection

pub struct Connection<State> {
    pub sender: Arc<Mutex<UnboundedSender<String>>>,
    pub authorized: Arc<Mutex<bool>>,
    pub subscribed: Arc<Mutex<bool>>,
    pub session_start: SystemTime,
    pub connection_state: Mutex<ConnectionState>,
    pub difficulty: Arc<Mutex<f64>>,
    pub stats: Arc<Mutex<MinerStats>>,
    pub needs_ban: Arc<Mutex<bool>>,
    pub next_difficulty: Arc<Mutex<Option<f64>>>,
    pub id: Uuid,
    pub subscriber_id: Arc<Mutex<String>>,
    pub miner_info: Arc<RwLock<MinerInfo>>,
    pub job_stats: Arc<Mutex<JobStats>>,
    pub options: Arc<MinerOptions>,
    pub var_diff: Arc<Mutex<bool>>,
    pub last_message_id: Arc<Mutex<ID>>,
    pub worker_info: Arc<Mutex<WorkerInfo>>,
    pub state: Arc<Mutex<State>>,
    pub stop_source: Arc<Mutex<Option<StopSource>>>,
    pub stop_token: StopToken,
}

Fields

sender: Arc<Mutex<UnboundedSender<String>>>

authorized: Arc<Mutex<bool>>

subscribed: Arc<Mutex<bool>>

session_start: SystemTime

connection_state: Mutex<ConnectionState>

difficulty: Arc<Mutex<f64>>

stats: Arc<Mutex<MinerStats>>

needs_ban: Arc<Mutex<bool>>

next_difficulty: Arc<Mutex<Option<f64>>>

id: Uuid

subscriber_id: Arc<Mutex<String>>

miner_info: Arc<RwLock<MinerInfo>>

job_stats: Arc<Mutex<JobStats>>

options: Arc<MinerOptions>

var_diff: Arc<Mutex<bool>>

last_message_id: Arc<Mutex<ID>>

worker_info: Arc<Mutex<WorkerInfo>>

state: Arc<Mutex<State>>

stop_source: Arc<Mutex<Option<StopSource>>>

stop_token: StopToken

Implementations

impl<State: Clone + Send + Sync + 'static> Connection<State>

pub fn new(
    addr: SocketAddr,
    sender: UnboundedSender<String>,
    initial_difficulty: f64,
    var_diff_config: VarDiffConfig,
    state: State
) -> Self

pub async fn info<'_>(&'_ self) -> MinerInfo

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

pub async fn send<T: Serialize, '_>(&'_ self, message: T) -> Result<()>

pub async fn shutdown<'_>(&'_ self) -> 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

pub async fn ip<'_>(&'_ self) -> IpAddr

pub fn id(&self) -> Uuid

pub async fn set_sid<'_>(
    &'_ self,
    sid: Option<String>,
    sid_size: usize
) -> String

pub async fn set_var_diff<'_>(&'_ self, var_diff: bool)

pub async fn set_worker_name<'_>(&'_ self, name: Option<String>)

pub async fn set_account_id<'_>(&'_ self, id: i32)

pub async fn get_account_id<'_>(&'_ self) -> i32

pub async fn set_client<'_, '_>(&'_ self, client: &'_ str)

pub async fn get_client<'_>(&'_ self) -> Option<String>

pub async fn set_worker_id<'_>(&'_ self, id: Uuid)

pub async fn get_sid<'_>(&'_ self) -> Option<Buffer>

pub async fn get_worker<'_>(&'_ self) -> WorkerInfo

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

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

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

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

pub async fn set_difficulty<'_>(&'_ self, difficulty: f64)

pub async fn get_difficulty<'_>(&'_ self) -> f64

pub async fn get_state<'_>(&'_ self) -> State

pub async fn set_state<'_>(&'_ self, state: State)

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

pub async fn update_difficulty<'_>(&'_ self) -> Option<f64>

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

pub fn get_stop_token(&self) -> StopToken

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

Trait Implementations

impl<State: Debug> Debug for Connection<State>

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

Formats the value using the given formatter.