Struct ckb_network::Peer
source · [−]pub struct Peer {
pub connected_addr: Multiaddr,
pub listened_addrs: Vec<Multiaddr>,
pub identify_info: Option<PeerIdentifyInfo>,
pub last_ping_protocol_message_received_at: Option<Instant>,
pub ping_rtt: Option<Duration>,
pub is_feeler: bool,
pub connected_time: Instant,
pub session_id: SessionId,
pub session_type: SessionType,
pub protocols: HashMap<ProtocolId, ProtocolVersion>,
pub is_whitelist: bool,
}Expand description
Peer info
Fields
connected_addr: MultiaddrPeer address
listened_addrs: Vec<Multiaddr>Peer listen addresses
identify_info: Option<PeerIdentifyInfo>Peer info from identify protocol message
last_ping_protocol_message_received_at: Option<Instant>Ping/Pong message last received time
ping_rtt: Option<Duration>ping pong rtt
is_feeler: boolIndicates whether it is a probe connection of the fleer protocol
connected_time: InstantPeer connected time
session_id: SessionIdSession id
session_type: SessionTypeSession type, Inbound or Outbound
protocols: HashMap<ProtocolId, ProtocolVersion>Opened protocols on this session
is_whitelist: boolWhether a whitelist
Implementations
sourceimpl Peer
impl Peer
sourcepub fn new(
session_id: SessionId,
session_type: SessionType,
connected_addr: Multiaddr,
is_whitelist: bool
) -> Self
pub fn new(
session_id: SessionId,
session_type: SessionType,
connected_addr: Multiaddr,
is_whitelist: bool
) -> Self
Init session info
sourcepub fn is_outbound(&self) -> bool
pub fn is_outbound(&self) -> bool
Whether outbound session
sourcepub fn is_inbound(&self) -> bool
pub fn is_inbound(&self) -> bool
Whether inbound session
sourcepub fn network_group(&self) -> Group
pub fn network_group(&self) -> Group
Get net group
sourcepub fn protocol_version(
&self,
protocol_id: ProtocolId
) -> Option<ProtocolVersion>
pub fn protocol_version(
&self,
protocol_id: ProtocolId
) -> Option<ProtocolVersion>
Opened protocol version
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Peer
impl Send for Peer
impl Sync for Peer
impl Unpin for Peer
impl UnwindSafe for Peer
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more