Function mz_storage::boundary::tcp_boundary::server::serve

source · [−]

pub async fn serve<A: ToSocketAddrs + Display>(
    addr: A, 
    storage_workers: usize
) -> Result<(TcpEventLinkHandle, UnboundedReceiver<SourceInstanceRequest>, JoinHandle<Result<()>>)>

Expand description

Start the boundary server listening for connections on addr.

Returns a handle implementing StorageCapture and a join handle to await termination.