Rust microservices skeleton + integration tests + telemetry
This service bundles mongodb and other necessary infrastructure to run locally.
After making code updates, simply start service with the following commands:
$ docker-compose build
$ docker-compose upDownload and run autocannon with the appropriate parameters.
$ autocannon -c 100 -d 5 -p 10 http://0.0.0.0:3002
Running 5s test @ http://0.0.0.0:3002
100 connections with 10 pipelining factor
┌─────────┬──────┬──────┬────────┬────────┬──────────┬──────────┬───────────┐
│ Stat │ 2.5% │ 50% │ 97.5% │ 99% │ Avg │ Stdev │ Max │
├─────────┼──────┼──────┼────────┼────────┼──────────┼──────────┼───────────┤
│ Latency │ 0 ms │ 0 ms │ 320 ms │ 361 ms │ 27.74 ms │ 86.25 ms │ 565.66 ms │
└─────────┴──────┴──────┴────────┴────────┴──────────┴──────────┴───────────┘
┌───────────┬────────┬────────┬────────┬────────┬────────┬─────────┬────────┐
│ Stat │ 1% │ 2.5% │ 50% │ 97.5% │ Avg │ Stdev │ Min │
├───────────┼────────┼────────┼────────┼────────┼────────┼─────────┼────────┤
│ Req/Sec │ 3261 │ 3261 │ 3481 │ 3711 │ 3499 │ 162.29 │ 3260 │
├───────────┼────────┼────────┼────────┼────────┼────────┼─────────┼────────┤
│ Bytes/Sec │ 571 kB │ 571 kB │ 609 kB │ 650 kB │ 612 kB │ 28.4 kB │ 571 kB │
└───────────┴────────┴────────┴────────┴────────┴────────┴─────────┴────────┘
Req/Bytes counts sampled once per second.
17k requests in 5.06s, 3.06 MB readFor this, we need to install cargo-watch written in Rust and available on crates.io, so we can install it with cargo.
$ cargo install cargo-watch// src/main.rs// dependenciesuse color_eyre::Result;use std::net::TcpListener;// module definitions// use module dependenciesuse miru::configuration::get_configuration;use miru::startup::run;use miru::telemetry::{get_subscriber, init_subscriber};#[actix_web::main]asyncfnmain() -> Result<()>{// setup tracing subscriberlet subscriber = get_subscriber("miru".into(),"info".into(), std::io::stdout);init_subscriber(subscriber);// Get app config settingslet config = get_configuration();// bind TCP listener to specified socket addresslet listener = TcpListener::bind(format!("{}:{}", config.app.host, config.app.port)).expect("Failed to bind random port");// Run serverrun(listener)?.await?;Ok(())}