streamweave_transformers/
lib.rs

1#![doc = include_str!("../README.md")]
2
3// Declare all transformer modules
4// Note: Directory names use hyphens, but Rust modules use underscores
5#[path = "batch/mod.rs"]
6pub mod batch;
7#[path = "circuit-breaker/mod.rs"]
8pub mod circuit_breaker;
9#[path = "filter/mod.rs"]
10pub mod filter;
11#[path = "group-by/mod.rs"]
12pub mod group_by;
13#[path = "interleave/mod.rs"]
14pub mod interleave;
15#[path = "limit/mod.rs"]
16pub mod limit;
17#[path = "map/mod.rs"]
18pub mod map;
19#[path = "merge/mod.rs"]
20pub mod merge;
21#[path = "message-dedupe/mod.rs"]
22pub mod message_dedupe;
23#[cfg(feature = "ml")]
24#[path = "ml/mod.rs"]
25pub mod ml;
26#[path = "moving-average/mod.rs"]
27pub mod moving_average;
28#[path = "ordered-merge/mod.rs"]
29pub mod ordered_merge;
30#[path = "partition/mod.rs"]
31pub mod partition;
32#[path = "rate-limit/mod.rs"]
33pub mod rate_limit;
34#[path = "reduce/mod.rs"]
35pub mod reduce;
36#[path = "retry/mod.rs"]
37pub mod retry;
38#[path = "round-robin/mod.rs"]
39pub mod round_robin;
40#[path = "router/mod.rs"]
41pub mod router;
42#[path = "running-sum/mod.rs"]
43pub mod running_sum;
44#[path = "sample/mod.rs"]
45pub mod sample;
46#[path = "skip/mod.rs"]
47pub mod skip;
48#[path = "sort/mod.rs"]
49pub mod sort;
50#[path = "split/mod.rs"]
51pub mod split;
52#[path = "split-at/mod.rs"]
53pub mod split_at;
54#[path = "take/mod.rs"]
55pub mod take;
56#[path = "timeout/mod.rs"]
57pub mod timeout;
58#[path = "zip/mod.rs"]
59pub mod zip;
60
61// Note: We don't glob re-export to avoid naming conflicts (many transformers export
62// modules named `input`, `output`, `transformer`, etc.). Access transformers via
63// their module paths, e.g.:
64//   use streamweave_transformers::map::MapTransformer;
65//   use streamweave_transformers::running_sum::RunningSumTransformer;