Struct DevicePushRepository 

pub struct DevicePushRepository { /* private fields */ }

Implementations

impl DevicePushRepository

pub fn new(pool: DatabasePool) -> Self

pub async fn set( &self, device_id: &str, relay_subscription_id: &str, ) -> DomainResult<()>

pub async fn get(&self, device_id: &str) -> DomainResult<Option<DevicePush>>

pub async fn list(&self) -> DomainResult<Vec<DevicePush>>

pub async fn delete(&self, device_id: &str) -> DomainResult<bool>

pub async fn delete_matching( &self, device_id: &str, relay_subscription_id: &str, ) -> DomainResult<bool>

pub async fn mark_success(&self, device_id: &str) -> DomainResult<()>

pub async fn delete_all(&self) -> DomainResult<u64>

pub async fn import(&self, pushes: &[DevicePush]) -> DomainResult<()>

pub async fn mark_undelivered( &self, device_id: &str, relay_subscription_id: &str, seq: i64, ) -> DomainResult<()>

pub async fn ack_undelivered( &self, device_id: &str, through: i64, ) -> DomainResult<()>