Skip to main content

tl_stream/
lib.rs

1// ThinkingLanguage — Streaming & Pipeline Engine
2// Licensed under Apache-2.0
3//
4// Phase 4: Provides streaming data processing, ETL pipelines,
5// connectors, windowing, lineage tracking, alerting, and metrics.
6// Phase 34: Agent definitions.
7
8pub mod agent;
9pub mod alert;
10pub mod connector;
11pub mod lineage;
12pub mod metrics;
13pub mod pipeline;
14pub mod schedule;
15pub mod stream;
16pub mod window;
17
18pub use agent::{AgentDef, AgentTool};
19pub use alert::{AlertTarget, send_alert};
20pub use connector::{ChannelConnector, Connector, ConnectorConfig, create_connector};
21pub use lineage::{LineageNode, LineageTracker};
22pub use metrics::MetricsRegistry;
23pub use pipeline::{PipelineDef, PipelineResult, PipelineRunner, PipelineStatus};
24pub use schedule::parse_duration;
25pub use stream::{StreamDef, StreamEvent, StreamRunner};
26pub use window::{WindowState, WindowType};