Struct ScheduledTaskDbStore 

pub struct ScheduledTaskDbStore { /* private fields */ }

SeaORM-backed scheduled task store.

Implementations

impl ScheduledTaskDbStore

pub const fn new(db: DatabaseConnection) -> Self

Creates a scheduled task store from a SeaORM database connection.

pub async fn ensure_task( &self, entry: ScheduledTaskCatalogEntry<'_>, ) -> Result<Model>

Ensures one product scheduled task is present in the catalog.

pub async fn claim_due( &self, request: ScheduledTaskClaimRequest<'_>, ) -> Result<Option<ScheduledTaskClaim>>

Attempts to claim one due scheduled task firing.

pub async fn renew_claim( &self, renewal: ScheduledTaskClaimRenewal<'_>, ) -> Result<bool>

Renews an owned claim while the task body is still running.

pub async fn complete_claim( &self, completion: ScheduledTaskCompletion, ) -> Result<bool>

Completes a claimed firing and advances the next due timestamp.

Trait Implementations

impl Clone for ScheduledTaskDbStore

fn clone(&self) -> ScheduledTaskDbStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ScheduledTaskStore for ScheduledTaskDbStore

type Error = DbError

Store error type.

fn ensure_scheduled_task<'life0, 'life1, 'async_trait>( &'life0 self, entry: ScheduledTaskCatalogEntry<'life1>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Ensures one scheduled task is present in the catalog.

fn claim_scheduled_task<'life0, 'life1, 'async_trait>( &'life0 self, request: ScheduledTaskClaimRequest<'life1>, ) -> Pin<Box<dyn Future<Output = Result<Option<ScheduledTaskClaim>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Attempts to claim one due scheduled task firing.

fn renew_scheduled_task_claim<'life0, 'life1, 'async_trait>( &'life0 self, renewal: ScheduledTaskClaimRenewal<'life1>, ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Renews an owned claim while the task body is still running.

fn complete_scheduled_task<'life0, 'async_trait>( &'life0 self, completion: ScheduledTaskCompletion, ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Completes a claimed firing and advances the next due timestamp.