Struct Bridge 

pub struct Bridge { /* private fields */ }

Bridge to Network Threads. Routes outbound messages to the correct network thread. Single threaded for now.

Implementations

impl Bridge

pub fn new( lookup: Arc<ArcSwap<ActorStore>>, network_thread_log: KompactLogger, bridge_log: KompactLogger, addr: SocketAddr, dispatcher_ref: DispatcherRef, network_config: &NetworkConfig, ) -> (Self, SocketAddr)

Creates a new bridge

Returns

A tuple consisting of the new Bridge object and the network event receiver. The receiver will allow responding to [NetworkEvent]s for external state management.

pub fn set_dispatcher( &mut self, dispatcher: DispatcherRef, ) -> Option<DispatcherRef>

Sets the dispatcher reference, returning the previously stored one

pub fn stop(self) -> Result<(), NetworkBridgeError>

Stops the bridge gracefully

pub fn kill(self) -> Result<(), NetworkBridgeError>

Kills the Network

pub fn local_addr(&self) -> &Option<SocketAddr>

Returns the local address if already bound

pub fn connect( &self, proto: Transport, addr: SocketAddr, ) -> Result<(), NetworkBridgeError>

Attempts to establish a TCP connection to the provided addr.

Side effects

When the connection is successul: - a ConnectionState::Connected is dispatched on the network bridge event queue - NetworkThread will listen for incoming messages and write outgoing messages on the channel

Errors

If the provided protocol is not supported

pub fn ack_closed(&self, addr: SocketAddr) -> Result<(), NetworkBridgeError>

Acknowledges a closed channel, required to ensure FIFO ordering under connection loss

pub fn close_channel(&self, addr: SocketAddr) -> Result<(), NetworkBridgeError>

Requests that the NetworkThread should be closed

pub fn block_socket(&self, addr: SocketAddr) -> Result<(), NetworkBridgeError>

Requests the NetworkThread to block the socket addr

pub fn block_ip(&self, ip_addr: IpAddr) -> Result<(), NetworkBridgeError>

Requests the NetworkThread to block the ip address ip_addr

pub fn block_ip_net(&self, ip_net: IpNet) -> Result<(), NetworkBridgeError>

Requests the NetworkThread to block the ip subnet ip_net

pub fn allow_socket(&self, addr: SocketAddr) -> Result<(), NetworkBridgeError>

Requests the NetworkThread to unblock the socket addr

pub fn allow_ip(&self, ip_addr: IpAddr) -> Result<(), NetworkBridgeError>

Requests the NetworkThread to unblock the ip address ip_addr

pub fn allow_ip_net(&self, ip_net: IpNet) -> Result<(), NetworkBridgeError>

Requests the NetworkThread to unblock the ip subnet ip_net