Struct background_jobs_sled_storage::SledStorage

pub struct SledStorage { /* fields omitted */ }

Methods

impl SledStorage

pub fn new(db: Db) -> Result<Self, Error>

Trait Implementations

impl Clone for SledStorage

fn clone(&self) -> SledStorage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Storage for SledStorage

type Error = Error

fn generate_id(&mut self) -> Result<u64, Error>

This method generates unique IDs for jobs

fn save_job(&mut self, job: JobInfo) -> Result<(), Error>

This method should store the supplied job

fn fetch_job(&mut self, id: u64) -> Result<Option<JobInfo>, Error>

This method should return the job with the given ID regardless of what state the job is in.

fn fetch_job_from_queue(
    &mut self,
    queue: &str
) -> Result<Option<JobInfo>, Error>

This should fetch a job ready to be processed from the queue

fn queue_job(&mut self, queue: &str, id: u64) -> Result<(), Error>

This method tells the storage mechanism to mark the given job as being in the provided queue

fn run_job(&mut self, id: u64, runner_id: u64) -> Result<(), Error>

This method tells the storage mechanism to mark a given job as running

fn delete_job(&mut self, id: u64) -> Result<(), Error>

This method tells the storage mechanism to remove the job

fn get_stats(&self) -> Result<Stats, Error>

This method returns the current statistics, or Stats::default() if none exists.

fn update_stats<F>(&mut self, f: F) -> Result<(), Error> where
    F: Fn(Stats) -> Stats, 

This method fetches the existing statistics or Stats::default(), and stores the result of calling update_stats on it.

fn new_job(&mut self, job: NewJobInfo) -> Result<u64, Self::Error>

fn request_job(
    &mut self,
    queue: &str,
    runner_id: u64
) -> Result<Option<JobInfo>, Self::Error>

fn return_job(&mut self, ReturnJobInfo) -> Result<(), Self::Error>