Struct smtp_queue_fs::FsStorage

pub struct FsStorage<U> { /* private fields */ }

Implementations

impl<U> FsStorage<U>

pub async fn new(path: Arc<PathBuf>) -> Result<FsStorage<U>, Error>

Trait Implementations

impl<U> Storage<U> for FsStorage<U> where
    U: 'static + Send + Sync + for<'a> Deserialize<'a> + Serialize, 

type Enqueuer = FsEnqueuer<U>

type Error = Error

type InflightLister = Pin<Box<dyn Send + Stream<Item = Result<FsInflightMail, (Error, Option<QueueId>)>>>>

type InflightMail = FsInflightMail

type PendingCleanupLister = Pin<Box<dyn Send + Stream<Item = Result<FsPendingCleanupMail, (Error, Option<QueueId>)>>>>

type PendingCleanupMail = FsPendingCleanupMail

type QueueLister = Pin<Box<dyn Send + Stream<Item = Result<FsQueuedMail, (Error, Option<QueueId>)>>>>

type QueuedMail = FsQueuedMail

type Reader = Pin<Box<dyn Send + AsyncRead>>

fn list_queue<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Send + Stream<Item = Result<FsQueuedMail, (Error, Option<QueueId>)>>>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn find_inflight<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Send + Stream<Item = Result<FsInflightMail, (Error, Option<QueueId>)>>>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn find_pending_cleanup<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Send + Stream<Item = Result<FsPendingCleanupMail, (Error, Option<QueueId>)>>>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn read_inflight<'life0, 'life1, 'async_trait>(
    &'life0 self,
    mail: &'life1 FsInflightMail
) -> Pin<Box<dyn Future<Output = Result<(MailMetadata<U>, Self::Reader), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

fn enqueue<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<FsEnqueuer<U>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn reschedule<'life0, 'life1, 'async_trait>(
    &'life0 self,
    mail: &'life1 mut FsQueuedMail,
    schedule: ScheduleInfo
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

fn send_start<'life0, 'async_trait>(
    &'life0 self,
    mail: FsQueuedMail
) -> Pin<Box<dyn Future<Output = Result<Option<FsInflightMail>, (FsQueuedMail, Error)>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn send_done<'life0, 'async_trait>(
    &'life0 self,
    mail: FsInflightMail
) -> Pin<Box<dyn Future<Output = Result<Option<FsPendingCleanupMail>, (FsInflightMail, Error)>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn send_cancel<'life0, 'async_trait>(
    &'life0 self,
    mail: FsInflightMail
) -> Pin<Box<dyn Future<Output = Result<Option<FsQueuedMail>, (FsInflightMail, Error)>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn drop<'life0, 'async_trait>(
    &'life0 self,
    mail: FsQueuedMail
) -> Pin<Box<dyn Future<Output = Result<Option<FsPendingCleanupMail>, (FsQueuedMail, Error)>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn cleanup<'life0, 'async_trait>(
    &'life0 self,
    mail: FsPendingCleanupMail
) -> Pin<Box<dyn Future<Output = Result<bool, (FsPendingCleanupMail, Error)>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl<U> StorageEnqueuer<U, FsStorage<U>, FsQueuedMail> for FsEnqueuer<U> where
    U: 'static + Send + Sync + for<'a> Deserialize<'a> + Serialize, 

fn commit<'async_trait>(
    self,
    destinations: Vec<(MailMetadata<U>, ScheduleInfo)>
) -> Pin<Box<dyn Future<Output = Result<Vec<FsQueuedMail>, Error>> + Send + 'async_trait>> where
    Self: 'async_trait,