frost-guest-sdk 0.1.0

Guest-side bindings for the FROST WIT SDK.
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

pub use wit_bindgen;

#[macro_export]
macro_rules! frost_component {
    (
        component: $component:tt,
        world: $world:literal,
        path: $wit_path:literal $(,)?
    ) => {
        pub mod bindings {
            use super::*;
            use $crate::wit_bindgen as wit_bindgen;

            $crate::wit_bindgen::generate!({
                world: $world,
                path: $wit_path,
                generate_all,
                runtime_path: "frost_guest_sdk::wit_bindgen::rt",
            });

            export!($component);
        }

        pub mod sdk_guest {
            pub use super::bindings;

            pub mod outcome {
                use super::bindings::exports::frost::batch::job::{
                    FailureOutcome, MessageOutcome, Outcome, RetryOutcome,
                };

                pub fn ok(message: impl Into<String>) -> Outcome {
                    Outcome::Success(MessageOutcome {
                        message: message.into(),
                        props: Vec::new(),
                    })
                }

                pub fn ok_with_props(
                    message: impl Into<String>,
                    props: Vec<super::bindings::frost::core::types::Kv>,
                ) -> Outcome {
                    Outcome::Success(MessageOutcome {
                        message: message.into(),
                        props,
                    })
                }

                pub fn retry(message: impl Into<String>, retry_after_ns: Option<u64>) -> Outcome {
                    Outcome::Retry(RetryOutcome {
                        message: message.into(),
                        retry_after_ns,
                        props: Vec::new(),
                    })
                }

                pub fn retry_with_props(
                    message: impl Into<String>,
                    retry_after_ns: Option<u64>,
                    props: Vec<super::bindings::frost::core::types::Kv>,
                ) -> Outcome {
                    Outcome::Retry(RetryOutcome {
                        message: message.into(),
                        retry_after_ns,
                        props,
                    })
                }

                pub fn fail(message: impl Into<String>, permanent: bool) -> Outcome {
                    Outcome::Failure(FailureOutcome {
                        message: message.into(),
                        permanent,
                        props: Vec::new(),
                    })
                }

                pub fn fail_with_props(
                    message: impl Into<String>,
                    permanent: bool,
                    props: Vec<super::bindings::frost::core::types::Kv>,
                ) -> Outcome {
                    Outcome::Failure(FailureOutcome {
                        message: message.into(),
                        permanent,
                        props,
                    })
                }
            }

            pub mod prelude {
                pub use super::bindings::exports::frost::batch::job::{
                    FailureOutcome, Guest as Job, MessageOutcome, Outcome, RetryOutcome,
                };
                pub use super::bindings::frost::core::context::Ctx;
                pub use super::bindings::frost::core::diagnostics::{log, Level};
                pub use super::bindings::frost::core::types::{Error, Kv, Properties};
                pub use super::outcome::{fail, fail_with_props, ok, ok_with_props, retry, retry_with_props};
                pub use $crate::frost_component;
            }
        }
    };
}