feat: Add config to pcap output queue size

Author: rvql

agent/src/config/config.rs

@@ -1535,6 +1535,7 @@ impl Default for TcpHeader {
 #[serde(default)]
 pub struct PcapStream {
     pub receiver_queue_size: usize,
+    pub sender_queue_size: usize,
     pub buffer_size_per_flow: u32,
     pub total_buffer_size: u64,
     #[serde(with = "humantime_serde")]
@@ -1545,6 +1546,7 @@ impl Default for PcapStream {
     fn default() -> Self {
         Self {
             receiver_queue_size: 65536,
+            sender_queue_size: 8192,
             buffer_size_per_flow: 65536,
             total_buffer_size: 88304,
             flush_interval: Duration::from_secs(60),

agent/src/trident.rs

@@ -2522,11 +2522,7 @@ impl AgentComponents {
         let pcap_batch_queue = "2-pcap-batch-to-sender";
         let (pcap_batch_sender, pcap_batch_receiver, pcap_batch_counter) =
             queue::bounded_with_debug(
-                user_config
-                    .processors
-                    .packet
-                    .pcap_stream
-                    .receiver_queue_size,
+                user_config.processors.packet.pcap_stream.sender_queue_size,
                 pcap_batch_queue,
                 &queue_debugger,
             );

server/agent_config/README-CH.md

@@ -3715,7 +3715,8 @@ inputs:
 [eBPF] INFO openssl uprobe, pid:1005, path:/proc/1005/root/usr/lib64/libssl.so.1.0.2k
 ```
 
-注意：开启此功能时，需要同时在 `inputs.proc.process_matcher` 中进一步指定具体的进程列表，
+注意：开启此功能后，Envoy mTLS 流量可自动完成追踪；
+若为非 Envoy 流量，则需要同时在 `inputs.proc.process_matcher` 中进一步指定具体的进程列表，
 即 `inputs.proc.process_matcher.[*].enabled_features` 中需要包含 `ebpf.socket.uprobe.tls`。
 
 ##### DPDK {#inputs.ebpf.socket.uprobe.dpdk}
@@ -6788,6 +6789,35 @@ processors:
 
 设置 deepflow-agent 的 1-mini-meta-packet-to-pcap 队列大小。
 
+#### Sender 队列大小 {#processors.packet.pcap_stream.sender_queue_size}
+
+**标签**:
+
+<mark>agent_restart</mark>
+<mark>ee_feature</mark>
+
+**FQCN**:
+
+`processors.packet.pcap_stream.sender_queue_size`
+
+**默认值**:
+```yaml
+processors:
+  packet:
+    pcap_stream:
+      sender_queue_size: 8192
+```
+
+**模式**:
+| Key  | Value                        |
+| ---- | ---------------------------- |
+| Type | int |
+| Range | [4096, 64000000] |
+
+**详细描述**:
+
+设置 deepflow-agent 的 2-pcap-batch-to-sender 队列大小。
+
 #### 每个 Flow 的缓冲区大小 {#processors.packet.pcap_stream.buffer_size_per_flow}
 
 **标签**:

server/agent_config/README.md

@@ -3786,7 +3786,8 @@ to the following:
 [eBPF] INFO openssl uprobe, pid:1005, path:/proc/1005/root/usr/lib64/libssl.so.1.0.2k
 ```
 
-Note: When enabling this feature, the specific process list must also be specified in `inputs.proc.process_matcher`,
+Note: When this feature is enabled, Envoy mTLS traffic can be automatically traced.
+For non-Envoy traffic, the specific process list must also be specified in `inputs.proc.process_matcher`,
 i.e., `ebpf.socket.uprobe.tls` must be included in `inputs.proc.process_matcher.[*].enabled_features`.
 
 ##### DPDK {#inputs.ebpf.socket.uprobe.dpdk}
@@ -6945,6 +6946,36 @@ processors:
 The length of the following queues:
 - 1-mini-meta-packet-to-pcap
 
+#### Sender Queue Size {#processors.packet.pcap_stream.sender_queue_size}
+
+**Tags**:
+
+<mark>agent_restart</mark>
+<mark>ee_feature</mark>
+
+**FQCN**:
+
+`processors.packet.pcap_stream.sender_queue_size`
+
+**Default value**:
+```yaml
+processors:
+  packet:
+    pcap_stream:
+      sender_queue_size: 8192
+```
+
+**Schema**:
+| Key  | Value                        |
+| ---- | ---------------------------- |
+| Type | int |
+| Range | [4096, 64000000] |
+
+**Description**:
+
+The length of the following queues:
+- 2-pcap-batch-to-sender
+
 #### Buffer Size Per Flow {#processors.packet.pcap_stream.buffer_size_per_flow}
 
 **Tags**:

server/agent_config/template.yaml

@@ -4772,6 +4772,23 @@ processors:
       receiver_queue_size: 65536
       # type: int
       # name:
+      #   en: Sender Queue Size
+      #   ch: Sender 队列大小
+      # unit:
+      # range: [4096, 64000000]
+      # enum_options: []
+      # modification: agent_restart
+      # ee_feature: true
+      # description:
+      #   en: |-
+      #     The length of the following queues:
+      #     - 2-pcap-batch-to-sender
+      #   ch: |-
+      #     设置 deepflow-agent 的 2-pcap-batch-to-sender 队列大小。
+      # upgrade_from:
+      sender_queue_size: 8192
+      # type: int
+      # name:
       #   en: Buffer Size Per Flow
       #   ch: 每个 Flow 的缓冲区大小
       # unit: