Function run

src/storage/examples/upsert_open_loop.rs:299–331

(args: Args)

}

pub async fn run(args: Args) -> Result<(), anyhow::Error> {
    let metrics_registry = MetricsRegistry::new();
    {
        let metrics_registry = metrics_registry.clone();
        info!(
            "serving internal HTTP server on http://{}/metrics",
            args.internal_http_listen_addr
        );

        let listener = TcpListener::bind(&args.internal_http_listen_addr)
            .await
            .expect("can bind");
        mz_ore::task::spawn(
            || "http_server",
            axum::serve(
                listener,
                axum::Router::new()
                    .route(
                        "/metrics",
                        axum::routing::get(move |headers: axum::http::HeaderMap| async move {
                            mz_http_util::handle_prometheus(&metrics_registry, headers).await
                        }),
                    )
                    .into_make_service(),
            )
            .into_future(),
        );
    }

    let num_sources = args.num_sources;
    let num_workers = args.num_timely_workers;
    run_benchmark(args, metrics_registry, num_sources, num_workers).await
}

async fn run_benchmark(
    args: Args,