wp-core-connectors 0.5.2

Core connector registry and sink runtimes for WarpParse
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

//! TCP 源实现 - 高性能分离式架构
//!
//! 模块结构：
//! - framing.rs：TCP消息分帧处理（行/长度前缀/自动检测）
//! - source.rs：TcpSource 实现，直接管理监听 loop 交付的 sockets
//! - factory.rs：参数解析与 TcpSourceFactory
//! - zc_types.rs：零拷贝数据结构

use std::collections::HashSet;
use std::sync::{Arc, Mutex};

pub mod acceptor;
pub mod config;
pub mod conn;
pub mod factory;
pub mod framing;
pub mod source;
pub mod worker;
pub mod zc;
pub use acceptor::TcpAcceptor;
pub use factory::{TcpSourceFactory, register_tcp_factory};
pub use framing::FramingMode;
pub use source::TcpSource;

// 零拷贝类型导出
pub use zc::types::{
    BatchConfig, BufferPoolMetrics, BufferStats, MessageBatch, ZcpConfig, ZcpMessage, ZcpResult,
    ZeroCopyError,
};

pub(crate) type ConnectionRegistry = Arc<Mutex<HashSet<u64>>>;
pub(crate) const TCP_READER_BATCH_CAP_DEFAULT: usize = 32;

pub(crate) fn tcp_reader_batch_channel_cap() -> usize {
    TCP_READER_BATCH_CAP_DEFAULT
}