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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
#include <chrono>
#include <memory>
#include <string>
#include <unordered_map>
#include <utility>
#include <vector>
#include "opentelemetry/common/attribute_value.h"
#include "opentelemetry/common/key_value_iterable.h"
#include "opentelemetry/common/timestamp.h"
#include "opentelemetry/nostd/string_view.h"
#include "opentelemetry/sdk/common/attribute_utils.h"
#include "opentelemetry/sdk/instrumentationscope/instrumentation_scope.h"
#include "opentelemetry/sdk/resource/resource.h"
#include "opentelemetry/sdk/trace/span_data.h"
#include "opentelemetry/trace/span_context.h"
#include "opentelemetry/trace/span_id.h"
#include "opentelemetry/trace/span_metadata.h"
#include "opentelemetry/trace/trace_flags.h"
#include "opentelemetry/version.h"
OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
namespace trace
{
SpanDataEvent::SpanDataEvent(std::string name,
opentelemetry::common::SystemTimestamp timestamp,
const opentelemetry::common::KeyValueIterable &attributes)
: name_(std::move(name)), timestamp_(timestamp), attribute_map_(attributes)
{}
const std::unordered_map<std::string, opentelemetry::sdk::common::OwnedAttributeValue> &
SpanDataEvent::GetAttributes() const noexcept
{
return attribute_map_.GetAttributes();
}
SpanDataLink::SpanDataLink(opentelemetry::trace::SpanContext span_context,
const opentelemetry::common::KeyValueIterable &attributes)
: span_context_(std::move(span_context)), attribute_map_(attributes)
{}
const std::unordered_map<std::string, opentelemetry::sdk::common::OwnedAttributeValue> &
SpanDataLink::GetAttributes() const noexcept
{
return attribute_map_.GetAttributes();
}
const opentelemetry::sdk::resource::Resource &SpanData::GetResource() const noexcept
{
if (resource_ == nullptr)
{
// this shouldn't happen as TraceProvider provides default resources
static opentelemetry::sdk::resource::Resource resource =
opentelemetry::sdk::resource::Resource::GetEmpty();
return resource;
}
return *resource_;
}
const opentelemetry::sdk::trace::InstrumentationScope &SpanData::GetInstrumentationScope()
const noexcept
{
if (instrumentation_scope_ == nullptr)
{
// this shouldn't happen as Tracer ensures there is valid default instrumentation scope.
static std::unique_ptr<opentelemetry::sdk::instrumentationscope::InstrumentationScope>
instrumentation_scope =
opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create(
"unknown_service");
return *instrumentation_scope;
}
return *instrumentation_scope_;
}
const std::unordered_map<std::string, opentelemetry::sdk::common::OwnedAttributeValue> &
SpanData::GetAttributes() const noexcept
{
return attribute_map_.GetAttributes();
}
void SpanData::SetIdentity(const opentelemetry::trace::SpanContext &span_context,
opentelemetry::trace::SpanId parent_span_id) noexcept
{
span_context_ = span_context;
parent_span_id_ = parent_span_id;
}
void SpanData::SetAttribute(nostd::string_view key,
const opentelemetry::common::AttributeValue &value) noexcept
{
attribute_map_.SetAttribute(key, value);
}
void SpanData::AddEvent(nostd::string_view name,
opentelemetry::common::SystemTimestamp timestamp,
const opentelemetry::common::KeyValueIterable &attributes) noexcept
{
SpanDataEvent event(std::string(name), timestamp, attributes);
events_.push_back(event);
}
void SpanData::AddLink(const opentelemetry::trace::SpanContext &span_context,
const opentelemetry::common::KeyValueIterable &attributes) noexcept
{
SpanDataLink link(span_context, attributes);
links_.push_back(link);
}
void SpanData::SetStatus(opentelemetry::trace::StatusCode code,
nostd::string_view description) noexcept
{
status_code_ = code;
status_desc_ = std::string(description);
}
void SpanData::SetName(nostd::string_view name) noexcept
{
name_ = std::string(name.data(), name.length());
}
void SpanData::SetTraceFlags(opentelemetry::trace::TraceFlags flags) noexcept
{
flags_ = flags;
}
void SpanData::SetSpanKind(opentelemetry::trace::SpanKind span_kind) noexcept
{
span_kind_ = span_kind;
}
void SpanData::SetResource(const opentelemetry::sdk::resource::Resource &resource) noexcept
{
resource_ = &resource;
}
void SpanData::SetStartTime(opentelemetry::common::SystemTimestamp start_time) noexcept
{
start_time_ = start_time;
}
void SpanData::SetDuration(std::chrono::nanoseconds duration) noexcept
{
duration_ = duration;
}
void SpanData::SetInstrumentationScope(const InstrumentationScope &instrumentation_scope) noexcept
{
instrumentation_scope_ = &instrumentation_scope;
}
} // namespace trace
} // namespace sdk
OPENTELEMETRY_END_NAMESPACE
|
