Trait QueryDeviceSyncMessages 

pub trait QueryDeviceSyncMessages {
    // Required methods
    fn unprocessed_sync_group_messages(
        &self,
    ) -> Result<Vec<StoredGroupMessage>, StorageError>;
    fn sync_group_messages_paged(
        &self,
        offset: i64,
        limit: i64,
    ) -> Result<Vec<StoredGroupMessage>, StorageError>;
    fn mark_device_sync_msg_as_processed(
        &self,
        message_id: &[u8],
    ) -> Result<(), StorageError>;
    fn increment_device_sync_msg_attempt(
        &self,
        message_id: &[u8],
        max_attempts: i32,
    ) -> Result<i32, StorageError>;
}

Required Methods

fn unprocessed_sync_group_messages( &self, ) -> Result<Vec<StoredGroupMessage>, StorageError>

fn sync_group_messages_paged( &self, offset: i64, limit: i64, ) -> Result<Vec<StoredGroupMessage>, StorageError>

fn mark_device_sync_msg_as_processed( &self, message_id: &[u8], ) -> Result<(), StorageError>

Marks a device sync message as processed.

fn increment_device_sync_msg_attempt( &self, message_id: &[u8], max_attempts: i32, ) -> Result<i32, StorageError>

Increments the attempt count for a device sync message. If the attempt count reaches max_attempts, the state is set to Failed. Returns the new attempt count.

Implementations on Foreign Types

impl<T> QueryDeviceSyncMessages for &T

where T: QueryDeviceSyncMessages,

fn unprocessed_sync_group_messages( &self, ) -> Result<Vec<StoredGroupMessage>, StorageError>

fn sync_group_messages_paged( &self, offset: i64, limit: i64, ) -> Result<Vec<StoredGroupMessage>, StorageError>

fn mark_device_sync_msg_as_processed( &self, message_id: &[u8], ) -> Result<(), StorageError>

fn increment_device_sync_msg_attempt( &self, message_id: &[u8], max_attempts: i32, ) -> Result<i32, StorageError>

Implementors

impl QueryDeviceSyncMessages for MockDbQuery

impl<C: ConnectionExt> QueryDeviceSyncMessages for DbConnection<C>