sdf-context-guest 0.14.0

guest crate for sdf operator ctx
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

#[allow(dead_code)]
#[rustfmt::skip]
#[allow(clippy::all)]
pub mod bindings {
    use wit_bindgen::generate;

    cfg_if::cfg_if!(
        if #[cfg(all(feature = "row", feature = "table"))] {
            generate!({
                world: "context-world",
                path: "wit",
                additional_derives: [PartialEq, Clone],
                generate_all,
                with: {
                    "sdf:row-state/row": ::sdf_row_guest::bindings::sdf::row_state::row,
                    "sdf:df/lazy": ::sdf_df_guest::bindings::sdf::df::lazy,
                }
            });
        } else if #[cfg(feature = "row")] {
            generate!({
                world: "context-world",
                path: "wit",
                additional_derives: [PartialEq, Clone],
                generate_all,
                with: {
                    "sdf:row-state/row": ::sdf_row_guest::bindings::sdf::row_state::row,
                }
            });
        } else if #[cfg(feature = "table")] {
            generate!({
                world: "context-world",
                path: "wit",
                additional_derives: [PartialEq, Clone],
                generate_all,
                with: {
                    "sdf:df/lazy": ::sdf_df_guest::bindings::sdf::df::lazy,
                }
            });
        } else {
            generate!({
                world: "context-world",
                path: "wit",
                additional_derives: [PartialEq, Clone],
                generate_all,
        });
    });
}

pub mod wit {
    pub use crate::bindings::sdf::context::types;
    pub use crate::bindings::sdf::context::operator_context;
    pub use crate::bindings::sdf::value_state;

    pub mod utils {
        pub use crate::bindings::sdf::context::operator_context::{
            key, window, get_row_value, get_value32, get_list32, get_param,
        };
        #[cfg(feature = "table")]
        pub fn sql(query: &str) -> anyhow::Result<sdf_df_guest::LazyDf> {
            match crate::bindings::sdf::context::operator_context::sql(query) {
                Ok(df) => Ok(df.into()),
                Err(e) => Err(anyhow::anyhow!("{}", e)),
            }
        }
    }
}