wp-core-connectors 0.1.4

Core connector registry and sink runtimes for WarpParse
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

//! Syslog 源常量与类型别名（统一复用 tcp::framing 定义）

use wp_conf_base::ConfParser;
use wp_connector_api::Tags;

pub use crate::sources::tcp::framing::{DEFAULT_TCP_RECV_BYTES, Message, STOP_CHANNEL_CAPACITY};

/// Default UDP receive buffer size (8 MB)
pub const DEFAULT_UDP_RECV_BUFFER: usize = 8 * 1024 * 1024;

/// Extract tags from `Vec<String>` items (k:v / k=v / flag)
#[allow(dead_code)]
pub fn tags_from_vec(items: &[String]) -> Tags {
    Tags::from_parse(items)
}