opentelemetry-spanprocessor-any 0.17.0

A metrics collection and distributed tracing framework
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

use crate::metrics::{AtomicNumber, Descriptor, MetricsError, Number, Result};
use crate::sdk::export::metrics::{Aggregator, Subtractor, Sum};
use std::any::Any;
use std::sync::Arc;

/// Create a new sum aggregator.
pub fn sum() -> SumAggregator {
    SumAggregator::default()
}

/// An aggregator for counter events.
#[derive(Debug, Default)]
pub struct SumAggregator {
    value: AtomicNumber,
}

impl Sum for SumAggregator {
    fn sum(&self) -> Result<Number> {
        Ok(self.value.load())
    }
}

impl Subtractor for SumAggregator {
    fn subtract(
        &self,
        operand: &(dyn Aggregator + Send + Sync),
        result: &(dyn Aggregator + Send + Sync),
        descriptor: &Descriptor,
    ) -> Result<()> {
        match (
            operand.as_any().downcast_ref::<Self>(),
            result.as_any().downcast_ref::<Self>(),
        ) {
            (Some(op), Some(res)) => {
                res.value.store(&self.value.load());
                res.value
                    .fetch_add(descriptor.number_kind(), &op.value.load());
                Ok(())
            }
            _ => Err(MetricsError::InconsistentAggregator(format!(
                "Expected {:?}, got: {:?} and {:?}",
                self, operand, result
            ))),
        }
    }
}

impl Aggregator for SumAggregator {
    fn update(&self, number: &Number, descriptor: &Descriptor) -> Result<()> {
        self.value.fetch_add(descriptor.number_kind(), number);
        Ok(())
    }
    fn synchronized_move(
        &self,
        other: &Arc<dyn Aggregator + Send + Sync>,
        descriptor: &Descriptor,
    ) -> Result<()> {
        if let Some(other) = other.as_any().downcast_ref::<Self>() {
            let kind = descriptor.number_kind();
            other.value.store(&self.value.load());
            self.value.store(&kind.zero());
            Ok(())
        } else {
            Err(MetricsError::InconsistentAggregator(format!(
                "Expected {:?}, got: {:?}",
                self, other
            )))
        }
    }
    fn merge(&self, other: &(dyn Aggregator + Send + Sync), descriptor: &Descriptor) -> Result<()> {
        if let Some(other_sum) = other.as_any().downcast_ref::<SumAggregator>() {
            self.value
                .fetch_add(descriptor.number_kind(), &other_sum.value.load())
        }

        Ok(())
    }
    fn as_any(&self) -> &dyn Any {
        self
    }
}