mirror of
https://git.asonix.dog/asonix/background-jobs.git
synced 2024-11-21 19:40:59 +00:00
Update event-listener, bump jobs-core version
This commit is contained in:
parent
4dbde2c9eb
commit
ce4858d87a
2 changed files with 3 additions and 4 deletions
|
@ -1,7 +1,7 @@
|
||||||
[package]
|
[package]
|
||||||
name = "background-jobs-core"
|
name = "background-jobs-core"
|
||||||
description = "Core types for implementing an asynchronous jobs processor"
|
description = "Core types for implementing an asynchronous jobs processor"
|
||||||
version = "0.18.0"
|
version = "0.18.1"
|
||||||
license = "AGPL-3.0"
|
license = "AGPL-3.0"
|
||||||
authors = ["asonix <asonix@asonix.dog>"]
|
authors = ["asonix <asonix@asonix.dog>"]
|
||||||
repository = "https://git.asonix.dog/asonix/background-jobs"
|
repository = "https://git.asonix.dog/asonix/background-jobs"
|
||||||
|
@ -19,7 +19,7 @@ error-logging = []
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
async-trait = "0.1.24"
|
async-trait = "0.1.24"
|
||||||
event-listener = "4"
|
event-listener = "5"
|
||||||
metrics = "0.22.0"
|
metrics = "0.22.0"
|
||||||
time = { version = "0.3", features = ["serde-human-readable"] }
|
time = { version = "0.3", features = ["serde-human-readable"] }
|
||||||
tracing = "0.1"
|
tracing = "0.1"
|
||||||
|
|
|
@ -41,7 +41,6 @@ pub mod memory_storage {
|
||||||
convert::Infallible,
|
convert::Infallible,
|
||||||
future::Future,
|
future::Future,
|
||||||
ops::Bound,
|
ops::Bound,
|
||||||
pin::Pin,
|
|
||||||
sync::Arc,
|
sync::Arc,
|
||||||
sync::Mutex,
|
sync::Mutex,
|
||||||
time::Duration,
|
time::Duration,
|
||||||
|
@ -107,7 +106,7 @@ pub mod memory_storage {
|
||||||
.map(|(job_info, _)| job_info.clone())
|
.map(|(job_info, _)| job_info.clone())
|
||||||
}
|
}
|
||||||
|
|
||||||
fn listener(&self, pop_queue: String) -> (Pin<Box<EventListener>>, Duration) {
|
fn listener(&self, pop_queue: String) -> (EventListener, Duration) {
|
||||||
let lower_bound = QueueTimeId(Uuid::new_v7(Timestamp::from_unix(NoContext, 0, 0)));
|
let lower_bound = QueueTimeId(Uuid::new_v7(Timestamp::from_unix(NoContext, 0, 0)));
|
||||||
let now = OffsetDateTime::now_utc();
|
let now = OffsetDateTime::now_utc();
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue