Struct SimpleServiceRegistry

pub struct SimpleServiceRegistry { /* private fields */ }

Implementations

impl SimpleServiceRegistry

pub fn new(default_tcp: SocketAddr, default_tls: SocketAddr) -> Self

Examples found in repository

examples/benchmark_clients.rs (line 92)

async fn main() {
    let args: Args = argh::from_env();

    #[cfg(feature = "quic")]
    rustls::crypto::ring::default_provider().install_default().expect("should install ring as default");

    //if RUST_LOG env is not set, set it to info
    let level = match std::env::var("RUST_LOG") {
        Ok(v) => LevelFilter::from_str(&v).unwrap_or(LevelFilter::Info),
        _ => LevelFilter::Info,
    };
    PicoLogger::new(level).init();

    let registry = SimpleServiceRegistry::new(args.http_dest, args.https_dest);
    let registry = Arc::new(registry);

    for client in 0..args.clients {
        let args_c = args.clone();
        let registry = registry.clone();
        tokio::spawn(async move {
            connect(client, args_c, registry).await;
        });
        sleep(Duration::from_millis(args.connect_wait_ms)).await;
    }

    loop {
        sleep(Duration::from_millis(1000)).await;
    }
}

pub fn set_tcp_service(&mut self, service: u16, dest: SocketAddr)

pub fn set_tls_service(&mut self, service: u16, dest: SocketAddr)

Trait Implementations

impl ServiceRegistry for SimpleServiceRegistry

fn dest_for( &self, tls: bool, service: Option<u16>, _domain: &str, ) -> Option<SocketAddr>