kubeworks/kube-yaseg
Watch
1
0
Fork
You've already forked kube-yaseg
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(controller/reporting): make clippy happy

Browse source
This commit is contained in:
spushk 2026-05-15 13:07:08 +05:00 • committed by spushk
commit 843ba014aa
Signed by: spushk
GPG key ID: 7797B761E105E8AA
1 changed files with 12 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

20
kuyaseg-controller/src/reporting/tracing_evt.rs
View file

@ -27,8 +27,13 @@ use crate::reporting::prometheus::{
/// - k8s events are not automatically recorded /// - k8s events are not automatically recorded
/// - prometheus labels are recorded if metrics are set for layer /// - prometheus labels are recorded if metrics are set for layer
pub enum TracingK8sEvent { pub enum TracingK8sEvent {
K8sEvent { reference: ObjectReference, event: Event }, K8sEvent {
ProLabel { label: ProLabel }, reference: ObjectReference,
event: Box<Event>,
},
ProLabel {
label: ProLabel,
},
} }
/// Watches for tracing events, containing information necessary to construst k8s events and write prometheus metrics. /// Watches for tracing events, containing information necessary to construst k8s events and write prometheus metrics.
@ -124,16 +129,16 @@ where
_ = tx _ = tx
.send(TracingK8sEvent::K8sEvent { .send(TracingK8sEvent::K8sEvent {
reference: span_fields.to_object(), reference: span_fields.to_object(),
event, event: Box::new(event),
}) })
.inspect_err(|e| tracing::error!(debug=?e, "Failed to issue event on k8s event from tracing")); .inspect_err(|e| tracing::error!(debug=?e, "Failed to issue event on k8s event from tracing"));
} }
// write/measure pro event // write/measure pro event
if let Some(label) = try_create_pro_label(&span_fields, &event_fields, pro_severity) { if let Some(label) = try_create_pro_label(&span_fields, &event_fields, pro_severity) {
self.metrics.read().as_ref().map(|metrics| { if let Some(metrics) = self.metrics.read().as_ref() {
metrics.measure(&label); metrics.measure(&label);
}); }
_ = tx.send(TracingK8sEvent::ProLabel { label }).inspect_err( _ = tx.send(TracingK8sEvent::ProLabel { label }).inspect_err(
|e| tracing::error!(debug=?e, "Failed to issue event on prometheus label measure from tracing"), |e| tracing::error!(debug=?e, "Failed to issue event on prometheus label measure from tracing"),
@ -262,9 +267,8 @@ impl Visit for EventFields {
} }
fn record_bool(&mut self, field: &tracing::field::Field, value: bool) { fn record_bool(&mut self, field: &tracing::field::Field, value: bool) {
match field.name() { if field.name() == "critical" {
"critical" => self.critical = Some(value), self.critical = Some(value)
_ => {}
} }
} }