anthrove/bkapi
4
0
Fork 0
mirror of https://github.com/Syfaro/bkapi.git synced 2024-11-21 14:34:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bump versions.

Browse Source
This commit is contained in:
Syfaro 2022-10-12 16:38:11 -04:00
parent 1271acc49c
commit e5b7e6b5a7
4 changed files with 508 additions and 499 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

981
Cargo.lock generated
View File

File diff suppressed because it is too large Load Diff

2
bkapi-client/src/lib.rs
View File

@ -85,7 +85,7 @@ impl BKApiClient {
) -> Result<Vec<SearchResults>, reqwest::Error> {
let mut futs = futures::stream::FuturesOrdered::new();
for hash in hashes {
futs.push(self.search(*hash, distance));
futs.push_back(self.search(*hash, distance));
}
futs.try_collect().await

10
bkapi/Cargo.toml
View File

@ -11,10 +11,10 @@ thiserror = "1"
tracing = "0.1"
tracing-subscriber = { version = "0.3", features = ["env-filter"] }
tracing-unwrap = "0.9"
tracing-opentelemetry = "0.17"
tracing-opentelemetry = "0.18"
opentelemetry = { version = "0.17", features = ["rt-tokio"] }
opentelemetry-jaeger = { version = "0.16", features = ["rt-tokio"] }
opentelemetry = { version = "0.18", features = ["rt-tokio"] }
opentelemetry-jaeger = { version = "0.17", features = ["rt-tokio"] }
lazy_static = "1"
prometheus = { version = "0.13", features = ["process"] }
@ -31,8 +31,8 @@ serde_json = "1"
actix-web = "4"
actix-http = "3"
actix-service = "2"
tracing-actix-web = { version = "0.5", features = ["opentelemetry_0_17"] }
tracing-actix-web = { version = "0.6", features = ["opentelemetry_0_17"] }
[dependencies.sqlx]
version = "0.5"
version = "0.6"
features = ["runtime-actix-rustls", "postgres"]

14
bkapi/src/main.rs
View File

@ -141,13 +141,15 @@ fn configure_tracing(config: &Config) {
"release"
};
let tracer = opentelemetry_jaeger::new_pipeline()
.with_agent_endpoint(&config.jaeger_agent)
let tracer = opentelemetry_jaeger::new_agent_pipeline()
.with_endpoint(&config.jaeger_agent)
.with_service_name(&config.service_name)
.with_tags(vec![
KeyValue::new("environment", env.to_owned()),
KeyValue::new("version", env!("CARGO_PKG_VERSION")),
])
.with_trace_config(opentelemetry::sdk::trace::config().with_resource(
opentelemetry::sdk::Resource::new(vec![
KeyValue::new("environment", env.to_owned()),
KeyValue::new("version", env!("CARGO_PKG_VERSION")),
]),
))
.install_batch(opentelemetry::runtime::Tokio)
.expect("otel jaeger pipeline could not be created");