Enum chamomile_types::message::SendMessage

pub enum SendMessage {
    PeerJoinResult(PeerId, bool, bool, Vec<u8>),
    PeerConnect(PeerId, Option<SocketAddr>, Vec<u8>),
    PeerDisconnect(PeerId),
    Connect(SocketAddr, Option<Vec<u8>>),
    DisConnect(SocketAddr),
    Data(PeerId, Vec<u8>),
    Broadcast(Broadcast, Vec<u8>),
    Stream(u32, StreamType),
}

main send message for outside channel, send from outside to chamomile.

Variants

PeerJoinResult(PeerId, bool, bool, Vec<u8>)

(permissioned only) when peer request for join, outside decide connect or not. params is peer_id, is_connect, is_force_close, result info. if is_connect is true, it will add to white directly list. we want to build a better network, add a is_force_close. if is_connect is false, but is_force_close if true, we will use this peer to build our DHT for better connection. if false, we will force close it.

PeerConnect(PeerId, Option<SocketAddr>, Vec<u8>)

when need add a peer to stable connect, send to chamomile from outside. if success connect, will start a stable connection, and add peer to kad, stables, bootstraps and whitelists. if failure, will send PeerLeave to outside. params is peer_id, socket_addr and peer join_info.

PeerDisconnect(PeerId)

when outside want to close a stable connectioned peer. use it force close. params is peer_id.

Connect(SocketAddr, Option<Vec<u8>>)

when outside want to connect a peer. will try connect directly. if connected, chamomile will add to kad and bootstrap. if join_info is none, chamomile will use config's join_data as default. params is socket_addr, join_info.

DisConnect(SocketAddr)

when outside donnot want to connect peer. use it to force close. it will remove from kad and bootstrap list. params is socket_addr.

Data(PeerId, Vec<u8>)

when need send a data to a peer, only need know the peer_id, the chamomile will help you send data to there. params is peer_id and data_bytes.

Broadcast(Broadcast, Vec<u8>)

when need broadcast a data to all network, chamomile support some common algorithm, use it, donnot worry. params is broadcast_type and data_bytes

Stream(u32, StreamType)

Apply for build a stream between nodes. params is u32 stream symbol, and StreamType.

Trait Implementations

impl Clone for SendMessage

fn clone(&self) -> SendMessage

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SendMessage

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

Formats the value using the given formatter.

impl Eq for SendMessage

impl PartialEq<SendMessage> for SendMessage

fn eq(&self, other: &SendMessage) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &SendMessage) -> bool

This method tests for !=.

impl StructuralEq for SendMessage

impl StructuralPartialEq for SendMessage