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

use apalis_core::Storage;

use sqlx::pool::Pool;
use sqlx::Sqlite;

pub struct SequelStorage<D: sqlx::Database> {
    pool: Pool<D>
}


#[cfg(any(feature = "mysql", feature = "sqlite"))]
impl Storage for SequelStorage<Sqlite> {

    fn push(&self) {
        sqlx::query::<Sqlite>("INSERT INTO jobs (job) VALUES (?)").execute(&self.pool.clone());
    }
    fn fetch(&self) {
        todo!()
    }

    fn ack(&self) {
        todo!()
    }

}

#[cfg(any(feature = "postgres"))]
impl Storage for SequelStorage {

}