Struct roles_logic_sv2::selectors::GeneralMiningSelector

pub struct GeneralMiningSelector<Sel: DownstreamMiningSelector<Down>, Down: IsMiningDownstream, Up: IsMiningUpstream<Down, Sel>> {
    pub upstreams: Vec<Arc<Mutex<Up>>>,
    pub id_to_upstream: HashMap<u32, Arc<Mutex<Up>>, BuildNoHashHasher<u32>>,
    /* private fields */
}

Upstream selector is used to chose between a set of known mining upstream nodes which one/ones can accept messages from a specific mining downstream node

Fields

upstreams: Vec<Arc<Mutex<Up>>>

id_to_upstream: HashMap<u32, Arc<Mutex<Up>>, BuildNoHashHasher<u32>>

Implementations

impl<Sel: DownstreamMiningSelector<Down>, Up: IsMiningUpstream<Down, Sel>, Down: IsMiningDownstream> GeneralMiningSelector<Sel, Down, Up>

pub fn new(upstreams: Vec<Arc<Mutex<Up>>>) -> Self

pub fn update_upstreams(&mut self, upstreams: Vec<Arc<Mutex<Up>>>)

Trait Implementations

impl<Sel: Debug + DownstreamMiningSelector<Down>, Down: Debug + IsMiningDownstream, Up: Debug + IsMiningUpstream<Down, Sel>> Debug for GeneralMiningSelector<Sel, Down, Up>

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

Formats the value using the given formatter.

impl<Sel: DownstreamMiningSelector<Down>, Down: IsMiningDownstream, Up: IsMiningUpstream<Down, Sel>> UpstreamMiningSelctor<Down, Up, Sel> for GeneralMiningSelector<Sel, Down, Up>

fn on_setup_connection( &mut self, pair_settings: &PairSettings ) -> Result<(Vec<Arc<Mutex<Up>>>, u32), Error>

Return the set of mining upstream nodes that can accept messages from a downstream with the passed PairSettings and the sum of all the accepted flags

fn get_upstream(&self, upstream_id: u32) -> Option<Arc<Mutex<Up>>>

impl<Sel: DownstreamMiningSelector<Down>, Down: IsMiningDownstream, Up: IsMiningUpstream<Down, Sel>> UpstreamSelector for GeneralMiningSelector<Sel, Down, Up>