Struct exocore_transport::messages::OutMessage

pub struct OutMessage {
    pub to: Vec<Node>,
    pub expiration: Option<Instant>,
    pub connection: Option<ConnectionId>,
    pub envelope_builder: CapnpFrameBuilder<Owned>,
}

Message to be sent to one or more other nodes.

Fields

to: Vec<Node>

expiration: Option<Instant>

connection: Option<ConnectionId>

envelope_builder: CapnpFrameBuilder<Owned>

Implementations

impl OutMessage

pub fn from_framed_message<T>(
    cell: &Cell,
    to_service: ServiceType,
    frame: CapnpFrameBuilder<T>
) -> Result<OutMessage, Error> where
    T: for<'a> MessageType<'a>, 

pub fn with_to_node(self, to_node: Node) -> Self

pub fn with_to_nodes(self, nodes: Vec<Node>) -> Self

pub fn with_rendez_vous_id(self, rendez_vous_id: RendezVousId) -> Self

pub fn with_expiration(self, expiration: Option<Instant>) -> Self

pub fn with_connection(self, connection: ConnectionId) -> Self