Module erdos::communication

Re-exports

pub use crate::communication::pusher::Pusher;

pub use crate::communication::pusher::PusherT;

Modules

pusher
receivers
senders

Structs

MessageCodec	Encodes messages into bytes, and decodes bytes into SerializedMessages.
MessageHeader
SerializedMessage

Enums

CodecError	Error that is raised by the MessageCodec when messages cannot be encoded or decoded.
CommunicationError	Error raised by the communication layer.
ControlMessage
RecvEndpoint	Endpoint to be used to receive messages.
SendEndpoint	Endpoint to be used to send messages between operators.
TryRecvError

Traits

Serializable

Trait automatically derived for all messages that derive Serialize and Deserialize.

Functions

create_tcp_streams

Returns a vec of TCPStreams; one for each node pair.