athena_rs 3.4.7

Database driver
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

//! Pipeline feature - ETL operations (source → transform → sink).
//!
//! # Structure
//! - `mod.rs` - Feature-facing re-exports for pipeline definitions and operations
//!
//! # Usage
//! The application loads and executes pipelines through this module. Pipelines reuse
//! gateway fetch/insert schemas and x-athena-client routing (currently in `src/api/pipelines/`).
//!
//! # Key Types
//! - `PipelineDefinition` - Declarative pipeline config (source, transforms, sink)
//! - `SourceConfig`, `TransformConfig`, `SinkConfig` - Pipeline stage definitions
//! - Pipeline execution happens through gateway endpoints: `POST /pipelines`

pub use crate::api::pipelines::{
    PipelineDefinition, SinkConfig, SourceConfig, TransformConfig, list_pipeline_templates,
    load_registry_from_path, run_pipeline, simulate_pipeline,
};