Struct Durability 

pub struct Durability<SOk, SErr> { /* private fields */ }

Implementations

impl<SOk, SErr> Durability<SOk, SErr>

pub fn new<SIn>( interface: &'static str, function: &'static str, function_type: DurableFunctionType, input: &SIn, ) -> Self

where SIn: Clone + IntoSchema,

pub fn enable_forced_commit(&mut self)

pub fn with_forced_commit(self) -> Self

pub fn run<Ok, Err, F>(self, body: F) -> Result<Ok, Err>

where F: FnOnce() -> Result<Ok, Err>, Ok: Clone + From<SOk>, Err: From<SErr>, SErr: FromSchema + for<'a> From<&'a Err>, SOk: FromSchema + From<Ok>, Result<SOk, SErr>: IntoSchema,

pub async fn run_async<Ok, Err, F, Fut>(self, body: F) -> Result<Ok, Err>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<Ok, Err>>, Ok: Clone + From<SOk>, Err: From<SErr>, SErr: FromSchema + for<'a> From<&'a Err>, SOk: FromSchema + From<Ok>, Result<SOk, SErr>: IntoSchema,

pub fn run_infallible<Ok, F>(self, body: F) -> Ok

where F: FnOnce() -> Ok, Ok: Clone + From<SOk>, SOk: FromSchema + From<Ok>, SErr: FromSchema + Display, Result<SOk, SErr>: IntoSchema,

pub async fn run_infallible_async<Ok, F, Fut>(self, body: F) -> Ok

where F: FnOnce() -> Fut, Fut: Future<Output = Ok>, Ok: Clone + From<SOk>, SOk: FromSchema + From<Ok>, SErr: FromSchema + Display, Result<SOk, SErr>: IntoSchema,