mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-30 08:49:26 +00:00
create get default log path func
This commit is contained in:
@@ -7,7 +7,7 @@ use tracing_core::Level;
|
|||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() {
|
async fn main() {
|
||||||
let obs_conf = Some("packages/obs/examples/config.toml".to_string());
|
let obs_conf = Some("crates/obs/examples/config.toml".to_string());
|
||||||
let config = load_config(obs_conf);
|
let config = load_config(obs_conf);
|
||||||
let (_logger, _guard) = init_obs(config.clone()).await;
|
let (_logger, _guard) = init_obs(config.clone()).await;
|
||||||
let span = tracing::span!(Level::INFO, "main");
|
let span = tracing::span!(Level::INFO, "main");
|
||||||
|
|||||||
@@ -67,11 +67,24 @@ pub struct FileSinkConfig {
|
|||||||
pub flush_threshold: Option<usize>, // Refresh threshold, default 100 logs
|
pub flush_threshold: Option<usize>, // Refresh threshold, default 100 logs
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl FileSinkConfig {
|
||||||
|
pub fn get_default_log_path() -> String {
|
||||||
|
let temp_dir = env::temp_dir().join("rustfs").join("logs");
|
||||||
|
|
||||||
|
if let Err(e) = std::fs::create_dir_all(&temp_dir) {
|
||||||
|
eprintln!("Failed to create log directory: {}", e);
|
||||||
|
return "logs/app.log".to_string();
|
||||||
|
}
|
||||||
|
|
||||||
|
temp_dir.join("app.log").to_str().unwrap_or("logs/app.log").to_string()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
impl Default for FileSinkConfig {
|
impl Default for FileSinkConfig {
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
FileSinkConfig {
|
FileSinkConfig {
|
||||||
enabled: true,
|
enabled: true,
|
||||||
path: "logs/app.log".to_string(),
|
path: Self::get_default_log_path(),
|
||||||
buffer_size: Some(8192),
|
buffer_size: Some(8192),
|
||||||
flush_interval_ms: Some(1000),
|
flush_interval_ms: Some(1000),
|
||||||
flush_threshold: Some(100),
|
flush_threshold: Some(100),
|
||||||
|
|||||||
Reference in New Issue
Block a user