Add Jaeger exporter

.gitmodules

@@ -32,3 +32,6 @@
 	path = third_party/nlohmann-json
 	url = https://github.com/nlohmann/json
 	branch = master
+[submodule "third_party/jaeger-idl"]
+	path = third_party/jaeger-idl
+	url = https://github.com/jaegertracing/jaeger-idl

CMakeLists.txt

@@ -81,6 +81,8 @@ option(WITH_PROMETHEUS "Whether to include the Prometheus Client in the SDK"
 option(WITH_ELASTICSEARCH
        "Whether to include the Elasticsearch Client in the SDK" OFF)
 
+option(WITH_JAEGER "Whether to include the Jaeger exporter" OFF)
+
 option(BUILD_TESTING "Whether to enable tests" ON)
 if(WIN32)
   option(WITH_ETW "Whether to include the ETW Exporter in the SDK" ON)

exporters/CMakeLists.txt

@@ -16,3 +16,7 @@ endif()
 if(WITH_ETW)
   add_subdirectory(etw)
 endif()
+
+if(WITH_JAEGER)
+  add_subdirectory(jaeger)
+endif()

exporters/jaeger/CMakeLists.txt

@@ -0,0 +1,35 @@
+# Copyright 2020, OpenTelemetry Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+include_directories(include)
+
+find_package(Boost REQUIRED)
+find_package(thrift REQUIRED)
+
+set(JAEGER_THRIFT_GENCPP_SOURCES
+    thrift-gen/Agent.cpp
+    thrift-gen/jaeger_types.cpp
+    thrift-gen/Collector.cpp
+)
+
+add_library(jaeger_trace_exporter ${JAEGER_THRIFT_GENCPP_SOURCES})
+target_link_libraries(jaeger_trace_exporter PRIVATE thrift::thrift Boost::boost)
+
+if(BUILD_TESTING)
+    #  add_executable(jaeger_exporter_test )
+    #  target_link_libraries(jaeger_exporter_test ${GTEST_BOTH_LIBRARIES})
+    #                        ${CMAKE_THREAD_LIBS_INIT} jaeger_trace_exporter)
+    #
+    #  gtest_add_tests()
+endif() # BUILD_TESTING

exporters/jaeger/include/opentelemetry/exporters/jaeger/jaeger_exporter.h

@@ -0,0 +1,80 @@
+// Copyright 2020, OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#pragma once
+
+#include <opentelemetry/sdk/trace/exporter.h>
+#include <memory>
+
+OPENTELEMETRY_BEGIN_NANESPACE
+namespace exporter
+{
+namespace jaeger
+{
+enum class TransportType
+{
+  THRIFT_UDP,
+};
+
+/**
+ * Struct to hold Jaeger exporter options.
+ */
+struct JaegerExporterOptions
+{
+  // The endpoint to export to.
+  std::string server_addr      = "localhost";
+  uint16_t server_port         = 9090;
+  TransportType transport_type = THRIFT_UDP;
+};
+
+namespace trace_sdk = opentelemetry::sdk::trace;
+
+class JaegerExporter final : public trace_sdk::SpanExporter
+{
+public:
+  /**
+   * Create a JaegerExporter using all default options.
+   */
+  JaegerExporter();
+
+  /**
+   * Export a batch of spans.
+   * @param spans a span of unique pointers to span recordables.
+   */
+  trace_sdk::ExportResult Export(
+      const nostd::span<std::unique_ptr<trace_sdk::Recordable>> &spans) noexcept override;
+
+  /**
+   * Shutdown the exporter.
+   * @param timeout an option timeout, default to max.
+   */
+  bool Shutdown(
+      std::chrono::microseconds timeout = std::chrono::microseconds::max() noexcept override;)
+  {
+    return true;
+  }
+
+private:
+  void InitializeEndpoint();
+
+private:
+  // The configuration options associated with this exporter.
+  bool is_shutdown_ = false;
+  JaegerExporterOptions options_;
+  std::unique_ptr<ThriftSender> sender_;
+};
+
+}  // namespace jaeger
+}  // namespace exporter
+OPENTELEMETRY_END_NAMESPACE

exporters/jaeger/include/opentelemetry/exporters/jaeger/recordable.h

@@ -0,0 +1,58 @@
+// Copyright 2020, OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#pragma once
+
+#include <opentelemetry/sdk/trace/recordable.h>
+#include <opentelemetry/version.h>
+#include <thrift-gen/cpp/jaeger_types.h>
+
+OPENTELEMETRY_BEGIN_NANESPACE
+namespace exporter
+{
+namespace jaeger
+{
+class Recordable final : public sdk::trace::Recordable
+{
+public:
+  const thrift::Span &span() const noexcept { return span_; }
+
+  voiid SetIds(trace::TraceId trace_id,
+               trace::SpanId span_id,
+               trace::SpanId parent_span_id) noexcept override;
+
+  void SetAttribute(nostd::string_view key,
+                    const opentelemetry::common::AttributeValue &value) noexcept override;
+
+  void AddEvent(nostd::string_view key,
+                core::SystemTimestamp timestamp,
+                const common::KeyValueIterable &attributes) noexcept override;
+
+  void AddLink(const opentelemetry::trace::SpanContext &span_context const common::KeyValueIterable
+                   &attributes) noexcept override;
+
+  void SetStatus(trace::CanonicalCode code, nostd::string_view description) noexcept override;
+
+  void SetName(nostd::string_view name) noexcept override;
+
+  void SetStartTime(opentelemetry::core::SystemTimestamp start_time) noexcept override;
+
+  void SetSpanKind(opentelemtry::trace::SpanKind span_kind) noexcept override;
+
+private:
+  thrift::Span span_;
+};
+}  // namespace jaeger
+}  // namespace exporter
+OPENTELEMETRY_END_NAMESPACE

exporters/jaeger/include/opentelemetry/exporters/jaeger/thrift_sender.h

@@ -0,0 +1,41 @@
+// Copyright 2020, OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#pragma once
+
+#include <thrift-gen/cpp/agent.h>
+#include <vector>
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace exporter
+{
+namespace jaeger
+{
+
+class ThriftSender
+{
+public:
+  ThriftSender();
+  ~ThriftSender();
+
+  int Append(std::shared_ptr<thrift::Span> span);
+  int Flush();
+
+private:
+  std::vector<thrift::Span> _spanBuffer;
+};
+
+}  // namespace jaeger
+}  // namespace exporter
+OPENTELEMETRY_END_NAMESPACE

exporters/jaeger/include/opentelemetry/exporters/jaeger/transport.h

@@ -0,0 +1,36 @@
+// Copyright 2020, OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#pragma once
+
+#include <thrift-gen/cpp/jaeger_types.h>
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace exporter
+{
+namespace jaeger
+{
+
+class Transport
+{
+public:
+  Transport()          = default;
+  virtual ~Transport() = default;
+
+  virtual void EmitBatch(const thrift::Batch &batch) = 0;
+};
+
+}  // namespace jaeger
+}  // namespace exporter
+OPENTELEMETRY_END_NAMESPACE

exporters/jaeger/include/opentelemetry/exporters/jaeger/udp_transport.h

@@ -0,0 +1,48 @@
+
+// Copyright 2020, OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#pragma once
+
+#include "transport.h"
+
+#include <thrift-gen/cpp/agent.h>
+#include <thrift/transport/TSocket.h>
+#include <memory>
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace exporter
+{
+namespace jaeger
+{
+
+namespace AgentClient = jagertracing::agent::thrift::AgentClient;
+
+class UDPTransport : public Transport
+{
+  pubilc : UDPTransport(const std::string &addr, uint16_t port);
+  ~UDPTransport();
+
+  void EmitBatch(const thrift::Batch &batch) override;
+
+private:
+  std::unique_ptr<AgentClient> agent_;
+  std::shared_ptr<TTransport> socket_;
+  std::shared_ptr<TTransport> transport_;
+  std::shared_ptr<TTransport> protocol_;
+};
+
+}  // namespace jaeger
+}  // namespace exporter
+OPENTELEMETRY_END_NAMESPACE

exporters/jaeger/src/jaeger_exporter.cc

@@ -0,0 +1,71 @@
+// Copyright 2020, OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include <opentelemetry/exporters/jaeger/jaeger_exporter.h>
+#include <opentelemetry/exporters/jaeger/recordable.h>
+#include <thrift-gen/cpp/agent_types.h>
+
+#include <vector>
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace exporter
+{
+namespace jaeger
+{
+
+JaegerExporter::JaegerExporter(const JaegerExporterOptions &options) : options_(options)
+{
+  InitializeEndpoint();
+}
+
+JaegerExporter::JaegerExporter() : JaegerExporter(JaegerExporterOptions()) {}
+
+std::unique_ptr<std::trace::Recordable> JaegerExporter::MakeRecordable() noexcept
+{
+  return std::unique_ptr<sdk::trace::Recordable>(new (nothrow) Recordable);
+}
+
+std::trace::ExportResult JaegerExporter::Export(
+    const nostd::span<std::unique_ptr<std::trace::Recordable>> &spans) noexcept
+{
+  if (is_shutdown_)
+  {
+    return sdk::trace::ExportResult::kFailuer;
+  }
+  std::vector<thrift::Span> spans{spans};
+
+  thrift::Batch batch;
+  // batch.__set_process(_process);
+  batch.__set_spans(_spanBuffer);
+
+  sender_.EmitBatch(batch);
+
+  return sdk::trace::ExportResult::kSuccess;
+}
+
+void JaegerExporter::InitializeEndpoint()
+{
+  if (options.transport_type == THRIFT_UDP)
+  {
+    sender_ =
+        std::unique_ptr<ThriftSender>(new ThriftSender(options.server_addr, options.server_port));
+  }
+  else
+  {
+    static_assert(false, "Unsupported transport type");
+  }
+}
+
+}  // namespace jaeger
+}  // namespace exporter