Skip to content

Commit cd4f81b

Browse files
simplified function that failed in deepsource analysis
1 parent fc1d9db commit cd4f81b

File tree

1 file changed

+41
-67
lines changed

1 file changed

+41
-67
lines changed

server/src/metrics/prom_utils.rs

Lines changed: 41 additions & 67 deletions
Original file line numberDiff line numberDiff line change
@@ -101,73 +101,47 @@ impl Metrics {
101101
) -> Result<Self, PostError> {
102102
let mut prom_dress = Metrics::new(ingestor_metadata.domain_name.to_string());
103103
for sample in samples {
104-
if &sample.metric == "parseable_events_ingested" {
105-
if let PromValue::Gauge(val) = sample.value {
106-
prom_dress.parseable_events_ingested += val;
107-
}
108-
}
109-
if &sample.metric == "parseable_events_ingested_size" {
110-
if let PromValue::Gauge(val) = sample.value {
111-
prom_dress.parseable_events_ingested_size += val;
112-
}
113-
}
114-
if &sample.metric == "parseable_lifetime_events_ingested" {
115-
if let PromValue::Gauge(val) = sample.value {
116-
prom_dress.parseable_lifetime_events_ingested += val;
117-
}
118-
}
119-
if &sample.metric == "parseable_lifetime_events_ingested_size" {
120-
if let PromValue::Gauge(val) = sample.value {
121-
prom_dress.parseable_lifetime_events_ingested_size += val;
122-
}
123-
}
124-
if &sample.metric == "parseable_deleted_events_ingested" {
125-
if let PromValue::Gauge(val) = sample.value {
126-
prom_dress.parseable_deleted_events_ingested += val;
127-
}
128-
}
129-
if &sample.metric == "parseable_deleted_events_ingested_size" {
130-
if let PromValue::Gauge(val) = sample.value {
131-
prom_dress.parseable_deleted_events_ingested_size += val;
132-
}
133-
}
134-
if sample.metric == "parseable_staging_files" {
135-
if let PromValue::Gauge(val) = sample.value {
136-
prom_dress.parseable_staging_files += val;
137-
}
138-
}
139-
if sample.metric == "process_resident_memory_bytes" {
140-
if let PromValue::Gauge(val) = sample.value {
141-
prom_dress.process_resident_memory_bytes += val;
142-
}
143-
}
144-
if sample.metric == "parseable_storage_size"
145-
&& sample.labels.get("type").expect("type is present") == "data"
146-
{
147-
if let PromValue::Gauge(val) = sample.value {
148-
prom_dress.parseable_storage_size.data += val;
149-
}
150-
}
151-
if sample.metric == "parseable_storage_size"
152-
&& sample.labels.get("type").expect("type is present") == "staging"
153-
{
154-
if let PromValue::Gauge(val) = sample.value {
155-
prom_dress.parseable_storage_size.staging += val;
156-
}
157-
}
158-
159-
if sample.metric == "parseable_lifetime_events_storage_size"
160-
&& sample.labels.get("type").expect("type is present") == "data"
161-
{
162-
if let PromValue::Gauge(val) = sample.value {
163-
prom_dress.parseable_lifetime_storage_size.data += val;
164-
}
165-
}
166-
if sample.metric == "parseable_deleted_events_storage_size"
167-
&& sample.labels.get("type").expect("type is present") == "data"
168-
{
169-
if let PromValue::Gauge(val) = sample.value {
170-
prom_dress.parseable_deleted_storage_size.data += val;
104+
if let PromValue::Gauge(val) = sample.value {
105+
match sample.metric.as_str() {
106+
"parseable_events_ingested" => prom_dress.parseable_events_ingested += val,
107+
"parseable_events_ingested_size" => {
108+
prom_dress.parseable_events_ingested_size += val
109+
}
110+
"parseable_lifetime_events_ingested" => {
111+
prom_dress.parseable_lifetime_events_ingested += val
112+
}
113+
"parseable_lifetime_events_ingested_size" => {
114+
prom_dress.parseable_lifetime_events_ingested_size += val
115+
}
116+
"parseable_deleted_events_ingested" => {
117+
prom_dress.parseable_deleted_events_ingested += val
118+
}
119+
"parseable_deleted_events_ingested_size" => {
120+
prom_dress.parseable_deleted_events_ingested_size += val
121+
}
122+
"parseable_staging_files" => prom_dress.parseable_staging_files += val,
123+
"process_resident_memory_bytes" => {
124+
prom_dress.process_resident_memory_bytes += val
125+
}
126+
"parseable_storage_size" => {
127+
if sample.labels.get("type").expect("type is present") == "staging" {
128+
prom_dress.parseable_storage_size.staging += val;
129+
}
130+
if sample.labels.get("type").expect("type is present") == "data" {
131+
prom_dress.parseable_storage_size.data += val;
132+
}
133+
}
134+
"parseable_lifetime_events_storage_size" => {
135+
if sample.labels.get("type").expect("type is present") == "data" {
136+
prom_dress.parseable_lifetime_storage_size.data += val;
137+
}
138+
}
139+
"parseable_deleted_events_storage_size" => {
140+
if sample.labels.get("type").expect("type is present") == "data" {
141+
prom_dress.parseable_deleted_storage_size.data += val;
142+
}
143+
}
144+
_ => {}
171145
}
172146
}
173147
}

0 commit comments

Comments
 (0)