Skip to content

Commit

Permalink
change detail
Browse files Browse the repository at this point in the history
  • Loading branch information
zhuxiujia committed Dec 28, 2023
1 parent fec4df2 commit c6bea1d
Show file tree
Hide file tree
Showing 8 changed files with 20 additions and 20 deletions.
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ members = [

[package]
name = "fast_log"
version = "1.6.10"
version = "1.6.11"
description = "Rust async log High-performance asynchronous logging"
readme = "Readme.md"
authors = ["ce <zhuxiujia@qq.com>"]
Expand Down
7 changes: 1 addition & 6 deletions example/src/bench_test_file_split.rs
Original file line number Diff line number Diff line change
Expand Up @@ -11,12 +11,7 @@ fn main() {
let _ = std::fs::remove_dir("target/logs/");
fast_log::init(
Config::new()
.file_split(
"target/logs/",
LogSize::MB(1),
KeepType::All,
LogPacker {},
)
.file_split("target/logs/", LogSize::MB(1), KeepType::All, LogPacker {})
.chan_len(Some(100000)),
)
.unwrap();
Expand Down
2 changes: 1 addition & 1 deletion example/src/custom_appender.rs
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
use fastdate::DateTime;
use fast_log::appender::{FastLogRecord, LogAppender};
use fast_log::config::Config;
use fastdate::DateTime;
use log::Level;

struct CustomLog {}
Expand Down
2 changes: 1 addition & 1 deletion example/src/custom_appender_tokio.rs
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
use fastdate::DateTime;
use fast_log::appender::{FastLogRecord, LogAppender};
use fast_log::config::Config;
use fastdate::DateTime;
use log::Level;
use tokio::runtime::Runtime;

Expand Down
1 change: 1 addition & 0 deletions example/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -6,5 +6,6 @@ fn main() {
log::info!("Commencing yak shaving{}", 0);
}
fast_log::print("Commencing print\n".into()).expect("fast log not init");
log::error!("Commencing yak shaving{}", 0);
log::logger().flush();
}
2 changes: 1 addition & 1 deletion example/src/split_log_mmap.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ fn main() {
LogPacker {},
),
)
.unwrap();
.unwrap();
for _ in 0..40000 {
log::info!("Commencing yak shaving");
}
Expand Down
11 changes: 7 additions & 4 deletions src/formats.rs
Original file line number Diff line number Diff line change
Expand Up @@ -39,10 +39,7 @@ impl RecordFormat for FastLogFormat {
arg.args,
);
} else {
arg.formated = format!(
"{:27} {} {} - {}\n",
&now, arg.level, arg.module_path, arg.args
);
arg.formated = format!("{:27} {} - {}\n", &now, arg.level, arg.args);
}
}
Command::CommandExit => {}
Expand All @@ -64,6 +61,12 @@ impl FastLogFormat {
self.display_line_level = level;
self
}

/// set time_type
pub fn set_time_type(mut self, time_type: TimeType) -> Self {
self.time_type = time_type;
self
}
}

pub struct FastLogFormatJson {
Expand Down
13 changes: 7 additions & 6 deletions src/plugin/packer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -50,10 +50,11 @@ impl Packer for ZipPacker {
let zip_file = zip_file.unwrap();
//write zip bytes data
let mut zip = zip::ZipWriter::new(zip_file);
zip.start_file(log_name, FileOptions::default()).map_err(|e|LogError::from(e.to_string()))?;
zip.start_file(log_name, FileOptions::default())
.map_err(|e| LogError::from(e.to_string()))?;
//buf reader
std::io::copy(&mut log_file, &mut zip).map_err(|e|LogError::from(e.to_string()))?;
zip.flush().map_err(|e|LogError::from(e.to_string()))?;
std::io::copy(&mut log_file, &mut zip).map_err(|e| LogError::from(e.to_string()))?;
zip.flush().map_err(|e| LogError::from(e.to_string()))?;
let finish: ZipResult<File> = zip.finish();
if finish.is_err() {
//println!("[fast_log] try zip fail{:?}", finish.err());
Expand Down Expand Up @@ -94,7 +95,7 @@ impl Packer for LZ4Packer {
//write lz4 bytes data
let mut encoder = FrameEncoder::new(lz4_file);
//buf reader
std::io::copy(&mut log_file, &mut encoder).map_err(|e|LogError::from(e.to_string()))?;
std::io::copy(&mut log_file, &mut encoder).map_err(|e| LogError::from(e.to_string()))?;
let result = encoder.finish();
if result.is_err() {
return Err(LogError::from(format!(
Expand Down Expand Up @@ -134,8 +135,8 @@ impl Packer for GZipPacker {
let zip_file = zip_file.unwrap();
//write zip bytes data
let mut zip = GzEncoder::new(zip_file, Compression::default());
std::io::copy(&mut log_file, &mut zip).map_err(|e|LogError::from(e.to_string()))?;
zip.flush().map_err(|e|LogError::from(e.to_string()))?;
std::io::copy(&mut log_file, &mut zip).map_err(|e| LogError::from(e.to_string()))?;
zip.flush().map_err(|e| LogError::from(e.to_string()))?;
let finish = zip.finish();
if finish.is_err() {
return Err(LogError::from(format!(
Expand Down

0 comments on commit c6bea1d

Please sign in to comment.