1use std::{collections::HashMap, ops::Deref, sync::Arc};
5
6use crate::{AggregateFunction, GeneratorFunction, ScalarFunction};
7
8#[derive(Clone)]
9pub struct Functions(Arc<FunctionsInner>);
10
11impl Functions {
12 pub fn empty() -> Functions {
13 Functions::builder().build()
14 }
15
16 pub fn builder() -> FunctionsBuilder {
17 FunctionsBuilder(FunctionsInner {
18 scalars: HashMap::new(),
19 aggregates: HashMap::new(),
20 generators: HashMap::new(),
21 })
22 }
23
24 pub fn defaults() -> FunctionsBuilder {
25 use crate::{
26 blob, clock, date, datetime, duration, flow, is, math, meta, series, subscription, text, time,
27 };
28
29 Functions::builder()
30 .register_aggregate("math::sum", math::aggregate::sum::Sum::new)
31 .register_aggregate("math::min", math::aggregate::min::Min::new)
32 .register_aggregate("math::max", math::aggregate::max::Max::new)
33 .register_aggregate("math::avg", math::aggregate::avg::Avg::new)
34 .register_aggregate("math::count", math::aggregate::count::Count::new)
35 .register_scalar("flow_node::to_json", flow::to_json::FlowNodeToJson::new)
36 .register_scalar("clock::now", clock::now::Now::new)
37 .register_scalar("clock::set", clock::set::Set::new)
38 .register_scalar("clock::advance", clock::advance::Advance::new)
39 .register_scalar("blob::b58", blob::b58::BlobB58::new)
40 .register_scalar("blob::b64", blob::b64::BlobB64::new)
41 .register_scalar("blob::b64url", blob::b64url::BlobB64url::new)
42 .register_scalar("blob::hex", blob::hex::BlobHex::new)
43 .register_scalar("blob::utf8", blob::utf8::BlobUtf8::new)
44 .register_scalar("math::abs", math::scalar::abs::Abs::new)
45 .register_scalar("math::acos", math::scalar::acos::Acos::new)
46 .register_scalar("math::asin", math::scalar::asin::Asin::new)
47 .register_scalar("math::atan", math::scalar::atan::Atan::new)
48 .register_scalar("math::atan2", math::scalar::atan2::Atan2::new)
49 .register_scalar("math::avg", math::scalar::avg::Avg::new)
50 .register_scalar("math::ceil", math::scalar::ceil::Ceil::new)
51 .register_scalar("math::clamp", math::scalar::clamp::Clamp::new)
52 .register_scalar("math::cos", math::scalar::cos::Cos::new)
53 .register_scalar("math::e", math::scalar::euler::Euler::new)
54 .register_scalar("math::exp", math::scalar::exp::Exp::new)
55 .register_scalar("math::floor", math::scalar::floor::Floor::new)
56 .register_scalar("math::gcd", math::scalar::gcd::Gcd::new)
57 .register_scalar("math::lcm", math::scalar::lcm::Lcm::new)
58 .register_scalar("math::log", math::scalar::log::Log::new)
59 .register_scalar("math::log10", math::scalar::log10::Log10::new)
60 .register_scalar("math::log2", math::scalar::log2::Log2::new)
61 .register_scalar("math::max", math::scalar::max::Max::new)
62 .register_scalar("math::min", math::scalar::min::Min::new)
63 .register_scalar("math::mod", math::scalar::modulo::Modulo::new)
64 .register_scalar("math::pi", math::scalar::pi::Pi::new)
65 .register_scalar("math::power", math::scalar::power::Power::new)
66 .register_scalar("math::round", math::scalar::round::Round::new)
67 .register_scalar("math::sign", math::scalar::sign::Sign::new)
68 .register_scalar("math::sin", math::scalar::sin::Sin::new)
69 .register_scalar("math::sqrt", math::scalar::sqrt::Sqrt::new)
70 .register_scalar("math::tan", math::scalar::tan::Tan::new)
71 .register_scalar("math::truncate", math::scalar::truncate::Truncate::new)
72 .register_scalar("date::year", date::year::DateYear::new)
73 .register_scalar("date::month", date::month::DateMonth::new)
74 .register_scalar("date::day", date::day::DateDay::new)
75 .register_scalar("date::day_of_year", date::day_of_year::DateDayOfYear::new)
76 .register_scalar("date::day_of_week", date::day_of_week::DateDayOfWeek::new)
77 .register_scalar("date::quarter", date::quarter::DateQuarter::new)
78 .register_scalar("date::week", date::week::DateWeek::new)
79 .register_scalar("date::is_leap_year", date::is_leap_year::DateIsLeapYear::new)
80 .register_scalar("date::days_in_month", date::days_in_month::DateDaysInMonth::new)
81 .register_scalar("date::end_of_month", date::end_of_month::DateEndOfMonth::new)
82 .register_scalar("date::start_of_month", date::start_of_month::DateStartOfMonth::new)
83 .register_scalar("date::start_of_year", date::start_of_year::DateStartOfYear::new)
84 .register_scalar("date::new", date::new::DateNew::new)
85 .register_scalar("date::now", date::now::DateNow::new)
86 .register_scalar("date::add", date::add::DateAdd::new)
87 .register_scalar("date::subtract", date::subtract::DateSubtract::new)
88 .register_scalar("date::diff", date::diff::DateDiff::new)
89 .register_scalar("date::trunc", date::trunc::DateTrunc::new)
90 .register_scalar("date::age", date::age::DateAge::new)
91 .register_scalar("date::format", date::format::DateFormat::new)
92 .register_scalar("time::hour", time::hour::TimeHour::new)
93 .register_scalar("time::minute", time::minute::TimeMinute::new)
94 .register_scalar("time::second", time::second::TimeSecond::new)
95 .register_scalar("time::nanosecond", time::nanosecond::TimeNanosecond::new)
96 .register_scalar("time::new", time::new::TimeNew::new)
97 .register_scalar("time::now", time::now::TimeNow::new)
98 .register_scalar("time::add", time::add::TimeAdd::new)
99 .register_scalar("time::subtract", time::subtract::TimeSubtract::new)
100 .register_scalar("time::diff", time::diff::TimeDiff::new)
101 .register_scalar("time::trunc", time::trunc::TimeTrunc::new)
102 .register_scalar("time::age", time::age::TimeAge::new)
103 .register_scalar("time::format", time::format::TimeFormat::new)
104 .register_scalar("datetime::year", datetime::year::DateTimeYear::new)
105 .register_scalar("datetime::month", datetime::month::DateTimeMonth::new)
106 .register_scalar("datetime::day", datetime::day::DateTimeDay::new)
107 .register_scalar("datetime::hour", datetime::hour::DateTimeHour::new)
108 .register_scalar("datetime::minute", datetime::minute::DateTimeMinute::new)
109 .register_scalar("datetime::second", datetime::second::DateTimeSecond::new)
110 .register_scalar("datetime::nanosecond", datetime::nanosecond::DateTimeNanosecond::new)
111 .register_scalar("datetime::day_of_year", datetime::day_of_year::DateTimeDayOfYear::new)
112 .register_scalar("datetime::day_of_week", datetime::day_of_week::DateTimeDayOfWeek::new)
113 .register_scalar("datetime::quarter", datetime::quarter::DateTimeQuarter::new)
114 .register_scalar("datetime::week", datetime::week::DateTimeWeek::new)
115 .register_scalar("datetime::date", datetime::date::DateTimeDate::new)
116 .register_scalar("datetime::time", datetime::time::DateTimeTime::new)
117 .register_scalar("datetime::epoch", datetime::epoch::DateTimeEpoch::new)
118 .register_scalar("datetime::epoch_millis", datetime::epoch_millis::DateTimeEpochMillis::new)
119 .register_scalar("datetime::new", datetime::new::DateTimeNew::new)
120 .register_scalar("datetime::now", datetime::now::DateTimeNow::new)
121 .register_scalar("datetime::from_epoch", datetime::from_epoch::DateTimeFromEpoch::new)
122 .register_scalar(
123 "datetime::from_epoch_millis",
124 datetime::from_epoch_millis::DateTimeFromEpochMillis::new,
125 )
126 .register_scalar("datetime::add", datetime::add::DateTimeAdd::new)
127 .register_scalar("datetime::subtract", datetime::subtract::DateTimeSubtract::new)
128 .register_scalar("datetime::diff", datetime::diff::DateTimeDiff::new)
129 .register_scalar("datetime::trunc", datetime::trunc::DateTimeTrunc::new)
130 .register_scalar("datetime::age", datetime::age::DateTimeAge::new)
131 .register_scalar("datetime::format", datetime::format::DateTimeFormat::new)
132 .register_scalar("duration::years", duration::years::DurationYears::new)
133 .register_scalar("duration::months", duration::months::DurationMonths::new)
134 .register_scalar("duration::weeks", duration::weeks::DurationWeeks::new)
135 .register_scalar("duration::days", duration::days::DurationDays::new)
136 .register_scalar("duration::hours", duration::hours::DurationHours::new)
137 .register_scalar("duration::minutes", duration::minutes::DurationMinutes::new)
138 .register_scalar("duration::seconds", duration::seconds::DurationSeconds::new)
139 .register_scalar("duration::millis", duration::millis::DurationMillis::new)
140 .register_scalar("duration::year", duration::years::DurationYears::new)
141 .register_scalar("duration::month", duration::months::DurationMonths::new)
142 .register_scalar("duration::week", duration::weeks::DurationWeeks::new)
143 .register_scalar("duration::day", duration::days::DurationDays::new)
144 .register_scalar("duration::hour", duration::hours::DurationHours::new)
145 .register_scalar("duration::minute", duration::minutes::DurationMinutes::new)
146 .register_scalar("duration::second", duration::seconds::DurationSeconds::new)
147 .register_scalar("duration::get_months", duration::get_months::DurationGetMonths::new)
148 .register_scalar("duration::get_days", duration::get_days::DurationGetDays::new)
149 .register_scalar("duration::get_nanos", duration::get_nanos::DurationGetNanos::new)
150 .register_scalar("duration::add", duration::add::DurationAdd::new)
151 .register_scalar("duration::subtract", duration::subtract::DurationSubtract::new)
152 .register_scalar("duration::negate", duration::negate::DurationNegate::new)
153 .register_scalar("duration::scale", duration::scale::DurationScale::new)
154 .register_scalar("duration::trunc", duration::trunc::DurationTrunc::new)
155 .register_scalar("duration::format", duration::format::DurationFormat::new)
156 .register_scalar("text::ascii", text::ascii::TextAscii::new)
157 .register_scalar("text::char", text::char::TextChar::new)
158 .register_scalar("text::concat", text::concat::TextConcat::new)
159 .register_scalar("text::contains", text::contains::TextContains::new)
160 .register_scalar("text::count", text::count::TextCount::new)
161 .register_scalar("text::ends_with", text::ends_with::TextEndsWith::new)
162 .register_scalar("text::index_of", text::index_of::TextIndexOf::new)
163 .register_scalar("text::pad_left", text::pad_left::TextPadLeft::new)
164 .register_scalar("text::pad_right", text::pad_right::TextPadRight::new)
165 .register_scalar("text::repeat", text::repeat::TextRepeat::new)
166 .register_scalar("text::replace", text::replace::TextReplace::new)
167 .register_scalar("text::reverse", text::reverse::TextReverse::new)
168 .register_scalar("text::starts_with", text::starts_with::TextStartsWith::new)
169 .register_scalar("text::length", text::length::TextLength::new)
170 .register_scalar("text::trim", text::trim::TextTrim::new)
171 .register_scalar("text::trim_end", text::trim_end::TextTrimEnd::new)
172 .register_scalar("text::trim_start", text::trim_start::TextTrimStart::new)
173 .register_scalar("text::upper", text::upper::TextUpper::new)
174 .register_scalar("text::lower", text::lower::TextLower::new)
175 .register_scalar("text::substring", text::substring::TextSubstring::new)
176 .register_scalar("text::format_bytes", text::format_bytes::FormatBytes::new)
177 .register_scalar("text::format_bytes_si", text::format_bytes_si::FormatBytesSi::new)
178 .register_scalar("meta::type", meta::r#type::Type::new)
179 .register_scalar("is::some", is::some::IsSome::new)
180 .register_scalar("is::none", is::none::IsNone::new)
181 .register_scalar("is::type", is::r#type::IsType::new)
182 .register_scalar("gen::series", series::Series::new)
183 .register_generator("generate_series", series::GenerateSeries::new)
184 .register_generator("inspect_subscription", subscription::inspect::InspectSubscription::new)
185 }
186}
187
188impl Deref for Functions {
189 type Target = FunctionsInner;
190
191 fn deref(&self) -> &Self::Target {
192 &self.0
193 }
194}
195
196#[derive(Clone)]
197pub struct FunctionsInner {
198 scalars: HashMap<String, Arc<dyn Fn() -> Box<dyn ScalarFunction> + Send + Sync>>,
199 aggregates: HashMap<String, Arc<dyn Fn() -> Box<dyn AggregateFunction> + Send + Sync>>,
200 generators: HashMap<String, Arc<dyn Fn() -> Box<dyn GeneratorFunction> + Send + Sync>>,
201}
202
203impl FunctionsInner {
204 pub fn get_aggregate(&self, name: &str) -> Option<Box<dyn AggregateFunction>> {
205 self.aggregates.get(name).map(|func| func())
206 }
207
208 pub fn get_scalar(&self, name: &str) -> Option<Box<dyn ScalarFunction>> {
209 self.scalars.get(name).map(|func| func())
210 }
211
212 pub fn get_generator(&self, name: &str) -> Option<Box<dyn GeneratorFunction>> {
213 self.generators.get(name).map(|func| func())
214 }
215
216 pub fn scalar_names(&self) -> Vec<&str> {
217 self.scalars.keys().map(|s| s.as_str()).collect()
218 }
219
220 pub fn aggregate_names(&self) -> Vec<&str> {
221 self.aggregates.keys().map(|s| s.as_str()).collect()
222 }
223
224 pub fn generator_names(&self) -> Vec<&str> {
225 self.generators.keys().map(|s| s.as_str()).collect()
226 }
227
228 pub fn get_scalar_factory(&self, name: &str) -> Option<Arc<dyn Fn() -> Box<dyn ScalarFunction> + Send + Sync>> {
229 self.scalars.get(name).cloned()
230 }
231
232 pub fn get_aggregate_factory(
233 &self,
234 name: &str,
235 ) -> Option<Arc<dyn Fn() -> Box<dyn AggregateFunction> + Send + Sync>> {
236 self.aggregates.get(name).cloned()
237 }
238}
239
240pub struct FunctionsBuilder(FunctionsInner);
241
242impl FunctionsBuilder {
243 pub fn register_scalar<F, A>(mut self, name: &str, init: F) -> Self
244 where
245 F: Fn() -> A + Send + Sync + 'static,
246 A: ScalarFunction + 'static,
247 {
248 self.0.scalars.insert(name.to_string(), Arc::new(move || Box::new(init()) as Box<dyn ScalarFunction>));
249
250 self
251 }
252
253 pub fn register_aggregate<F, A>(mut self, name: &str, init: F) -> Self
254 where
255 F: Fn() -> A + Send + Sync + 'static,
256 A: AggregateFunction + 'static,
257 {
258 self.0.aggregates
259 .insert(name.to_string(), Arc::new(move || Box::new(init()) as Box<dyn AggregateFunction>));
260
261 self
262 }
263
264 pub fn register_generator<F, G>(mut self, name: &str, init: F) -> Self
265 where
266 F: Fn() -> G + Send + Sync + 'static,
267 G: GeneratorFunction + 'static,
268 {
269 self.0.generators
270 .insert(name.to_string(), Arc::new(move || Box::new(init()) as Box<dyn GeneratorFunction>));
271
272 self
273 }
274
275 pub fn build(self) -> Functions {
276 Functions(Arc::new(self.0))
277 }
278}