changed port
This commit is contained in:
@@ -290,7 +290,7 @@ impl MetricsCollector {
|
|||||||
async fn collect_and_send_loop(&mut self, base_url: &str) -> Result<(), Box<dyn Error>> {
|
async fn collect_and_send_loop(&mut self, base_url: &str) -> Result<(), Box<dyn Error>> {
|
||||||
let client = Client::new();
|
let client = Client::new();
|
||||||
let url = format!("{}/monitoring/metric", base_url);
|
let url = format!("{}/monitoring/metric", base_url);
|
||||||
let mut interval = interval(Duration::from_secs(30));
|
let mut interval = interval(Duration::from_secs(20));
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
interval.tick().await;
|
interval.tick().await;
|
||||||
@@ -426,7 +426,7 @@ fn get_network_traffic() -> Option<(u64, u64)> {
|
|||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() -> Result<(), Box<dyn Error>> {
|
async fn main() -> Result<(), Box<dyn Error>> {
|
||||||
let server_base_url = "http://localhost:5258";
|
let server_base_url = "http://localhost:5000";
|
||||||
|
|
||||||
// Registration phase
|
// Registration phase
|
||||||
println!("Starting registration process...");
|
println!("Starting registration process...");
|
||||||
|
Reference in New Issue
Block a user