backbone-jobs 3.0.2

Job scheduling and cron management for the Backbone Framework
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//! Job storage trait definition

pub mod in_memory;

use crate::error::JobResult;
use crate::job::Job;
use crate::types::{JobExecutionAttempt, JobId, JobStatistics, JobStatus};
use async_trait::async_trait;

/// Trait for job storage operations
#[async_trait]
pub trait JobStorage: Send + Sync {
    /// Store a new job
    async fn create_job(&self, job: &Job) -> JobResult<()>;

    /// Update an existing job
    async fn update_job(&self, job: &Job) -> JobResult<()>;

    /// Get a job by ID
    async fn get_job(&self, job_id: &JobId) -> JobResult<Option<Job>>;

    /// Delete a job by ID
    async fn delete_job(&self, job_id: &JobId) -> JobResult<()>;

    /// List all jobs
    async fn list_jobs(&self) -> JobResult<Vec<Job>>;

    /// List jobs by status
    async fn list_jobs_by_status(&self, status: JobStatus) -> JobResult<Vec<Job>>;

    /// Get jobs scheduled to run before the given time
    async fn get_pending_jobs(&self, before: chrono::DateTime<chrono::Utc>) -> JobResult<Vec<Job>>;

    /// Update job status
    async fn update_job_status(&self, job_id: &JobId, status: JobStatus) -> JobResult<()>;

    /// Update next run time for a job
    async fn update_next_run_time(&self, job_id: &JobId, next_run: chrono::DateTime<chrono::Utc>) -> JobResult<()>;

    /// Record job execution attempt
    async fn record_execution_attempt(&self, job_id: &JobId, attempt: &JobExecutionAttempt) -> JobResult<()>;

    /// Get job execution history
    async fn get_execution_history(&self, job_id: &JobId, limit: Option<u32>) -> JobResult<Vec<JobExecutionAttempt>>;

    /// Get job statistics
    async fn get_statistics(&self) -> JobResult<JobStatistics>;

    /// Clean up old execution attempts
    async fn cleanup_old_attempts(&self, older_than: chrono::DateTime<chrono::Utc>) -> JobResult<u64>;
}

// Re-export for convenience
pub use in_memory::InMemoryJobStorage;