Skip to content

Commit

Permalink
ref(metrics): Remove option for controlling metrics summaries calcula…
Browse files Browse the repository at this point in the history
…tion
  • Loading branch information
iambriccardo committed Jul 8, 2024
1 parent 9d24cb3 commit 2ab86b1
Show file tree
Hide file tree
Showing 5 changed files with 4 additions and 44 deletions.
8 changes: 0 additions & 8 deletions relay-dynamic-config/src/global.rs
Original file line number Diff line number Diff line change
Expand Up @@ -214,14 +214,6 @@ pub struct Options {
)]
pub span_extraction_sample_rate: Option<f32>,

/// Overall sampling of metrics summaries computation.
#[serde(
rename = "relay.compute-metrics-summaries.sample-rate",
deserialize_with = "default_on_error",
skip_serializing_if = "is_default"
)]
pub compute_metrics_summaries_sample_rate: Option<f32>,

/// The maximum duplication factor used to extrapolate distribution metrics from sampled data.
///
/// This applies as long as Relay duplicates distribution values to extrapolate. The default is
Expand Down
22 changes: 3 additions & 19 deletions relay-server/src/metrics_extraction/event.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,20 +52,11 @@ pub fn extract_metrics(
config: CombinedMetricExtractionConfig<'_>,
max_tag_value_size: usize,
span_extraction_sample_rate: Option<f32>,
compute_metrics_summaries_sample_rate: Option<f32>,
) -> Vec<Bucket> {
let mut metrics = generic::extract_metrics(event, config);
// If spans were already extracted for an event, we rely on span processing to extract metrics.
if !spans_extracted && sample(span_extraction_sample_rate.unwrap_or(1.0)) {
let compute_metrics_summaries_sample_rate =
compute_metrics_summaries_sample_rate.unwrap_or(1.0);
extract_span_metrics_for_event(
event,
config,
max_tag_value_size,
&mut metrics,
compute_metrics_summaries_sample_rate,
);
extract_span_metrics_for_event(event, config, max_tag_value_size, &mut metrics);
}

metrics
Expand All @@ -76,17 +67,12 @@ fn extract_span_metrics_for_event(
config: CombinedMetricExtractionConfig<'_>,
max_tag_value_size: usize,
output: &mut Vec<Bucket>,
compute_metrics_summaries_sample_rate: f32,
) {
let compute_metrics_summaries = sample(compute_metrics_summaries_sample_rate);

relay_statsd::metric!(timer(RelayTimers::EventProcessingSpanMetricsExtraction), {
if let Some(transaction_span) = extract_transaction_span(event, max_tag_value_size) {
let (metrics, metrics_summary) =
metrics_summary::extract_and_summarize_metrics(&transaction_span, config);
if compute_metrics_summaries {
metrics_summary.apply_on(&mut event._metrics_summary);
}
metrics_summary.apply_on(&mut event._metrics_summary);
output.extend(metrics);
}

Expand All @@ -95,9 +81,7 @@ fn extract_span_metrics_for_event(
if let Some(span) = annotated_span.value_mut() {
let (metrics, metrics_summary) =
metrics_summary::extract_and_summarize_metrics(span, config);
if compute_metrics_summaries {
metrics_summary.apply_on(&mut span._metrics_summary);
}
metrics_summary.apply_on(&mut span._metrics_summary);
output.extend(metrics);
}
}
Expand Down
1 change: 0 additions & 1 deletion relay-server/src/services/processor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1428,7 +1428,6 @@ impl EnvelopeProcessorService {
.aggregator
.max_tag_value_length,
global.options.span_extraction_sample_rate,
global.options.compute_metrics_summaries_sample_rate,
);

state
Expand Down
9 changes: 1 addition & 8 deletions relay-server/src/services/processor/span/processing.rs
Original file line number Diff line number Diff line change
Expand Up @@ -158,14 +158,7 @@ pub fn process(
span,
CombinedMetricExtractionConfig::new(global_metrics_config, config),
);
if sample(
global_config
.options
.compute_metrics_summaries_sample_rate
.unwrap_or(1.0),
) {
metrics_summary.apply_on(&mut span._metrics_summary)
}
metrics_summary.apply_on(&mut span._metrics_summary);

state
.extracted_metrics
Expand Down
8 changes: 0 additions & 8 deletions tests/integration/test_spans.py
Original file line number Diff line number Diff line change
Expand Up @@ -2062,10 +2062,6 @@ def test_metrics_summary_with_extracted_spans(
relay_with_processing,
metrics_summaries_consumer,
):
mini_sentry.global_config["options"] = {
"relay.compute-metrics-summaries.sample-rate": 1.0
}

metrics_summaries_consumer = metrics_summaries_consumer()

relay = relay_with_processing()
Expand Down Expand Up @@ -2139,10 +2135,6 @@ def test_metrics_summary_with_standalone_spans(
relay_with_processing,
metrics_summaries_consumer,
):
mini_sentry.global_config["options"] = {
"relay.compute-metrics-summaries.sample-rate": 1.0
}

metrics_summaries_consumer = metrics_summaries_consumer()

relay = relay_with_processing()
Expand Down

0 comments on commit 2ab86b1

Please sign in to comment.