Skip to content
This repository has been archived by the owner on Jun 8, 2024. It is now read-only.

Commit

Permalink
more CI fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
KodrAus committed Jun 6, 2024
1 parent 1ee8e11 commit c9fde0e
Show file tree
Hide file tree
Showing 5 changed files with 2 additions and 70 deletions.
2 changes: 1 addition & 1 deletion emitter/file/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ default_writer = ["emit/sval", "sval_json"]
version = "0.11.0-alpha.1"
path = "../../"
default-features = false
features = ["std"]
features = ["std", "implicit_internal_rt"]

[dependencies.sval]
version = "2"
Expand Down
4 changes: 1 addition & 3 deletions emitter/file/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -99,8 +99,6 @@ use std::{
thread,
};

use emit::Props as _;

use emit_batcher::BatchError;
use internal_metrics::InternalMetrics;

Expand Down Expand Up @@ -484,7 +482,7 @@ fn default_writer(
) -> io::Result<()> {
use std::ops::ControlFlow;

use emit::well_known::{KEY_MSG, KEY_TPL, KEY_TS, KEY_TS_START};
use emit::{Props as _, well_known::{KEY_MSG, KEY_TPL, KEY_TS, KEY_TS_START}};

struct EventValue<'a, P>(&'a emit::Event<'a, P>);

Expand Down
22 changes: 0 additions & 22 deletions emitter/otlp/src/data/logs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -88,25 +88,3 @@ impl<'a> sval::Value for EncodedScopeLogs<'a> {
})
}
}

#[cfg(feature = "decode_responses")]
pub(crate) fn decode_response(body: Result<&[u8], &[u8]>) {
match body {
Ok(body) => {
emit::debug!(
rt: emit::runtime::internal(),
"received logs {response}",
#[emit::as_debug]
response: crate::data::generated::response::decode::<crate::data::generated::collector::logs::v1::ExportLogsServiceResponse>(body),
);
}
Err(body) => {
emit::warn!(
rt: emit::runtime::internal(),
"received logs {response}",
#[emit::as_debug]
response: crate::data::generated::response::decode::<crate::data::generated::google::rpc::Status>(body),
);
}
}
}
22 changes: 0 additions & 22 deletions emitter/otlp/src/data/metrics.rs
Original file line number Diff line number Diff line change
Expand Up @@ -393,25 +393,3 @@ impl<'a> sval::Value for EncodedScopeMetrics<'a> {
})
}
}

#[cfg(feature = "decode_responses")]
pub(crate) fn decode_response(body: Result<&[u8], &[u8]>) {
match body {
Ok(body) => {
emit::debug!(
rt: emit::runtime::internal(),
"received metrics {response}",
#[emit::as_debug]
response: crate::data::generated::response::decode::<crate::data::generated::collector::metrics::v1::ExportMetricsServiceResponse>(body),
);
}
Err(body) => {
emit::warn!(
rt: emit::runtime::internal(),
"received metrics {response}",
#[emit::as_debug]
response: crate::data::generated::response::decode::<crate::data::generated::google::rpc::Status>(body),
);
}
}
}
22 changes: 0 additions & 22 deletions emitter/otlp/src/data/traces.rs
Original file line number Diff line number Diff line change
Expand Up @@ -104,25 +104,3 @@ impl<'a> sval::Value for EncodedScopeSpans<'a> {
})
}
}

#[cfg(feature = "decode_responses")]
pub(crate) fn decode_response(body: Result<&[u8], &[u8]>) {
match body {
Ok(body) => {
emit::debug!(
rt: emit::runtime::internal(),
"received traces {response}",
#[emit::as_debug]
response: crate::data::generated::response::decode::<crate::data::generated::collector::trace::v1::ExportTraceServiceResponse>(body),
);
}
Err(body) => {
emit::warn!(
rt: emit::runtime::internal(),
"received traces {response}",
#[emit::as_debug]
response: crate::data::generated::response::decode::<crate::data::generated::google::rpc::Status>(body),
);
}
}
}

0 comments on commit c9fde0e

Please sign in to comment.