blob: 0dfbefe5f3ced9cd397fbf043b23739b6db51da6 (
plain) (
blame)
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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
#include <stdint.h>
#include <chrono>
#include <memory>
#include <mutex>
#include "opentelemetry/common/spin_lock_mutex.h"
#include "opentelemetry/common/timestamp.h"
#include "opentelemetry/nostd/variant.h"
#include "opentelemetry/sdk/metrics/aggregation/aggregation.h"
#include "opentelemetry/sdk/metrics/aggregation/lastvalue_aggregation.h"
#include "opentelemetry/sdk/metrics/data/metric_data.h"
#include "opentelemetry/sdk/metrics/data/point_data.h"
#include "opentelemetry/version.h"
OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
namespace metrics
{
LongLastValueAggregation::LongLastValueAggregation()
{
point_data_.is_lastvalue_valid_ = false;
point_data_.value_ = static_cast<int64_t>(0);
}
LongLastValueAggregation::LongLastValueAggregation(const LastValuePointData &data)
: point_data_{data}
{}
void LongLastValueAggregation::Aggregate(int64_t value,
const PointAttributes & /* attributes */) noexcept
{
const std::lock_guard<opentelemetry::common::SpinLockMutex> locked(lock_);
point_data_.is_lastvalue_valid_ = true;
point_data_.value_ = value;
point_data_.sample_ts_ = std::chrono::system_clock::now();
}
std::unique_ptr<Aggregation> LongLastValueAggregation::Merge(
const Aggregation &delta) const noexcept
{
if (nostd::get<LastValuePointData>(ToPoint()).sample_ts_.time_since_epoch() >
nostd::get<LastValuePointData>(delta.ToPoint()).sample_ts_.time_since_epoch())
{
LastValuePointData merge_data = nostd::get<LastValuePointData>(ToPoint());
return std::unique_ptr<Aggregation>(new LongLastValueAggregation(merge_data));
}
else
{
LastValuePointData merge_data = nostd::get<LastValuePointData>(delta.ToPoint());
return std::unique_ptr<Aggregation>(new LongLastValueAggregation(merge_data));
}
}
std::unique_ptr<Aggregation> LongLastValueAggregation::Diff(const Aggregation &next) const noexcept
{
if (nostd::get<LastValuePointData>(ToPoint()).sample_ts_.time_since_epoch() >
nostd::get<LastValuePointData>(next.ToPoint()).sample_ts_.time_since_epoch())
{
LastValuePointData diff_data = nostd::get<LastValuePointData>(ToPoint());
return std::unique_ptr<Aggregation>(new LongLastValueAggregation(diff_data));
}
else
{
LastValuePointData diff_data = nostd::get<LastValuePointData>(next.ToPoint());
return std::unique_ptr<Aggregation>(new LongLastValueAggregation(diff_data));
}
}
PointType LongLastValueAggregation::ToPoint() const noexcept
{
const std::lock_guard<opentelemetry::common::SpinLockMutex> locked(lock_);
return point_data_;
}
DoubleLastValueAggregation::DoubleLastValueAggregation()
{
point_data_.is_lastvalue_valid_ = false;
point_data_.value_ = 0.0;
}
DoubleLastValueAggregation::DoubleLastValueAggregation(const LastValuePointData &data)
: point_data_{data}
{}
void DoubleLastValueAggregation::Aggregate(double value,
const PointAttributes & /* attributes */) noexcept
{
const std::lock_guard<opentelemetry::common::SpinLockMutex> locked(lock_);
point_data_.is_lastvalue_valid_ = true;
point_data_.value_ = value;
point_data_.sample_ts_ = std::chrono::system_clock::now();
}
std::unique_ptr<Aggregation> DoubleLastValueAggregation::Merge(
const Aggregation &delta) const noexcept
{
if (nostd::get<LastValuePointData>(ToPoint()).sample_ts_.time_since_epoch() >
nostd::get<LastValuePointData>(delta.ToPoint()).sample_ts_.time_since_epoch())
{
LastValuePointData merge_data = nostd::get<LastValuePointData>(ToPoint());
return std::unique_ptr<Aggregation>(new DoubleLastValueAggregation(merge_data));
}
else
{
LastValuePointData merge_data = nostd::get<LastValuePointData>(delta.ToPoint());
return std::unique_ptr<Aggregation>(new DoubleLastValueAggregation(merge_data));
}
}
std::unique_ptr<Aggregation> DoubleLastValueAggregation::Diff(
const Aggregation &next) const noexcept
{
if (nostd::get<LastValuePointData>(ToPoint()).sample_ts_.time_since_epoch() >
nostd::get<LastValuePointData>(next.ToPoint()).sample_ts_.time_since_epoch())
{
LastValuePointData diff_data = nostd::get<LastValuePointData>(ToPoint());
return std::unique_ptr<Aggregation>(new DoubleLastValueAggregation(diff_data));
}
else
{
LastValuePointData diff_data = nostd::get<LastValuePointData>(next.ToPoint());
return std::unique_ptr<Aggregation>(new DoubleLastValueAggregation(diff_data));
}
}
PointType DoubleLastValueAggregation::ToPoint() const noexcept
{
const std::lock_guard<opentelemetry::common::SpinLockMutex> locked(lock_);
return point_data_;
}
} // namespace metrics
} // namespace sdk
OPENTELEMETRY_END_NAMESPACE
|
