Skip to main content

spawn_tcp_bridge

ghostlink_core::runtime

Function spawn_tcp_bridge 

Source 
pub fn spawn_tcp_bridge(
    source_stage: usize,
    input_rx: Receiver<TransportBatch>,
    output_tx: SyncSender<TransportBatch>,
    config: TcpTransportConfig,
    listener: BridgeListener,
    addr: BridgeAddr,
) -> JoinHandle<BridgeAccumulator>
Expand description

Spawn a TCP transport bridge between pipeline stages.

In a multi-node deployment, the bind_addr and connect_addr can point to different physical interfaces or remote hosts.