inklog 0.2.0

Enterprise-grade Rust logging infrastructure
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

// Copyright (c) 2026 Kirky.X
// SPDX-License-Identifier: MIT
// 大数据量性能测试

#[cfg(test)]
mod large_volume_test {
    use inklog::{FileSinkConfig, InklogConfig, LoggerManager};
    use serial_test::serial;
    use tempfile::TempDir;
    use inklog::tokio::time::sleep;
    use std::time::Duration;

    #[tokio::test]
    #[serial]
    async fn test_large_volume_writing() {
        let temp_dir = TempDir::new().unwrap();
        let log_path = temp_dir.path().join("large_volume_test.log");
        
        let config = InklogConfig {
            file_sink: Some(FileSinkConfig {
                enabled: true,
                path: log_path.clone(),
                max_size: "1GB".into(),
                batch_size: 1000,
                flush_interval_ms: 500,
                compress: true,
                ..Default::default()
            }),
            performance: inklog::config::PerformanceConfig {
                worker_threads: 4,
                channel_capacity: 50000,
                ..Default::default()
            },
            ..Default::default()
        };

        let _logger = LoggerManager::with_config(config).await.unwrap();
        
        // 写入大量数据
        for i in 0..5000 {
            log::info!(target: "large_volume", "Large volume test message {} - Data: {}", i, "x".repeat(100));
        }
        
        sleep(Duration::from_secs(2)).await;
        
        // 验证数据已写入
        assert!(log_path.exists());
        let metadata = std::fs::metadata(&log_path).unwrap();
        assert!(metadata.len() > 50000); // 至少50KB
    }
}