Update versions.

This commit is contained in:
Syfaro 2024-03-22 21:45:51 -04:00
parent febb96e3bf
commit 69df266fcf
5 changed files with 449 additions and 211 deletions

637
Cargo.lock generated

File diff suppressed because it is too large Load Diff

View File

@ -9,15 +9,15 @@ publish = false
nats = ["async-nats"] nats = ["async-nats"]
[dependencies] [dependencies]
async-nats = { version = "0.31.0", optional = true } async-nats = { version = "0.34.0", optional = true }
futures = "0.3" futures = "0.3"
opentelemetry = "0.18" opentelemetry = "0.22.0"
opentelemetry-http = "0.7" opentelemetry-http = "0.11.0"
reqwest = { version = "0.11", default-features = false, features = ["json"] } reqwest = { version = "0.11.0", default-features = false, features = ["json"] }
serde = { version = "1", features = ["derive"] } serde = { version = "1", features = ["derive"] }
serde_json = "1" serde_json = "1"
tracing = "0.1" tracing = "0.1"
tracing-opentelemetry = "0.18" tracing-opentelemetry = "0.23.0"
[dev-dependencies] [dev-dependencies]
tokio = { version = "1", features = ["full"] } tokio = { version = "1", features = ["full"] }

View File

@ -17,7 +17,7 @@ pub struct HashDistance {
} }
impl BKApiNatsClient { impl BKApiNatsClient {
const NATS_SUBJECT: &str = "bkapi.search"; const NATS_SUBJECT: &'static str = "bkapi.search";
/// Create a new client with a given NATS client. /// Create a new client with a given NATS client.
pub fn new(client: async_nats::Client, prefix: &str) -> Self { pub fn new(client: async_nats::Client, prefix: &str) -> Self {

View File

@ -9,7 +9,7 @@ publish = false
actix-http = "3" actix-http = "3"
actix-service = "2" actix-service = "2"
actix-web = "4" actix-web = "4"
async-nats = { version = "0.31", features = ["service"] } async-nats = { version = "0.34", features = ["service"] }
bincode = { version = "2.0.0-rc.3", features = ["serde"] } bincode = { version = "2.0.0-rc.3", features = ["serde"] }
bk-tree = { version = "0.5.0", features = ["serde"] } bk-tree = { version = "0.5.0", features = ["serde"] }
clap = { version = "4", features = ["derive", "env"] } clap = { version = "4", features = ["derive", "env"] }
@ -18,7 +18,7 @@ flate2 = "1"
futures = "0.3" futures = "0.3"
hamming = "0.1" hamming = "0.1"
lazy_static = "1" lazy_static = "1"
opentelemetry = { version = "0.18", features = ["rt-tokio"] } opentelemetry = "0.22"
prometheus = { version = "0.13", features = ["process"] } prometheus = { version = "0.13", features = ["process"] }
serde = { version = "1", features = ["derive"] } serde = { version = "1", features = ["derive"] }
serde_json = "1" serde_json = "1"
@ -26,10 +26,10 @@ thiserror = "1"
tokio = { version = "1", features = ["sync"] } tokio = { version = "1", features = ["sync"] }
tokio-util = { version = "0.7", features = ["io", "io-util"] } tokio-util = { version = "0.7", features = ["io", "io-util"] }
tracing = "0.1" tracing = "0.1"
tracing-actix-web = { version = "0.7", features = ["opentelemetry_0_18"] } tracing-actix-web = { version = "0.7", features = ["opentelemetry_0_22"] }
tracing-opentelemetry = "0.18" tracing-opentelemetry = "0.23.0"
tracing-subscriber = { version = "0.3", features = ["env-filter"] } tracing-subscriber = { version = "0.3", features = ["env-filter"] }
tracing-unwrap = "0.10" tracing-unwrap = "1.0.1"
foxlib = { git = "https://github.com/Syfaro/foxlib.git" } foxlib = { git = "https://github.com/Syfaro/foxlib.git" }

View File

@ -334,6 +334,7 @@ async fn search_nats(
description: None, description: None,
stats_handler: None, stats_handler: None,
metadata: None, metadata: None,
queue_group: None,
}) })
.await .await
.map_err(NatsError::Generic)?; .map_err(NatsError::Generic)?;