Struct Server

Source

pub struct Server {Show 14 fields
    key: PublicKey,
    conf: Arc<Config>,
    role: Role,
    msgid: MsgId,
    lower_bound: Slot,
    parties: HashMap<PublicKey, Party>,
    ibound: UnboundedSender<(PublicKey, Bytes, Option<OwnedSemaphorePermit>)>,
    obound: UnboundedReceiver<Command>,
    next_slot: Receiver<Slot>,
    accept_tasks: JoinSet<Result<Connection, NetworkError>>,
    hello_tasks: JoinMap<PublicKey, Result<(Hello, Connection, Hello), NetworkError>>,
    connect_tasks: JoinMap<PublicKey, Connection>,
    peer_tasks: JoinMap<PublicKey, Peer>,
    metrics: Arc<dyn Metrics>,
}

Fields§

§key: PublicKey§conf: Arc<Config>§role: Role§msgid: MsgId§lower_bound: Slot§parties: HashMap<PublicKey, Party>§ibound: UnboundedSender<(PublicKey, Bytes, Option<OwnedSemaphorePermit>)>§obound: UnboundedReceiver<Command>§next_slot: Receiver<Slot>§accept_tasks: JoinSet<Result<Connection, NetworkError>>§hello_tasks: JoinMap<PublicKey, Result<(Hello, Connection, Hello), NetworkError>>§connect_tasks: JoinMap<PublicKey, Connection>§peer_tasks: JoinMap<PublicKey, Peer>§metrics: Arc<dyn Metrics>

Struct Server Copy item path

Fields§

Implementations§

impl Server

pub(super) fn spawn( conf: Arc<Config>, listener: TcpListener, role: Role, tx: UnboundedSender<(PublicKey, Bytes, Option<OwnedSemaphorePermit>)>, rx: UnboundedReceiver<Command>, sx: Receiver<Slot>, metrics: Arc<dyn Metrics>, ) -> JoinHandle<()>

async fn run(self, listener: TcpListener)

fn spawn_connect(&mut self, key: PublicKey, addr: NetAddr)

fn spawn_accept(&mut self, stream: TcpStream)

fn spawn_hello(&mut self, conn: Connection, ours: Hello)

fn spawn_peer(&mut self, key: PublicKey, peer: Peer)

fn next_msgid(&mut self) -> MsgId

Auto Trait Implementations§

impl Freeze for Server

impl !RefUnwindSafe for Server

impl Send for Server

impl Sync for Server

impl Unpin for Server

impl UnsafeUnpin for Server

impl !UnwindSafe for Server

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

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

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