datadog-opentelemetry 0.2.0

A Datadog layer of compatibility for the opentelemetry SDK
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

// Copyright 2025-Present Datadog, Inc. https://www.datadoghq.com/
// SPDX-License-Identifier: Apache-2.0

use std::{
    collections::HashMap,
    sync::{Arc, RwLock},
};

use super::rate_sampler::RateSampler;

#[derive(Debug, serde::Deserialize)]
pub(crate) struct AgentRates<'a> {
    #[serde(borrow)]
    pub rates_by_service: Option<HashMap<&'a str, f64>>,
}

#[derive(Debug, Default, Clone)]
pub(crate) struct ServicesSampler {
    inner: Arc<RwLock<HashMap<String, RateSampler>>>,
}

impl ServicesSampler {
    pub fn get(&self, service: &str) -> Option<RateSampler> {
        self.inner.read().unwrap().get(service).cloned()
    }

    pub fn update_rates<I: IntoIterator<Item = (String, f64)>>(&self, rates: I) {
        let new_rates: HashMap<_, _> = rates
            .into_iter()
            .map(|(s, r)| (s, RateSampler::new(r)))
            .collect();
        *self.inner.write().unwrap() = new_rates;
    }

    // used for testing purposes

    #[allow(dead_code)]
    pub(crate) fn is_empty(&self) -> bool {
        self.inner.read().unwrap().is_empty()
    }

    #[allow(dead_code)]
    pub(crate) fn len(&self) -> usize {
        self.inner.read().unwrap().len()
    }

    #[allow(dead_code)]
    pub(crate) fn contains_key(&self, service: &str) -> bool {
        self.inner.read().unwrap().contains_key(service)
    }
}