FortifyNet Proxy v2

1use fortifynet_proxy::{start_proxy_server, ProxyConfig};
2use log::info;
3
4#[tokio::main]
5async fn main() -> anyhow::Result<()> {
6    // Initialize the logger
7    env_logger::init();
8
9    // Create a proxy configuration
10    let config = ProxyConfig {
11        ip_address: "127.0.0.1".to_string(),
12        port: 8080,
13        authentication: false,
14        username: "admin".to_string(),
15        password: "password".to_string(),
16        cache_enabled: true,
17        socks5_address: None,
18        https_enabled: false,
19        certificate_path: None,
20        private_key_path: None,
21        target_address: Some("http://localhost".to_string())
22    };
23
24    // Log the configuration
25    info!("Starting Proxy server with configuration: {:?}", config);
26
27    // Start the proxy server
28    start_proxy_server(config).await?;
29
30    Ok(())
31}

1// Example of accessing metrics programmatically
2use fortifynet_proxy::metrics::{get_total_requests, get_average_response_time, get_cache_hit_rate};
3
4async fn print_metrics() {
5    let total_requests = get_total_requests().await;
6    let avg_response_time = get_average_response_time().await;
7    let cache_hit_rate = get_cache_hit_rate().await;
8    
9    println!("Total Requests: {}", total_requests);
10    println!("Average Response Time: {} ms", avg_response_time);
11    println!("Cache Hit Rate: {}%", cache_hit_rate * 100.0);
12    
13    // You can also subscribe to real-time metrics updates
14    let mut metrics_stream = subscribe_to_metrics().await;
15    while let Some(metric) = metrics_stream.next().await {
16        println!("Metric update: {:?}", metric);
17    }
18}