import time import threading from dataclasses import dataclass, field from typing import Callable, Dict, List
use sqlx::PgPool; use std::time::Duration; use tokio::sync::mpsc; #[derive(Debug, Clone)] pub struct MetricPoint {