Struct apalis_sql::mysql::MysqlStorage

pub struct MysqlStorage<T> { /* private fields */ }

Available on crate feature mysql only.

Represents a Storage that persists to MySQL

Implementations

impl MysqlStorage<()>

pub fn migrations() -> Migrator

Get mysql migrations without running them

pub async fn setup(pool: &Pool<MySql>) -> Result<(), Error>

Do migrations for mysql

impl<T: Serialize + DeserializeOwned> MysqlStorage<T>

pub fn new(pool: MySqlPool) -> Self

Create a new instance from a pool

pub fn new_with_config(pool: MySqlPool, config: Config) -> Self

Create a new instance from a pool and custom config

pub fn pool(&self) -> &Pool<MySql>

Expose the pool for other functionality, eg custom migrations

impl<T: Job> MysqlStorage<T>

pub async fn kill( &mut self, worker_id: &WorkerId, job_id: &TaskId ) -> Result<(), Error>

Kill a job

pub async fn retry( &mut self, worker_id: &WorkerId, job_id: &TaskId ) -> Result<(), Error>

Puts the job instantly back into the queue

pub async fn reenqueue_orphaned(&self, timeout: i64) -> Result<bool, Error>

Readd jobs that are abandoned to the queue

Trait Implementations

impl<T: Sync> Ack<T> for MysqlStorage<T>

type Acknowledger = TaskId

The data to fetch from context to allow acknowledgement

type Error = Error

The error returned by the ack

async fn ack( &self, worker_id: &WorkerId, task_id: &Self::Acknowledger ) -> Result<(), Error>

Acknowledges successful processing of the given request

impl<T: Job + Serialize + DeserializeOwned + Sync + Send + Unpin + 'static> Backend<Request<T>> for MysqlStorage<T>

type Stream = BackendStream<Pin<Box<dyn Stream<Item = Result<Option<Request<T>>, Error>> + Send>>>

The stream to be produced by the backend

type Layer = AckLayer<MysqlStorage<T>, T>

Returns the final decoration of layers

fn common_layer(&self, worker_id: WorkerId) -> Self::Layer

Allows the backend to decorate the service with Layer

fn poll(self, worker: WorkerId) -> Poller<Self::Stream>

Returns a poller that is ready for streaming

impl<T> Clone for MysqlStorage<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for MysqlStorage<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Storage for MysqlStorage<T>

where T: Job + Serialize + DeserializeOwned + Send + 'static + Unpin + Sync,

type Job = T

The type of job that can be persisted

type Error = Error

The error produced by the storage

type Identifier = TaskId

Jobs must have Ids.

async fn push(&mut self, job: Self::Job) -> Result<TaskId, Error>

Pushes a job to a storage

async fn schedule(&mut self, job: Self::Job, on: i64) -> Result<TaskId, Error>

Push a job into the scheduled set

async fn fetch_by_id( &self, job_id: &TaskId ) -> Result<Option<Request<Self::Job>>, Error>

Fetch a job given an id

async fn len(&self) -> Result<i64, Error>

Return the number of pending jobs from the queue

async fn reschedule( &mut self, job: Request<T>, wait: Duration ) -> Result<(), Error>

Reschedule a job

async fn update(&self, job: Request<Self::Job>) -> Result<(), Error>

Update a job details

async fn is_empty(&self) -> Result<bool, Self::Error>

Returns true if there is no jobs in the storage

async fn vacuum(&self) -> Result<usize, Error>

Vacuum the storage, removes done and killed jobs