Struct Multicast 

pub struct Multicast { /* private fields */ }

UDP multicast adapter for LAN peer discovery and sync.

Broadcasts Gun protocol messages to the multicast group 233.255.255.255:7654 and receives messages from other peers on the same LAN. Messages exceeding the safe UDP datagram size are transparently chunked and reassembled.

Implementations

impl Multicast

pub fn new(config: Config) -> Self

Creates a new multicast adapter bound to the default group.

Panics

Panics if the multicast socket cannot be created (e.g. no network interfaces available, or port 7654 is in use).

Trait Implementations

impl Actor for Multicast

fn subscribe_to_everything(&self) -> bool

Returns true — multicast subscribes to all messages.

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: Arc<Message>, ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an incoming message.

fn pre_start<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once before the actor starts processing messages.

fn stopping<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once after the actor’s message loop exits.

fn handle_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, batch: &'life1 mut Vec<Arc<Message>>, context: &'life2 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Handle a batch of messages drained from the mailbox.

fn try_clone_storage(&self) -> Option<Box<dyn Actor>>

Attempts to produce a clone of this actor for storage read/write splitting.