Struct QuickwitConfig 

pub struct QuickwitConfig {
    pub url: String,
    pub index_id: String,
    pub timeout: u64,
    pub batch_size: usize,
    pub enabled: bool,
    pub token: Option<String>,
}

Quickwit 配置

Fields

url: String

Quickwit 服务器 URL

index_id: String

索引 ID

timeout: u64

连接超时时间（秒）

batch_size: usize

批量发送大小

enabled: bool

是否启用

token: Option<String>

认证 token（可选）

Implementations

impl QuickwitConfig

pub fn new(url: String, index_id: String) -> Self

创建新的 Quickwit 配置

Examples found in repository

examples/quickwit_example.rs (line 13)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 配置 Quickwit（带 token 认证）
    let quickwit_config =
        QuickwitConfig::new("http://localhost:7280".to_string(), "log_full".to_string())
            .with_timeout(30)
            .with_batch_size(50); // 可选的认证 token

    // 使用 Builder 配置日志器，包含 Quickwit 功能
    Builder::new()
        .level(log::LevelFilter::Info)
        .use_console(true)
        .log_file("logs/quickwit_example.log".to_string())
        .log_file_max(10 * 1024 * 1024) // 10MB
        .quickwit(quickwit_config)
        .builder()?;

    loop {
        // 记录一些测试日志
        info!("这是一条信息日志，将被发送到 Quickwit");
        warn!("这是一条警告日志，包含关键信息: user_id=12345");
        error!("这是一条错误日志，错误代码: E001");

        // 记录带有结构化数据的日志
        info!(
            "用户登录成功: user={}, ip={}, timestamp={}",
            "alice",
            "192.168.1.100",
            std::time::SystemTime::now()
                .duration_since(std::time::UNIX_EPOCH)
                .unwrap()
                .as_secs()
        );

        println!("日志已记录并发送到 Quickwit（如果配置正确）");
        println!("请检查 Quickwit 索引 'log_full' 中的日志条目");

        // 确保所有异步日志都被处理
        log::logger().flush();
        std::thread::sleep(std::time::Duration::from_millis(1000));

        println!("所有日志处理完成");
        thread::sleep(time::Duration::from_secs(3));
    }

    // Ok(())
}

examples/test_quickwit.rs (lines 12-15)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("开始测试 Quickwit 连接...");
    
    // 创建 Quickwit 配置（不使用 token）
    let config = QuickwitConfig::new(
        "http://localhost:7280".to_string(),
        "log_full".to_string(),
    )
    .with_timeout(10)
    .with_batch_size(1);
    
    println!("配置: {:?}", config);
    
    // 创建客户端
    let client = match QuickwitClient::new(config) {
        Ok(client) => {
            println!("✓ Quickwit 客户端创建成功");
            client
        },
        Err(e) => {
            println!("✗ Quickwit 客户端创建失败: {}", e);
            return Err(e.into());
        }
    };
    
    // 创建测试日志条目
    let log_entry = QuickwitLogEntry {
        timestamp: std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .unwrap()
            .as_secs(),
        level: "INFO".to_string(),
        message: "测试日志条目 - Quickwit 连接测试".to_string(),
        module: Some("test_quickwit".to_string()),
        file: Some("test_quickwit.rs".to_string()),
        line: Some(42),
        process_id: Some(std::process::id()),
        thread_id: Some("main".to_string()),
        custom_fields: HashMap::new(),
    };
    
    println!("准备发送测试日志条目...");
    
    // 发送日志
    match client.send_log(&log_entry) {
        Ok(()) => {
            println!("✓ 日志发送成功！");
            println!("请检查 Quickwit 索引 'log_full' 中是否有新的日志条目");
        },
        Err(e) => {
            println!("✗ 日志发送失败: {}", e);
            println!("可能的原因:");
            println!("  1. Quickwit 服务未运行 (检查 http://localhost:7280)");
            println!("  2. 索引 'log_full' 不存在");
            println!("  3. 网络连接问题");
            println!("  4. Quickwit 配置错误");
            return Err(e.into());
        }
    }
    
    println!("测试完成！");
    Ok(())
}

pub fn with_timeout(self, timeout: u64) -> Self

设置超时时间

Examples found in repository

examples/quickwit_example.rs (line 14)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 配置 Quickwit（带 token 认证）
    let quickwit_config =
        QuickwitConfig::new("http://localhost:7280".to_string(), "log_full".to_string())
            .with_timeout(30)
            .with_batch_size(50); // 可选的认证 token

    // 使用 Builder 配置日志器，包含 Quickwit 功能
    Builder::new()
        .level(log::LevelFilter::Info)
        .use_console(true)
        .log_file("logs/quickwit_example.log".to_string())
        .log_file_max(10 * 1024 * 1024) // 10MB
        .quickwit(quickwit_config)
        .builder()?;

    loop {
        // 记录一些测试日志
        info!("这是一条信息日志，将被发送到 Quickwit");
        warn!("这是一条警告日志，包含关键信息: user_id=12345");
        error!("这是一条错误日志，错误代码: E001");

        // 记录带有结构化数据的日志
        info!(
            "用户登录成功: user={}, ip={}, timestamp={}",
            "alice",
            "192.168.1.100",
            std::time::SystemTime::now()
                .duration_since(std::time::UNIX_EPOCH)
                .unwrap()
                .as_secs()
        );

        println!("日志已记录并发送到 Quickwit（如果配置正确）");
        println!("请检查 Quickwit 索引 'log_full' 中的日志条目");

        // 确保所有异步日志都被处理
        log::logger().flush();
        std::thread::sleep(std::time::Duration::from_millis(1000));

        println!("所有日志处理完成");
        thread::sleep(time::Duration::from_secs(3));
    }

    // Ok(())
}

examples/test_quickwit.rs (line 16)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("开始测试 Quickwit 连接...");
    
    // 创建 Quickwit 配置（不使用 token）
    let config = QuickwitConfig::new(
        "http://localhost:7280".to_string(),
        "log_full".to_string(),
    )
    .with_timeout(10)
    .with_batch_size(1);
    
    println!("配置: {:?}", config);
    
    // 创建客户端
    let client = match QuickwitClient::new(config) {
        Ok(client) => {
            println!("✓ Quickwit 客户端创建成功");
            client
        },
        Err(e) => {
            println!("✗ Quickwit 客户端创建失败: {}", e);
            return Err(e.into());
        }
    };
    
    // 创建测试日志条目
    let log_entry = QuickwitLogEntry {
        timestamp: std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .unwrap()
            .as_secs(),
        level: "INFO".to_string(),
        message: "测试日志条目 - Quickwit 连接测试".to_string(),
        module: Some("test_quickwit".to_string()),
        file: Some("test_quickwit.rs".to_string()),
        line: Some(42),
        process_id: Some(std::process::id()),
        thread_id: Some("main".to_string()),
        custom_fields: HashMap::new(),
    };
    
    println!("准备发送测试日志条目...");
    
    // 发送日志
    match client.send_log(&log_entry) {
        Ok(()) => {
            println!("✓ 日志发送成功！");
            println!("请检查 Quickwit 索引 'log_full' 中是否有新的日志条目");
        },
        Err(e) => {
            println!("✗ 日志发送失败: {}", e);
            println!("可能的原因:");
            println!("  1. Quickwit 服务未运行 (检查 http://localhost:7280)");
            println!("  2. 索引 'log_full' 不存在");
            println!("  3. 网络连接问题");
            println!("  4. Quickwit 配置错误");
            return Err(e.into());
        }
    }
    
    println!("测试完成！");
    Ok(())
}

pub fn with_batch_size(self, batch_size: usize) -> Self

设置批量大小

Examples found in repository

examples/quickwit_example.rs (line 15)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 配置 Quickwit（带 token 认证）
    let quickwit_config =
        QuickwitConfig::new("http://localhost:7280".to_string(), "log_full".to_string())
            .with_timeout(30)
            .with_batch_size(50); // 可选的认证 token

    // 使用 Builder 配置日志器，包含 Quickwit 功能
    Builder::new()
        .level(log::LevelFilter::Info)
        .use_console(true)
        .log_file("logs/quickwit_example.log".to_string())
        .log_file_max(10 * 1024 * 1024) // 10MB
        .quickwit(quickwit_config)
        .builder()?;

    loop {
        // 记录一些测试日志
        info!("这是一条信息日志，将被发送到 Quickwit");
        warn!("这是一条警告日志，包含关键信息: user_id=12345");
        error!("这是一条错误日志，错误代码: E001");

        // 记录带有结构化数据的日志
        info!(
            "用户登录成功: user={}, ip={}, timestamp={}",
            "alice",
            "192.168.1.100",
            std::time::SystemTime::now()
                .duration_since(std::time::UNIX_EPOCH)
                .unwrap()
                .as_secs()
        );

        println!("日志已记录并发送到 Quickwit（如果配置正确）");
        println!("请检查 Quickwit 索引 'log_full' 中的日志条目");

        // 确保所有异步日志都被处理
        log::logger().flush();
        std::thread::sleep(std::time::Duration::from_millis(1000));

        println!("所有日志处理完成");
        thread::sleep(time::Duration::from_secs(3));
    }

    // Ok(())
}

examples/test_quickwit.rs (line 17)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("开始测试 Quickwit 连接...");
    
    // 创建 Quickwit 配置（不使用 token）
    let config = QuickwitConfig::new(
        "http://localhost:7280".to_string(),
        "log_full".to_string(),
    )
    .with_timeout(10)
    .with_batch_size(1);
    
    println!("配置: {:?}", config);
    
    // 创建客户端
    let client = match QuickwitClient::new(config) {
        Ok(client) => {
            println!("✓ Quickwit 客户端创建成功");
            client
        },
        Err(e) => {
            println!("✗ Quickwit 客户端创建失败: {}", e);
            return Err(e.into());
        }
    };
    
    // 创建测试日志条目
    let log_entry = QuickwitLogEntry {
        timestamp: std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .unwrap()
            .as_secs(),
        level: "INFO".to_string(),
        message: "测试日志条目 - Quickwit 连接测试".to_string(),
        module: Some("test_quickwit".to_string()),
        file: Some("test_quickwit.rs".to_string()),
        line: Some(42),
        process_id: Some(std::process::id()),
        thread_id: Some("main".to_string()),
        custom_fields: HashMap::new(),
    };
    
    println!("准备发送测试日志条目...");
    
    // 发送日志
    match client.send_log(&log_entry) {
        Ok(()) => {
            println!("✓ 日志发送成功！");
            println!("请检查 Quickwit 索引 'log_full' 中是否有新的日志条目");
        },
        Err(e) => {
            println!("✗ 日志发送失败: {}", e);
            println!("可能的原因:");
            println!("  1. Quickwit 服务未运行 (检查 http://localhost:7280)");
            println!("  2. 索引 'log_full' 不存在");
            println!("  3. 网络连接问题");
            println!("  4. Quickwit 配置错误");
            return Err(e.into());
        }
    }
    
    println!("测试完成！");
    Ok(())
}

pub fn with_token<T: Into<String>>(self, token: T) -> Self

设置认证 token

pub fn validate(&self) -> LogResult<()>

验证配置

Trait Implementations

impl Clone for QuickwitConfig

fn clone(&self) -> QuickwitConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QuickwitConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for QuickwitConfig

fn default() -> Self

Returns the “default value” for a type.