Struct QueuedConn

Source

pub struct QueuedConn {
    pub reader: FramedReader<PeerNetMsgCodec>,
    pub writer: FramedWriter<PeerNetMsgCodec>,
    pub direction: ConnDirection,
    pub remote_endpoint: Endpoint,
    pub disconnect_signal: Sender<Result<()>>,
    pub verified_peer_id: Option<PeerID>,
    pub quic_conn: Option<QuicConn>,
}

Expand description

A connection queued for the PeerPool to handshake and turn into a Peer. Carries the raw split halves plus metadata.

Fields§

§reader: FramedReader<PeerNetMsgCodec>§writer: FramedWriter<PeerNetMsgCodec>§direction: ConnDirection§remote_endpoint: Endpoint§disconnect_signal: Sender<Result<()>>§verified_peer_id: Option<PeerID>

PeerID derived from the secure transport (TLS cert). None for unauthenticated transports (TCP, Unix). The application handshake asserts vermsg.peer_id == this when Some, so a peer can’t claim a PeerID it can’t prove.

§quic_conn: Option<QuicConn>

Auto Trait Implementations§

§

QueuedConn

Struct QueuedConn Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for QueuedConn

impl RefUnwindSafe for QueuedConn

impl Send for QueuedConn

impl Sync for QueuedConn

impl Unpin for QueuedConn

impl UnsafeUnpin for QueuedConn

impl UnwindSafe for QueuedConn

Blanket Implementations§

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

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

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> 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 QueuedConn

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

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

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>,