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
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
#include "opentelemetry/sdk/trace/tracer_provider.h"
#include "opentelemetry/sdk/resource/resource.h"
#include "opentelemetry/sdk/trace/samplers/always_off.h"
#include "opentelemetry/sdk/trace/samplers/always_on.h"
#include "opentelemetry/sdk/trace/simple_processor.h"
#include "opentelemetry/sdk/trace/tracer.h"
#include <gtest/gtest.h>
using namespace opentelemetry::sdk::trace;
using namespace opentelemetry::sdk::resource;
#include <iostream>
TEST(TracerProvider, GetTracer)
{
std::unique_ptr<SpanProcessor> processor(new SimpleSpanProcessor(nullptr));
std::vector<std::unique_ptr<SpanProcessor>> processors;
processors.push_back(std::move(processor));
TracerProvider tp1(std::make_shared<TracerContext>(std::move(processors), Resource::Create({})));
auto t1 = tp1.GetTracer("test");
auto t2 = tp1.GetTracer("test");
auto t3 = tp1.GetTracer("different", "1.0.0");
auto t4 = tp1.GetTracer("");
auto t5 = tp1.GetTracer(opentelemetry::nostd::string_view{});
auto t6 = tp1.GetTracer("different", "1.0.0", "https://opentelemetry.io/schemas/1.2.0");
ASSERT_NE(nullptr, t1);
ASSERT_NE(nullptr, t2);
ASSERT_NE(nullptr, t3);
ASSERT_NE(nullptr, t6);
// Should return the same instance each time.
ASSERT_EQ(t1, t2);
ASSERT_NE(t1, t3);
ASSERT_EQ(t4, t5);
ASSERT_NE(t3, t6);
// Should be an sdk::trace::Tracer with the processor attached.
#ifdef OPENTELEMETRY_RTTI_ENABLED
auto sdkTracer1 = dynamic_cast<Tracer *>(t1.get());
#else
auto sdkTracer1 = static_cast<Tracer *>(t1.get());
#endif
ASSERT_NE(nullptr, sdkTracer1);
ASSERT_EQ("AlwaysOnSampler", sdkTracer1->GetSampler().GetDescription());
std::unique_ptr<SpanProcessor> processor2(new SimpleSpanProcessor(nullptr));
std::vector<std::unique_ptr<SpanProcessor>> processors2;
processors2.push_back(std::move(processor2));
TracerProvider tp2(
std::make_shared<TracerContext>(std::move(processors2), Resource::Create({}),
std::unique_ptr<Sampler>(new AlwaysOffSampler()),
std::unique_ptr<IdGenerator>(new RandomIdGenerator)));
#ifdef OPENTELEMETRY_RTTI_ENABLED
auto sdkTracer2 = dynamic_cast<Tracer *>(tp2.GetTracer("test").get());
#else
auto sdkTracer2 = static_cast<Tracer *>(tp2.GetTracer("test").get());
#endif
ASSERT_EQ("AlwaysOffSampler", sdkTracer2->GetSampler().GetDescription());
auto instrumentation_library1 = sdkTracer1->GetInstrumentationLibrary();
ASSERT_EQ(instrumentation_library1.GetName(), "test");
ASSERT_EQ(instrumentation_library1.GetVersion(), "");
// Should be an sdk::trace::Tracer with the processor attached.
#ifdef OPENTELEMETRY_RTTI_ENABLED
auto sdkTracer3 = dynamic_cast<Tracer *>(t3.get());
#else
auto sdkTracer3 = static_cast<Tracer *>(t3.get());
#endif
auto instrumentation_library3 = sdkTracer3->GetInstrumentationLibrary();
ASSERT_EQ(instrumentation_library3.GetName(), "different");
ASSERT_EQ(instrumentation_library3.GetVersion(), "1.0.0");
}
TEST(TracerProvider, Shutdown)
{
std::unique_ptr<SpanProcessor> processor(new SimpleSpanProcessor(nullptr));
std::vector<std::unique_ptr<SpanProcessor>> processors;
processors.push_back(std::move(processor));
TracerProvider tp1(std::make_shared<TracerContext>(std::move(processors)));
EXPECT_TRUE(tp1.Shutdown());
// It's safe to shutdown again
EXPECT_TRUE(tp1.Shutdown());
}
TEST(TracerProvider, ForceFlush)
{
std::unique_ptr<SpanProcessor> processor1(new SimpleSpanProcessor(nullptr));
TracerProvider tp1(std::move(processor1));
EXPECT_TRUE(tp1.ForceFlush());
}
|
