Struct roles_logic_sv2::selectors::ProxyDownstreamMiningSelector

pub struct ProxyDownstreamMiningSelector<Down: IsDownstream> { /* private fields */ }

A DownstreamMiningSelector useful for routing messages in a mining proxy

Implementations

impl<Down: IsDownstream> ProxyDownstreamMiningSelector<Down>

pub fn new() -> Self

pub fn new_as_mutex() -> Arc<Mutex<Self>>

where Self: Sized,

Trait Implementations

impl<Down: Clone + IsDownstream> Clone for ProxyDownstreamMiningSelector<Down>

fn clone(&self) -> ProxyDownstreamMiningSelector<Down>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Down: Debug + IsDownstream> Debug for ProxyDownstreamMiningSelector<Down>

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

Formats the value using the given formatter.

impl<Down: Default + IsDownstream> Default for ProxyDownstreamMiningSelector<Down>

fn default() -> ProxyDownstreamMiningSelector<Down>

Returns the “default value” for a type.

impl<Down: IsMiningDownstream> DownstreamMiningSelector<Down> for ProxyDownstreamMiningSelector<Down>

fn on_open_standard_channel_request( &mut self, request_id: u32, downstream: Arc<Mutex<Down>> )

fn on_open_standard_channel_success( &mut self, request_id: u32, g_channel_id: u32, channel_id: u32 ) -> Result<Arc<Mutex<Down>>, Error>

fn get_downstreams_in_channel( &self, channel_id: u32 ) -> Option<&Vec<Arc<Mutex<Down>>>>

fn remove_downstreams_in_channel( &mut self, channel_id: u32 ) -> Vec<Arc<Mutex<Down>>>

fn remove_downstream(&mut self, d: &Arc<Mutex<Down>>)

fn downstream_from_channel_id( &self, channel_id: u32 ) -> Option<Arc<Mutex<Down>>>

fn get_all_downstreams(&self) -> Vec<Arc<Mutex<Down>>>

impl<Down: IsMiningDownstream> DownstreamSelector<Down> for ProxyDownstreamMiningSelector<Down>