wingfoil 8.0.0

graph based stream processing framework
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
37
38
39
40
41
42
43
44
45

//! A library of input and output adapters

#[cfg(any(feature = "aeron", feature = "aeron-rs"))]
pub mod aeron;
#[cfg(feature = "augurs")]
pub mod augurs;
#[cfg(feature = "kdb")]
pub mod cache;
/// Shared helpers reusable across I/O adapters (e.g. the out-of-window row
/// filter for historical reads). Always compiled so any adapter can use it
/// without touching feature gates.
pub mod common;
#[cfg(feature = "csv")]
pub mod csv;
#[cfg(feature = "etcd")]
pub mod etcd;
#[cfg(feature = "fix")]
#[doc(hidden)]
pub mod fix;
#[cfg(feature = "fluvio")]
pub mod fluvio;
#[cfg(feature = "iceoryx2")]
#[doc(hidden)]
pub mod iceoryx2;
#[cfg(feature = "kafka")]
pub mod kafka;
#[cfg(feature = "kdb")]
pub mod kdb;
#[cfg(feature = "otlp")]
pub mod otlp;
#[cfg(feature = "postgres")]
pub mod postgres;
#[cfg(feature = "prometheus")]
pub mod prometheus;
#[cfg(feature = "redis")]
pub mod redis;
/// Streaming statistics operators (EWMA, weighted moments, rolling windows).
/// Pure-Rust with no external service, so it is always compiled; bring
/// [`statistics::StatisticsOperators`] into scope with
/// `use wingfoil::adapters::statistics::*` to use the fluent operators.
pub mod statistics;
#[cfg(feature = "web")]
pub mod web;
#[cfg(feature = "zmq")]
pub mod zmq;