Struct NativeDbTaskStore 

pub struct NativeDbTaskStore {
    pub store: Arc<&'static Database<'static>>,
}

Fields

store: Arc<&'static Database<'static>>

Implementations

impl NativeDbTaskStore

pub fn new(db_path: Option<String>, cache_size: Option<u64>) -> Self

pub fn init(database: &'static Database<'static>) -> Self

pub fn fetch_and_lock_task( db: Arc<&'static Database<'static>>, queue: String, runner_id: String, ) -> Result<Option<TaskMeta>, NativeDbTaskStoreError>

pub fn fetch_pending_tasks( db: Arc<&'static Database<'static>>, ) -> Result<Vec<TaskMeta>, NativeDbTaskStoreError>

pub fn clean_up( db: Arc<&'static Database<'static>>, ) -> Result<(), NativeDbTaskStoreError>

pub fn set_status( db: Arc<&'static Database<'static>>, task_id: String, status: TaskStatus, reason: Option<String>, ) -> Result<(), NativeDbTaskStoreError>

pub fn heartbeat( db: Arc<&'static Database<'static>>, task_id: String, runner_id: String, ) -> Result<(), NativeDbTaskStoreError>

pub fn restore( db: Arc<&'static Database<'static>>, ) -> Result<(), NativeDbTaskStoreError>

pub fn get( db: Arc<&'static Database<'static>>, task_id: String, ) -> Result<Option<TaskMeta>, NativeDbTaskStoreError>

pub fn list( db: Arc<&'static Database<'static>>, ) -> Result<Vec<TaskMeta>, NativeDbTaskStoreError>

pub fn store_one( db: Arc<&'static Database<'static>>, task: TaskMeta, ) -> Result<(), NativeDbTaskStoreError>

pub fn store_many( db: Arc<&'static Database<'static>>, tasks: Vec<TaskMeta>, ) -> Result<(), NativeDbTaskStoreError>

Trait Implementations

impl Clone for NativeDbTaskStore

fn clone(&self) -> NativeDbTaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for NativeDbTaskStore

fn default() -> Self

Returns the “default value” for a type.

impl TaskStore for NativeDbTaskStore

type Error = NativeDbTaskStoreError

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

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

Restores task states by cleaning up all tasks in a running state and handling their next run times.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskMeta>, Self::Error>> + Send + 'async_trait>>

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

Retrieves task metadata based on the task ID.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskMeta>, Self::Error>> + Send + 'async_trait>>

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

Lists all task metadata.

fn store_task<'life0, 'async_trait>( &'life0 self, task: TaskMeta, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Stores task metadata.

fn store_tasks<'life0, 'async_trait>( &'life0 self, tasks: Vec<TaskMeta>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Stores tasks metadata.

fn fetch_pending_tasks<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskMeta>, Self::Error>> + Send + 'async_trait>>

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

Fetches all pending tasks from the store.

fn update_task_execution_status<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, is_success: bool, last_error: Option<String>, last_duration_ms: Option<usize>, last_retry_count: Option<usize>, next_run: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Updates the execution status of a task.

fn heartbeat<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, runner_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Updates the heartbeat for a task.

fn set_task_stopped<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, reason: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Marks a task as stopped.

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

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

Marks a task as removed.

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

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

Cleans up the task store by removing tasks marked as removed.