1mod dispatcher;
16pub mod error;
17mod etl;
18mod manager;
19mod metrics;
20mod tablesuffix;
21
22pub use etl::ctx_req::{ContextOpt, ContextReq};
23pub use etl::processor::Processor;
24pub use etl::transform::transformer::greptime::{GreptimePipelineParams, SchemaInfo};
25pub use etl::transform::transformer::identity_pipeline;
26pub use etl::transform::GreptimeTransformer;
27pub use etl::value::{Array, Map, Timestamp, Value};
28pub use etl::{
29 json_array_to_map, json_to_map, parse, simd_json_array_to_map, simd_json_to_map, Content,
30 DispatchedTo, Pipeline, PipelineExecOutput, TransformedOutput, TransformerMode,
31};
32pub use manager::{
33 pipeline_operator, table, util, IdentityTimeIndex, PipelineContext, PipelineDefinition,
34 PipelineInfo, PipelineRef, PipelineTableRef, PipelineVersion, PipelineWay, SelectInfo,
35 GREPTIME_INTERNAL_IDENTITY_PIPELINE_NAME, GREPTIME_INTERNAL_TRACE_PIPELINE_V1_NAME,
36};
37
38#[macro_export]
39macro_rules! unwrap_or_continue_if_err {
40 ($result:expr, $condition:expr) => {{
41 match $result {
42 Ok(value) => value,
43 Err(e) => {
44 if $condition {
45 continue;
46 } else {
47 return Err(e);
48 }
49 }
50 }
51 }};
52}