pub struct Durability<SOk, SErr> { /* private fields */ }
Implementations§
Source§impl<SOk, SErr> Durability<SOk, SErr>
impl<SOk, SErr> Durability<SOk, SErr>
pub fn new( interface: &'static str, function: &'static str, function_type: DurableFunctionType, ) -> Self
pub fn enabled_forced_commit(&mut self)
pub fn is_live(&self) -> bool
pub fn persist<SIn, Ok, Err>( &self, input: SIn, result: Result<Ok, Err>, ) -> Result<Ok, Err>
pub fn persist_infallible<SIn, Ok>(&self, input: SIn, result: Ok) -> Okwhere
Ok: Clone,
SIn: Debug + IntoValueAndType,
SOk: Debug + From<Ok>,
SErr: Debug,
Result<SOk, SErr>: IntoValueAndType,
pub fn persist_serializable<SIn>(&self, input: SIn, result: Result<SOk, SErr>)
pub fn replay_raw(&self) -> (ValueAndType, OplogEntryVersion)
pub fn replay_serializable(&self) -> Result<SOk, SErr>where
SOk: FromValueAndType,
SErr: FromValueAndType,
pub fn replay<Ok, Err>(&self) -> Result<Ok, Err>where
Ok: From<SOk>,
Err: From<SErr>,
SErr: Debug + FromValueAndType,
SOk: Debug + FromValueAndType,
pub fn replay_infallible<Ok>(&self) -> Ok
Auto Trait Implementations§
impl<SOk, SErr> Freeze for Durability<SOk, SErr>
impl<SOk, SErr> RefUnwindSafe for Durability<SOk, SErr>where
SOk: RefUnwindSafe,
SErr: RefUnwindSafe,
impl<SOk, SErr> Send for Durability<SOk, SErr>
impl<SOk, SErr> Sync for Durability<SOk, SErr>
impl<SOk, SErr> Unpin for Durability<SOk, SErr>
impl<SOk, SErr> UnwindSafe for Durability<SOk, SErr>where
SOk: UnwindSafe,
SErr: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more