mirror of
https://github.com/Diggsey/sqlxmq.git
synced 2024-11-21 15:51:00 +00:00
commit
e1cbd9f551
1 changed files with 2 additions and 2 deletions
|
@ -150,7 +150,7 @@ pub async fn commit<'b, E: sqlx::Executor<'b, Database = Postgres>>(
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Clear jobs from the specified queues.
|
/// Clear jobs from the specified channels.
|
||||||
pub async fn clear<'b, E: sqlx::Executor<'b, Database = Postgres>>(
|
pub async fn clear<'b, E: sqlx::Executor<'b, Database = Postgres>>(
|
||||||
executor: E,
|
executor: E,
|
||||||
channel_names: &[&str],
|
channel_names: &[&str],
|
||||||
|
@ -162,7 +162,7 @@ pub async fn clear<'b, E: sqlx::Executor<'b, Database = Postgres>>(
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Clear jobs from the specified queues.
|
/// Clear jobs from all channels.
|
||||||
pub async fn clear_all<'b, E: sqlx::Executor<'b, Database = Postgres>>(
|
pub async fn clear_all<'b, E: sqlx::Executor<'b, Database = Postgres>>(
|
||||||
executor: E,
|
executor: E,
|
||||||
) -> Result<(), sqlx::Error> {
|
) -> Result<(), sqlx::Error> {
|
||||||
|
|
Loading…
Reference in a new issue