Struct Persistence Manager &nbsp; Copy item path

impl PersistenceManager

pub async fn new(backend: Arc<dyn Backend>) -> Result<Self, StoreError>

Create a PersistenceManager with a backend implementation.

Note: The backend should already be configured with the correct device_id (via SqliteStore::new_for_device for multi-account scenarios).

pub async fn modify_device<F, R>(&self, modifier: F) -> R
where F: FnOnce(&mut Device) -> R,

pub async fn flush(&self) -> Result<(), StoreError>

Flush any dirty device state to the backend immediately.

pub async fn create_snapshot( &self, name: &str, extra_content: Option<&[u8]>, ) -> Result<(), StoreError>

Triggers a snapshot of the underlying storage backend. Useful for debugging critical errors like crypto state corruption.

pub fn run_background_saver( self: Arc<Self>, runtime: Arc<dyn Runtime>, interval: Duration, )

impl PersistenceManager

pub async fn process_command(&self, command: DeviceCommand)

impl PersistenceManager

pub async fn get_skdm_recipients( &self, group_jid: &str, ) -> Result<Vec<Jid>, StoreError>

pub async fn add_skdm_recipients( &self, group_jid: &str, device_jids: &[Jid], ) -> Result<(), StoreError>

pub async fn clear_skdm_recipients( &self, group_jid: &str, ) -> Result<(), StoreError>

Auto Trait Implementations§

impl Freeze for PersistenceManager

impl !RefUnwindSafe for PersistenceManager

impl Send for PersistenceManager

impl Sync for PersistenceManager

impl Unpin for PersistenceManager

impl UnsafeUnpin for PersistenceManager

impl !UnwindSafe for PersistenceManager

Blanket Implementations§

impl<T> AggregateExpressionMethods for T

fn aggregate_distinct(self) -> Self::Output
where Self: DistinctDsl,

DISTINCT modifier for aggregate functions Read more

fn aggregate_all(self) -> Self::Output
where Self: AllDsl,

ALL modifier for aggregate functions Read more

fn aggregate_filter(self, f: P) -> Self::Output
where P: AsExpression<Bool>, Self: FilterDsl<>::Expression>,

Add an aggregate function filter Read more

fn aggregate_order<O>(self, o: O) -> Self::Output
where Self: OrderAggregateDsl<O>,

Add an aggregate function order Read more

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> Downcast for T
where T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

Converts Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Converts Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.

fn as_any(&self) -> &(dyn Any + 'static)

Converts &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Converts &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.

impl<T> DowncastSend for T
where T: Any + Send,

fn into_any_send(self: Box<T>) -> Box<dyn Any + Send>

Converts Box<Trait> (where Trait: DowncastSend) to Box<dyn Any + Send>, which can then be downcast into Box<ConcreteType> where ConcreteType implements Trait.

impl<T> DowncastSync for T
where T: Any + Send + Sync,

fn into_any_sync(self: Box<T>) -> Box<dyn Any + Send + Sync>

Converts Box<Trait> (where Trait: DowncastSync) to Box<dyn Any + Send + Sync>, which can then be downcast into Box<ConcreteType> where ConcreteType implements Trait.

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

Converts Arc<Trait> (where Trait: DowncastSync) to Arc<Any>, which can then be downcast into Arc<ConcreteType> where ConcreteType implements Trait.