Struct NetworkServiceHandles

Source

pub struct NetworkServiceHandles {
    pub service: NetworkService,
    pub sink: Litep2pNetworkSink,
    pub msg_rx: Receiver<(Option<ValidatorId>, ConsensusMessage)>,
    pub sync_req_rx: Receiver<IncomingSyncRequest>,
    pub sync_resp_rx: Receiver<SyncResponse>,
    pub peer_info_rx: Receiver<Vec<PeerStatus>>,
    pub connected_count_rx: Receiver<usize>,
    pub notif_connected_count_rx: Receiver<usize>,
    pub mempool_tx_rx: Receiver<Vec<u8>>,
}

Expand description

All handles returned by NetworkService::create.

Fields§

§service: NetworkService§sink: Litep2pNetworkSink§msg_rx: Receiver<(Option<ValidatorId>, ConsensusMessage)>§sync_req_rx: Receiver<IncomingSyncRequest>§sync_resp_rx: Receiver<SyncResponse>§peer_info_rx: Receiver<Vec<PeerStatus>>§connected_count_rx: Receiver<usize>§notif_connected_count_rx: Receiver<usize>

Number of peers with an open notification (consensus) substream. Reaches >0 once the notification handshake completes, which is later than the raw connection and avoids the need for a fixed sleep.

§mempool_tx_rx: Receiver<Vec<u8>>

Receiver for transactions gossipped from peers via the mempool protocol.

Auto Trait Implementations§

§

NetworkServiceHandles

Struct NetworkServiceHandles Copy item path

Fields§

Auto Trait Implementations§

impl !Freeze for NetworkServiceHandles

impl !RefUnwindSafe for NetworkServiceHandles

impl Send for NetworkServiceHandles

impl !Sync for NetworkServiceHandles

impl Unpin for NetworkServiceHandles

impl UnsafeUnpin for NetworkServiceHandles

impl !UnwindSafe for NetworkServiceHandles

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct NetworkServiceHandles

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,