Module net

Re-exports

pub use message::Message;

pub use message_publisher::MessageSubscription;

pub use channel::ChannelPtr;

pub use p2p::P2p;

pub use p2p::P2pPtr;

pub use protocol::protocol_base::ProtocolBase;

pub use protocol::protocol_base::ProtocolBasePtr;

pub use protocol::protocol_jobs_manager::ProtocolJobsManager;

pub use protocol::protocol_jobs_manager::ProtocolJobsManagerPtr;

pub use settings::BanPolicy;

pub use settings::Settings;

Modules

acceptor

Handles the acceptance of inbound socket connections. Used to start listening on a local socket, to accept incoming connections, and to handle network errors.

channel

Async channel that handles the sending of messages across the network. Public interface is used to create new channels, to stop and start a channel, and to send messages.

connector

Handles the creation of outbound connections. Used to establish an outbound connection.

dnet

Optional events based debug-notify subsystem. Off by default. Enabled in P2P instance, and then call p2p.dnet_sub() to start receiving events.

hosts

Hosts are a list of network addresses used when establishing outbound connections.

message

Defines how to decode generic messages as well as implementing the common network messages that are sent between nodes as described by the protocol submodule.

message_publisher

Generic publish/subscribe class that can dispatch any kind of message to a subscribed list of dispatchers.

metering

Metering related definitions.

p2p

P2P provides all core functionality to interact with the P2P network.

protocol

Defines the networking protocol used at each stage in a connection. Consists of a series of messages that are sent across the network at the different connection stages.

session

Defines the interaction between nodes during a connection.

settings

Network configuration settings. This holds the configured P2P instance behaviour and is controlled by clients of this API.

transport

Network transports, holds implementations of pluggable transports. Exposes agnostic dialers and agnostic listeners.