From 0d1e6a7b95c4d1df2ab48bcf16a1afaa77d00371 Mon Sep 17 00:00:00 2001
From: dajiaohuang <mikewushuwen@outlook.com>
Date: Sun, 23 Aug 2026 23:21:41 +0800
Subject: [PATCH] fix(fluentd): parse retry queue length from yaml

---
 lib/vey-fluentd/src/config/yaml.rs | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/lib/vey-fluentd/src/config/yaml.rs b/lib/vey-fluentd/src/config/yaml.rs
index 55b8316da..012c9d667 100644
--- a/lib/vey-fluentd/src/config/yaml.rs
+++ b/lib/vey-fluentd/src/config/yaml.rs
@@ -96,6 +96,12 @@ impl FluentdClientConfig {
                         config.set_flush_interval(interval);
                         Ok(())
                     }
+                    "retry_queue_len" => {
+                        let len = vey_yaml::value::as_usize(v)
+                            .context(format!("invalid usize value for key {k}"))?;
+                        config.set_retry_queue_len(len);
+                        Ok(())
+                    }
                     _ => Err(anyhow!("invalid key {k}")),
                 })?;
 
@@ -143,6 +149,7 @@ mod tests {
                 connect_delay: "1s"
                 write_timeout: "500ms"
                 flush_interval: "100ms"
+                retry_queue_len: 64
             "#
         );
         let config = FluentdClientConfig::parse_yaml(&yaml, None).unwrap();
@@ -170,6 +177,7 @@ mod tests {
         assert_eq!(config.connect_delay, std::time::Duration::from_secs(1));
         assert_eq!(config.write_timeout, std::time::Duration::from_millis(500));
         assert_eq!(config.flush_interval, std::time::Duration::from_millis(100));
+        assert_eq!(config.retry_queue_len, 64);
 
         let yaml = yaml_doc!(
             r#"