Struct Session 

pub struct Session {
    pub id: NodeId,
    pub addr: Address,
    pub link: Link,
    pub persistent: bool,
    pub state: State,
    pub subscribe: Option<Subscribe>,
    pub last_active: LocalTime,
    pub queue: VecDeque<QueuedFetch>,
    /* private fields */
}

A peer session. Each connected peer will have one session.

Fields

id: NodeId

Peer id.

addr: Address

Peer address.

link: Link

Connection direction.

persistent: bool

Whether we should attempt to re-connect to this peer upon disconnection.

state: State

Peer connection state.

subscribe: Option<Subscribe>

Peer subscription.

last_active: LocalTime

Last time a message was received from the peer.

queue: VecDeque<QueuedFetch>

Fetch queue.

Implementations

impl Session

pub fn outbound( id: NodeId, addr: Address, persistent: bool, rng: Rng, limits: Limits, ) -> Self

pub fn inbound( id: NodeId, addr: Address, persistent: bool, rng: Rng, time: LocalTime, limits: Limits, ) -> Self

pub fn is_connecting(&self) -> bool

pub fn is_stable(&self) -> bool

pub fn is_connected(&self) -> bool

pub fn is_disconnected(&self) -> bool

pub fn is_initial(&self) -> bool

pub fn is_at_capacity(&self) -> bool

pub fn is_fetching(&self, rid: &RepoId) -> bool

pub fn queue_fetch(&mut self, fetch: QueuedFetch) -> Result<(), QueueError>

Queue a fetch. Returns true if it was added to the queue, and false if it already was present in the queue.

pub fn dequeue_fetch(&mut self) -> Option<QueuedFetch>

pub fn attempts(&self) -> usize

pub fn idle(&mut self, now: LocalTime)

Run ‘idle’ task for session.

pub fn fetching(&mut self, rid: RepoId)

Mark this session as fetching the given RID.

Panics

If it is already fetching that RID, or the session is disconnected.

pub fn fetched(&mut self, rid: RepoId)

pub fn to_attempted(&mut self)

pub fn to_connected(&mut self, since: LocalTime)

pub fn to_disconnected(&mut self, since: LocalTime, retry_at: LocalTime)

Move the session state to “disconnected”. Returns any pending RID that was requested.

pub fn to_initial(&mut self)

Return to initial state from disconnected state. This state transition happens when we attempt to re-connect to a disconnected peer.

pub fn ping( &mut self, since: LocalTime, reactor: &mut Outbox, ) -> Result<(), Error>

Trait Implementations

impl Clone for Session

fn clone(&self) -> Session

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Session

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

Formats the value using the given formatter.

impl Display for Session

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

Formats the value using the given formatter.

impl From<&Session> for Session

fn from(s: &Session) -> Self

Converts to this type from the input type.