Compare commits
No commits in common. "efb00dcf5e9dfb043af7e37f22b2bb45b82ed48e" and "ab75252e6b9a7846ded0a42f186f5eacddd196fb" have entirely different histories.
efb00dcf5e
...
ab75252e6b
|
|
@ -10,6 +10,6 @@
|
||||||
| Crate (submodule) | Progress |
|
| Crate (submodule) | Progress |
|
||||||
|---|---|
|
|---|---|
|
||||||
|`api-grub` | ✅✅✅✅✅✅✅🔲🔲🔲 |
|
|`api-grub` | ✅✅✅✅✅✅✅🔲🔲🔲 |
|
||||||
|`config-delivery` | ✅✅✅✅✅✅🔲🔲🔲🔲 |
|
|`config-delivery` | ✅✅✅✅🔲🔲🔲🔲🔲🔲 |
|
||||||
|`integrs-structs` | ✅✅✅✅✅✅🔲🔲🔲🔲 |
|
|`integrs-structs` | ✅✅✅✅✅✅🔲🔲🔲🔲 |
|
||||||
|`preproc` | ✅✅✅🔲🔲🔲🔲🔲🔲🔲 |
|
|`preproc` | 🔲🔲🔲🔲🔲🔲🔲🔲🔲🔲 |
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,4 @@
|
||||||
use std::collections::HashMap;
|
|
||||||
|
|
||||||
use serde::{Serialize, Deserialize};
|
use serde::{Serialize, Deserialize};
|
||||||
use serde_json::Value;
|
|
||||||
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
#[derive(Serialize, Deserialize, Debug)]
|
||||||
|
|
@ -24,36 +21,4 @@ impl Default for ApiConfig {
|
||||||
delay : 0,
|
delay : 0,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
// v2
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
|
||||||
pub struct ApiConfigV2 {
|
|
||||||
id : u64,
|
|
||||||
#[serde(default)]
|
|
||||||
template : Vec<Template>,
|
|
||||||
ip_address : String,
|
|
||||||
login : Option<String>,
|
|
||||||
pass : Option<String>,
|
|
||||||
api_key : Option<String>,
|
|
||||||
period : u32, // if "0" -> inf
|
|
||||||
timeout : u32, // if "0" -> no-delay
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
|
||||||
pub struct Template {
|
|
||||||
id : String,
|
|
||||||
name : String,
|
|
||||||
url : String,
|
|
||||||
#[serde(default)]
|
|
||||||
measure : Vec<String>,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
|
||||||
pub struct ProcessedEndpoint {
|
|
||||||
id : String,
|
|
||||||
name : String,
|
|
||||||
url : String,
|
|
||||||
#[serde(default)]
|
|
||||||
metrics : HashMap<String, Value>
|
|
||||||
}
|
}
|
||||||
|
|
@ -4,11 +4,3 @@ version = "0.1.0"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
anyhow = "1.0.95"
|
|
||||||
chrono = "0.4.39"
|
|
||||||
dotenv = "0.15.0"
|
|
||||||
env_logger = "0.11.6"
|
|
||||||
log = "0.4.25"
|
|
||||||
serde = { version = "1.0.217", features = ["derive"] }
|
|
||||||
serde_json = "1.0.137"
|
|
||||||
tokio = { version = "1.43.0", features = ["full"] }
|
|
||||||
|
|
|
||||||
|
|
@ -1,21 +0,0 @@
|
||||||
// mod for prpeproc config pulling and updating
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod config_unittests {
|
|
||||||
use tokio::test;
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
async fn create_unix_socket_server() { assert!(true) }
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
async fn verify_on_valid_config() { assert!(true) }
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
async fn verify_on_invalid_config() { assert!(true) }
|
|
||||||
}
|
|
||||||
|
|
@ -1,50 +0,0 @@
|
||||||
use chrono::Local;
|
|
||||||
use env_logger::Builder;
|
|
||||||
use log::LevelFilter;
|
|
||||||
use std::io::Write;
|
|
||||||
use anyhow::Result;
|
|
||||||
use log::info;
|
|
||||||
|
|
||||||
pub async fn setup_logger() -> Result<()> {
|
|
||||||
Builder::new()
|
|
||||||
.format(move |buf, record| {
|
|
||||||
writeln!(
|
|
||||||
buf,
|
|
||||||
"|{}| {} [{}] - {}",
|
|
||||||
"config-delivery",
|
|
||||||
Local::now().format("%d-%m-%Y %H:%M:%S"),
|
|
||||||
record.level(),
|
|
||||||
record.args(),
|
|
||||||
)
|
|
||||||
})
|
|
||||||
.filter(None, LevelFilter::Info)
|
|
||||||
.target(env_logger::Target::Stdout)
|
|
||||||
.init();
|
|
||||||
|
|
||||||
info!("Logger configured");
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod logger_unittests {
|
|
||||||
use tokio::test;
|
|
||||||
use super::*;
|
|
||||||
#[test]
|
|
||||||
async fn check_logger_builder() {
|
|
||||||
Builder::new()
|
|
||||||
.format(move |buf, record| {
|
|
||||||
writeln!(
|
|
||||||
buf,
|
|
||||||
"|{}| {} [{}] - {}",
|
|
||||||
"config-delivery",
|
|
||||||
Local::now().format("%d-%m-%Y %H:%M:%S"),
|
|
||||||
record.level(),
|
|
||||||
record.args(),
|
|
||||||
)
|
|
||||||
})
|
|
||||||
.filter(None, LevelFilter::Info)
|
|
||||||
.target(env_logger::Target::Stdout)
|
|
||||||
.init();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,18 +1,3 @@
|
||||||
mod config;
|
fn main() {
|
||||||
mod transform;
|
println!("Hello, world!");
|
||||||
mod logger;
|
|
||||||
|
|
||||||
use logger::setup_logger;
|
|
||||||
use dotenv::dotenv;
|
|
||||||
use anyhow::Result;
|
|
||||||
use log::info;
|
|
||||||
|
|
||||||
#[tokio::main(flavor = "multi_thread")]
|
|
||||||
async fn main() -> Result<()>{
|
|
||||||
let _ = setup_logger().await?;
|
|
||||||
|
|
||||||
info!("Pulling env vars from .env file if exists ...");
|
|
||||||
dotenv().ok();
|
|
||||||
|
|
||||||
Ok(())
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
// mod for preproccessing and transfering to the CM metrics data
|
|
||||||
Loading…
Reference in New Issue