grapevine 1.0.0

A modern, asynchronous peer-to-peer gossip protocol library and application
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! Network transport implementations.

pub mod tcp;
use std::net::SocketAddr;

use async_trait::async_trait;
use bytes::Bytes;
use serde::{Deserialize, Serialize};
pub use tcp::Tcp;

use crate::Result;

/// Trait for network transports.
#[async_trait]
pub trait Transport: Send + Sync {
    /// Listen on an address.
    async fn listen(&mut self, addr: SocketAddr) -> Result<()>;

    /// Connect to a peer.
    async fn connect(mut self, addr: SocketAddr) -> Result<()>;

    /// Send data to a peer.
    async fn send(&self, peer: SocketAddr, data: Bytes) -> Result<()>;

    /// Receive data from any peer.
    async fn recv(&mut self) -> Result<(SocketAddr, Bytes)>;
}

/// Transport protocol configuration.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum TransportConfig {
    /// TCP transport
    Tcp,
}