wf-examples — wfusion 场景 / 基准用例集

wfusion（warp-fusion + wp-reactor）的可运行场景与性能基准仓库：从最简管道、运维 控制面，到 NEXMark 对标与规则规模/内存稳定性验证。每个 case 自带规则、场景、配置与 一键脚本，可直接复跑并产出数据。

配套仓库（构建产物使用方）：

仓库	提供	消费方式
warp-fusion	wfusion（daemon/CLI）与 wfgen（编译/注入/诊断）二进制	case 脚本默认取 PATH（可用 WFUSION=/path WFGEN=/path 覆盖）
wp-reactor	wf-engine/wf-runtime/wf-lang 引擎（warp-fusion 以 path 依赖引用）	引擎修复会改变 case 结论——case README 注明所需引擎版本（如 memory_stability 依赖 727cbfe）

目录导航

目录	定位	入口
getting_started/	最简：一条命令验证完整 CEP 管道（batch + daemon）	./run.sh
baseline/	在线行为基线 step 1：stats（含 sumsq）生成 BaselineRecord 落文件（n/sum/sum_sq）	./smoke.sh
nginx_log_stats/	Nginx access 日志统计分析最小示例：stats 窗口报表 + 5xx 突发告警	./run.sh
core/remote_ctrl/	远端规则仓库同步 + 规则版本切换 + admin_api 热重载（L1/L2/blocked）全链路	./run.sh
core/meta_disable/	meta/spill 关闭路径冒烟	./smoke.sh
connectors/	sink/source 连接器配置样例（blackhole/file/doris/syslog/tcp…）	供 case topology/ 引用
performance/nexmark_pk/	NEXMark Q1–Q22：吞吐 PK（bench）+ 墙定位（diag）+ 正确性对拍（verify）	./bench.sh ./diag.sh ./verify_daemon.sh
performance/rule_scale_test/	合成大规则集规模测试（376 规则高压吞吐；规则家族成本/二分；内置 #18 object 驱逐门禁）	./run.sh ./diag.sh ./sweep.sh
performance/common_rules_100/	100 条常见 SOC 检测规则（爆破/扫描/C2/DGA/Web 攻击…）真实语义负载	./run.sh
performance/perf_diag_case/	perf-diag 诊断机制的独立验证（有区分度的墙梯）	./verify.sh
performance/memory_stability/	长跑内存稳定性：idle 实例 TTL 释放 + allocator 口径泄漏检测	`./run.sh [smoke
performance/scripts/	共享 python 库：bench_lib.py（度量/注入）、diag_analyze.py（墙表/墙判定）、diag_mem_analyze.py、rule_phase_profile.py	被各 case 的 shell 脚本调用

快速开始

# 1) 构建工具并放入 PATH（warp-fusion）：
#    cargo build --release -p wfusion -p wfgen
#    ln -s .../warp-fusion/target/release/{wfusion,wfgen} ~/bin/

# 2) 最简管道验证（~1 分钟）
cd getting_started && ./run.sh

# 3) 进入各 case（详见各自 README）
cd ../performance/nexmark_pk && ./bench.sh q1 replay 10m   # NEXMark q1 吞吐
cd ../performance/memory_stability && ./run.sh --leak      # 内存泄漏检测

通用约定

• 模式：性能/验证 case 以 wfusion daemon（TCP 实时注入 + 指标上报）为主路径； 正确性类（nexmark verify、perf_diag_case）走 wfgen 对拍/哨兵机制。
• 产物：落在各 case 的 data/（已 gitignore）；指标 metrics.ndjson、日志 daemon.log/wfusion.log 可事后分析。
• 口径：EPS/内存判定定义见各 case README 与 performance/scripts/ 实现；基准数据 注明机器与引擎版本（跨机/跨版本对比需同口径）。
• 端口：各 case 用自带 TCP 注入端口（多数 9800），同机并发前确认空闲。

变更记录

见 CHANGELOG.md（performance/verification 场景改动、实测数据与结论修正均按日期归档）。