Skip to content

Commit

Permalink
Revert "ref(statsd): Add metric name as a tag for Sentry errors (#1797)"
Browse files Browse the repository at this point in the history
This reverts commit d873ce2.
  • Loading branch information
iker-barriocanal committed Feb 22, 2023
1 parent 5e89b77 commit 2f4e6e1
Show file tree
Hide file tree
Showing 2 changed files with 49 additions and 84 deletions.
6 changes: 6 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,11 @@
# Changelog

## Unreleased

**Internal**:

- Revert back the addition of metric names as tag on Sentry errors when relay drops metrics.

## 23.2.0

**Features**:
Expand Down
127 changes: 43 additions & 84 deletions relay-statsd/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -492,122 +492,81 @@ pub trait GaugeMetric {
macro_rules! metric {
// counter increment
(counter($id:expr) += $value:expr $(, $k:ident = $v:expr)* $(,)?) => {
relay_log::with_scope(
|scope| {
scope.set_tag("key", &$crate::CounterMetric::name(&$id));
}, || {
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.count_with_tags(&$crate::CounterMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
}
)
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.count_with_tags(&$crate::CounterMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
};

// counter decrement
(counter($id:expr) -= $value:expr $(, $k:ident = $v:expr)* $(,)?) => {
relay_log::with_scope(
|scope| {
scope.set_tag("key", &$crate::CounterMetric::name(&$id));
}, || {
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.count_with_tags(&$crate::CounterMetric::name(&$id), -$value)
$(.with_tag(stringify!($k), $v))*
)
})
}
)
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.count_with_tags(&$crate::CounterMetric::name(&$id), -$value)
$(.with_tag(stringify!($k), $v))*
)
})
};

// gauge set
(gauge($id:expr) = $value:expr $(, $k:ident = $v:expr)* $(,)?) => {
$crate::with_client(|client| {
use $crate::_pred::*;
relay_log::with_scope(
|scope| {
scope.set_tag("key", &$crate::GaugeMetric::name(&$id));
}, || {
client.send_metric(
client.gauge_with_tags(&$crate::GaugeMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
}
client.send_metric(
client.gauge_with_tags(&$crate::GaugeMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
};

// histogram
(histogram($id:expr) = $value:expr $(, $k:ident = $v:expr)* $(,)?) => {
use $crate::_pred::*;
relay_log::with_scope(
|scope| {
scope.set_tag("key", &$crate::HistogramMetric::name(&$id));
}, || {
$crate::with_client(|client| {
client.send_metric(
client.histogram_with_tags(&$crate::HistogramMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
}
)
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.histogram_with_tags(&$crate::HistogramMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
};

// sets (count unique occurrences of a value per time interval)
(set($id:expr) = $value:expr $(, $k:ident = $v:expr)* $(,)?) => {
use $crate::_pred::*;
relay_log::with_scope(
|scope| {
scope.set_tag("key", &$crate::SetMetric::name(&$id));
}, || {
$crate::with_client(|client| {
client.send_metric(
client.set_with_tags(&$crate::SetMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
}
)
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.set_with_tags(&$crate::SetMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
};

// timer value (duration)
(timer($id:expr) = $value:expr $(, $k:ident = $v:expr)* $(,)?) => {
$crate::with_client(|client| {
relay_log::with_scope(
|scope| {
scope.set_tag("key", &$crate::TimerMetric::name(&$id));
}, || {
use $crate::_pred::*;
client.send_metric(
client.time_with_tags(&$crate::TimerMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
use $crate::_pred::*;
client.send_metric(
client.time_with_tags(&$crate::TimerMetric::name(&$id), $value)
$(.with_tag(stringify!($k), $v))*
)
})
};

// timed block
(timer($id:expr), $($k:ident = $v:expr,)* $block:block) => {{
let now = std::time::Instant::now();
let rv = {$block};
relay_log::with_scope(
|scope| {
scope.set_tag("key", &$crate::TimerMetric::name(&$id));
}, || {
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.time_with_tags(&$crate::TimerMetric::name(&$id), now.elapsed())
$(.with_tag(stringify!($k), $v))*
)
});
}
);
$crate::with_client(|client| {
use $crate::_pred::*;
client.send_metric(
client.time_with_tags(&$crate::TimerMetric::name(&$id), now.elapsed())
$(.with_tag(stringify!($k), $v))*
)
});
rv
}};
}
Expand Down

0 comments on commit 2f4e6e1

Please sign in to comment.