1pub mod batch;
2pub mod batch_metadata;
3pub mod contexts;
4pub mod error;
5pub mod failure;
6pub mod loop_op;
7pub mod macros;
8pub mod op;
9pub mod op_metadata;
10pub mod ops;
11pub mod structured_queries;
12pub mod trigger;
13pub mod wrappers;
14
15#[cfg(test)]
16mod control_flow_tests;
17
18pub use batch::BatchOp;
19pub use contexts::{DryContext, WetContext};
20pub use error::OpError;
21pub use failure::AttributionClass;
22pub use loop_op::LoopOp;
23pub use macros::AggregationStrategy;
24pub use op::Op;
25pub use op_metadata::{OpMetadata, TriggerFuse, ValidationReport};
26pub use ops::{get_caller_trigger_name, perform, wrap_nested_op_exception};
27pub use structured_queries::{
28 generate_outline_schema, FlatOutlineEntry, ListingOutline, OutlineEntry, OutlineMetadata,
29};
30pub use trigger::*;
31pub use wrappers::logging::LoggingWrapper;
32pub use wrappers::timeout::TimeBoundWrapper;
33pub use wrappers::validating::ValidatingWrapper;
34
35pub type OpResult<T> = std::result::Result<T, OpError>;
36
37pub mod prelude {
38 pub use serde::{Deserialize, Serialize};
39 pub use serde_json;
40 pub use std::any::Any;
41 pub use std::sync::Arc;
42 pub use tracing::{debug, error, info, trace, warn};
43
44 pub use crate::{DryContext, Op, OpError, OpMetadata, OpResult, WetContext};
45 pub use async_trait::async_trait;
46 pub use chrono::{DateTime, Utc};
47 pub use std::collections::HashMap;
48}