Struct kompact::net::Bridge

pub struct Bridge { /* fields omitted */ }

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

Methods

impl Bridge

pub fn new(
    lookup: Arc<ArcSwap<ActorStore>>,
    network_thread_log: KompactLogger,
    bridge_log: KompactLogger,
    addr: SocketAddr,
    dispatcher_ref: DispatcherRef
) -> (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 NetworkEvents 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<(), NetworkBridgeErr>

Stops the bridge

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

Returns the local address if already bound

pub fn route(
    &self,
    addr: SocketAddr,
    serialized: SerialisedFrame
) -> Result<(), NetworkBridgeErr>

Forwards serialized to the NetworkThread and makes sure that it will wake up.

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

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

Errors

If the provided protocol is not supported