Enum veloren_network::channel::Protocols

pub(crate) enum Protocols {
    Tcp((TcpSendProtocol<TcpDrain>, TcpRecvProtocol<TcpSink>)),
    Mpsc((MpscSendProtocol<MpscDrain>, MpscRecvProtocol<MpscSink>)),
    Quic((QuicSendProtocol<QuicDrain>, QuicRecvProtocol<QuicSink>)),
}

Variants

Tcp((TcpSendProtocol<TcpDrain>, TcpRecvProtocol<TcpSink>))

Mpsc((MpscSendProtocol<MpscDrain>, MpscRecvProtocol<MpscSink>))

Quic((QuicSendProtocol<QuicDrain>, QuicRecvProtocol<QuicSink>))

Implementations

impl Protocols

const MPSC_CHANNEL_BOUND: usize = 1_000usize

pub(crate) async fn with_tcp_connect( addr: SocketAddr, metrics: ProtocolMetricCache, ) -> Result<Self, NetworkConnectError>

pub(crate) async fn with_tcp_listen( addr: SocketAddr, cids: Arc<AtomicU64>, metrics: Arc<ProtocolMetrics>, s2s_stop_listening_r: Receiver<()>, c2s_protocol_s: UnboundedSender<(Protocols, ConnectAddr, Cid)>, ) -> Result<()>

pub(crate) fn new_tcp(stream: TcpStream, metrics: ProtocolMetricCache) -> Self

pub(crate) async fn with_mpsc_connect( addr: u64, metrics: ProtocolMetricCache, ) -> Result<Self, NetworkConnectError>

pub(crate) async fn with_mpsc_listen( addr: u64, cids: Arc<AtomicU64>, metrics: Arc<ProtocolMetrics>, s2s_stop_listening_r: Receiver<()>, c2s_protocol_s: UnboundedSender<(Protocols, ConnectAddr, Cid)>, ) -> Result<()>

pub(crate) fn new_mpsc( sender: Sender<MpscMsg>, receiver: Receiver<MpscMsg>, metrics: ProtocolMetricCache, ) -> Self

pub(crate) async fn with_quic_connect( addr: SocketAddr, config: ClientConfig, name: String, metrics: ProtocolMetricCache, ) -> Result<Self, NetworkConnectError>

pub(crate) async fn with_quic_listen( addr: SocketAddr, server_config: ServerConfig, cids: Arc<AtomicU64>, metrics: Arc<ProtocolMetrics>, s2s_stop_listening_r: Receiver<()>, c2s_protocol_s: UnboundedSender<(Protocols, ConnectAddr, Cid)>, ) -> Result<()>

pub(crate) async fn new_quic( connection: Connection, listen: bool, metrics: ProtocolMetricCache, ) -> Result<Self, ConnectionError>

pub(crate) fn split(self) -> (SendProtocols, RecvProtocols)

Trait Implementations

impl Debug for Protocols

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

Formats the value using the given formatter.

impl InitProtocol for Protocols

type CustomErr = ProtocolsError

fn initialize<'life0, 'async_trait>( &'life0 mut self, initializer: bool, local_pid: Pid, secret: u128, ) -> Pin<Box<dyn Future<Output = Result<(Pid, Sid, u128), InitProtocolError<Self::CustomErr>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,