Add initial OpenCensus tracing support.

api/bazel/repositories.bzl

@@ -301,11 +301,26 @@ api_proto_library(
     visibility = ["//visibility:public"],
 )
 
+api_proto_library(
+    name = "trace_config",
+    srcs = [
+        "trace_config.proto",
+    ],
+    visibility = ["//visibility:public"],
+)
+
 go_proto_library(
     name = "trace_model_go_proto",
     importpath = "trace_model",
     proto = ":trace_model",
     visibility = ["//visibility:public"],
 )
+
+go_proto_library(
+    name = "trace_config_go_proto",
+    importpath = "trace_config",
+    proto = ":trace_config",
+    visibility = ["//visibility:public"],
+)
         """,
     )

api/envoy/config/trace/v2/BUILD

@@ -10,6 +10,7 @@ api_proto_library_internal(
     ],
     deps = [
         "//envoy/api/v2/core:grpc_service",
+        "@io_opencensus_trace//:trace_config",
     ],
 )
 
@@ -18,5 +19,6 @@ api_go_proto_library(
     proto = ":trace",
     deps = [
         "//envoy/api/v2/core:grpc_service_go_proto",
+        "@io_opencensus_trace//:trace_config_go_proto",
     ],
 )

api/envoy/config/trace/v2/trace.proto

@@ -7,6 +7,7 @@ package envoy.config.trace.v2;
 option go_package = "v2";
 
 import "envoy/api/v2/core/grpc_service.proto";
+import "trace_config.proto";
 
 import "google/protobuf/any.proto";
 import "google/protobuf/struct.proto";
@@ -29,6 +30,7 @@ message Tracing {
     // - *envoy.zipkin*
     // - *envoy.dynamic.ot*
     // - *envoy.tracers.datadog*
+    // - *envoy.tracers.opencensus*
     string name = 1 [(validate.rules).string.min_bytes = 1];
 
     // Trace driver specific configuration which depends on the driver being instantiated.
@@ -38,6 +40,7 @@ message Tracing {
     // - :ref:`ZipkinConfig <envoy_api_msg_config.trace.v2.ZipkinConfig>`
     // - :ref:`DynamicOtConfig <envoy_api_msg_config.trace.v2.DynamicOtConfig>`
     // - :ref:`DatadogConfig <envoy_api_msg_config.trace.v2.DatadogConfig>`
+    // - :ref:`OpenCensusConfig <envoy_api_msg_config.trace.v2.OpenCensusConfig>`
     oneof config_type {
       google.protobuf.Struct config = 2;
 
@@ -100,6 +103,43 @@ message DatadogConfig {
   string service_name = 2 [(validate.rules).string.min_bytes = 1];
 }
 
+// Configuration for the OpenCensus tracer.
+message OpenCensusConfig {
+  // Configures tracing, e.g. the sampler, max number of annotations, etc.
+  opencensus.proto.trace.v1.TraceConfig trace_config = 1;
+
+  // Enables the stdout exporter if set to true. This is intended for debugging
+  // purposes.
+  bool stdout_exporter_enabled = 2;
+
+  // Enables the Stackdriver exporter if set to true. The project_id must also
+  // be set.
+  bool stackdriver_exporter_enabled = 3;
+
+  // The Cloud project_id to use for Stackdriver tracing.
+  string stackdriver_project_id = 4;
+
+  // Enables the Zipkin exporter if set to true. The url and service name must
+  // also be set.
+  bool zipkin_exporter_enabled = 5;
+
+  // The URL to Zipkin, e.g. "http://127.0.0.1:9411/api/v2/spans"
+  string zipkin_url = 6;
+
+  // The Zipkin service name.
+  string zipkin_service_name = 7;
+
+  // Enables propagating trace context using the X-Cloud-Trace-Context header.
+  bool propagate_cloud_trace_context = 8;
+
+  // Enables propagating trace context using the traceparent header with the
+  // W3C Trace-Context format.
+  bool propagate_trace_context = 9;
+
+  // Enables propagating trace context using the binary grpc-trace-bin header.
+  bool propagate_grpc_trace_bin = 10;
+}
+
 // Configuration structure.
 message TraceServiceConfig {
   // The upstream gRPC cluster that hosts the metrics service.

bazel/external/curl.BUILD

@@ -0,0 +1,35 @@
+load("@io_opencensus_cpp//opencensus:curl.bzl", "CURL_COPTS")
+
+package(features = ["no_copts_tokenization"])
+
+config_setting(
+    name = "windows",
+    values = {"cpu": "x64_windows"},
+    visibility = ["//visibility:private"],
+)
+
+config_setting(
+    name = "osx",
+    values = {"cpu": "darwin"},
+    visibility = ["//visibility:private"],
+)
+
+cc_library(
+    name = "curl",
+    srcs = glob([
+        "lib/**/*.c",
+    ]),
+    hdrs = glob([
+        "include/curl/*.h",
+        "lib/**/*.h",
+    ]),
+    copts = CURL_COPTS + [
+        "-DOS=\"os\"",
+        "-DCURL_EXTERN_SYMBOL=__attribute__((__visibility__(\"default\")))",
+    ],
+    includes = [
+        "include/",
+        "lib/",
+    ],
+    visibility = ["//visibility:public"],
+)

bazel/external/rapidjson.BUILD

@@ -2,5 +2,6 @@ cc_library(
     name = "rapidjson",
     hdrs = glob(["include/rapidjson/**/*.h"]),
     includes = ["include"],
+    defines = ["RAPIDJSON_HAS_STDSTRING=1"],
     visibility = ["//visibility:public"],
 )

bazel/repositories.bzl

@@ -295,6 +295,8 @@ def envoy_dependencies(path = "@envoy_deps//", skip_targets = []):
     _com_github_tencent_rapidjson()
     _com_google_googletest()
     _com_google_protobuf()
+    _io_opencensus_cpp()
+    _com_github_curl()
 
     # Used for bundling gcovr into a relocatable .par file.
     _repository_impl("subpar")
@@ -527,6 +529,36 @@ def _com_google_protobuf():
         actual = "@com_google_protobuf//util/python:python_headers",
     )
 
+def _io_opencensus_cpp():
+    _repository_impl("io_opencensus_cpp")
+    native.bind(
+        name = "opencensus_trace",
+        actual = "@io_opencensus_cpp//opencensus/trace",
+    )
+    native.bind(
+        name = "opencensus_trace_cloud_trace_context",
+        actual = "@io_opencensus_cpp//opencensus/trace:cloud_trace_context",
+    )
+    native.bind(
+        name = "opencensus_exporter_stdout",
+        actual = "@io_opencensus_cpp//opencensus/exporters/trace/stdout:stdout_exporter",
+    )
+    native.bind(
+        name = "opencensus_exporter_stackdriver",
+        actual = "@io_opencensus_cpp//opencensus/exporters/trace/stackdriver:stackdriver_exporter",
+    )
+    native.bind(
+        name = "opencensus_exporter_zipkin",
+        actual = "@io_opencensus_cpp//opencensus/exporters/trace/zipkin:zipkin_exporter",
+    )
+
+def _com_github_curl():
+    # Curl library - used by OpenCensus Zipkin exporter.
+    _repository_impl(
+        "com_github_curl",
+        build_file = "@envoy//bazel/external:curl.BUILD",
+    )
+
 def _com_github_grpc_grpc():
     _repository_impl("com_github_grpc_grpc")
 

bazel/repository_locations.bzl

@@ -11,10 +11,10 @@ REPOSITORY_LOCATIONS = dict(
         urls = ["https://github.com/google/boringssl/archive/77e47de9e16ec8865d1bc6d614dd918141f094d2.tar.gz"],
     ),
     com_google_absl = dict(
-        sha256 = "e35082e88b9da04f4d68094c05ba112502a5063712f3021adfa465306d238c76",
-        strip_prefix = "abseil-cpp-cc8dcd307b76a575d2e3e0958a4fe4c7193c2f68",
+        sha256 = "3ad76de484192b2d5afd49d90492b5ed0bc59eb1a4e8e0deecc7a2a077a90251",
+        strip_prefix = "abseil-cpp-f197d7c72a54064cfde5a2058f1513a4a0ee36fb",
         # 2018-10-31
-        urls = ["https://github.com/abseil/abseil-cpp/archive/cc8dcd307b76a575d2e3e0958a4fe4c7193c2f68.tar.gz"],
+        urls = ["https://github.com/abseil/abseil-cpp/archive/f197d7c72a54064cfde5a2058f1513a4a0ee36fb.tar.gz"],
     ),
     com_github_apache_thrift = dict(
         sha256 = "7d59ac4fdcb2c58037ebd4a9da5f9a49e3e034bf75b3f26d9fe48ba3d8806e6b",
@@ -190,4 +190,14 @@ REPOSITORY_LOCATIONS = dict(
         strip_prefix = "subpar-1.3.0",
         urls = ["https://github.com/google/subpar/archive/1.3.0.tar.gz"],
     ),
+    io_opencensus_cpp = dict(
+        sha256 = "b967e22fd6be41e2e78bb2fee2d7027ed48cc6b9e0ce2620c2f3db3a8913ff9c",
+        strip_prefix = "opencensus-cpp-e9d986ebeb413acb4f8ec1bdff33485866a794b7",
+        urls = ["https://github.com/census-instrumentation/opencensus-cpp/archive/e9d986ebeb413acb4f8ec1bdff33485866a794b7.tar.gz"],
+    ),
+    com_github_curl = dict(
+        sha256 = "d483b89062832e211c887d7cf1b65c902d591b48c11fe7d174af781681580b41",
+        strip_prefix = "curl-7.63.0",
+        urls = ["https://github.com/curl/curl/releases/download/curl-7_63_0/curl-7.63.0.tar.gz"],
+    ),
 )

source/extensions/extensions_build_config.bzl

@@ -104,6 +104,7 @@ EXTENSIONS = {
     "envoy.tracers.lightstep":                          "//source/extensions/tracers/lightstep:config",
     "envoy.tracers.datadog":                            "//source/extensions/tracers/datadog:config",
     "envoy.tracers.zipkin":                             "//source/extensions/tracers/zipkin:config",
+    "envoy.tracers.opencensus":                         "//source/extensions/tracers/opencensus:config",
 
     #
     # Transport sockets

source/extensions/tracers/opencensus/BUILD

@@ -0,0 +1,39 @@
+licenses(["notice"])  # Apache 2
+
+# Trace driver for OpenCensus: https://opencensus.io/
+
+load(
+    "//bazel:envoy_build_system.bzl",
+    "envoy_cc_library",
+    "envoy_package",
+)
+
+envoy_package()
+
+envoy_cc_library(
+    name = "config",
+    srcs = ["config.cc"],
+    hdrs = ["config.h"],
+    deps = [
+        ":opencensus_tracer_impl",
+        "//source/extensions/tracers:well_known_names",
+        "//source/extensions/tracers/common:factory_base_lib",
+    ],
+)
+
+envoy_cc_library(
+    name = "opencensus_tracer_impl",
+    srcs = ["opencensus_tracer_impl.cc"],
+    hdrs = ["opencensus_tracer_impl.h"],
+    external_deps = [
+        "opencensus_trace",
+        "opencensus_trace_cloud_trace_context",
+        "opencensus_exporter_stdout",
+        "opencensus_exporter_stackdriver",
+        "opencensus_exporter_zipkin",
+    ],
+    deps = [
+        "//source/common/config:utility_lib",
+        "//source/common/tracing:http_tracer_lib",
+    ],
+)

source/extensions/tracers/opencensus/config.cc

@@ -0,0 +1,37 @@
+#include "extensions/tracers/opencensus/config.h"
+
+#include <iostream>
+
+#include "envoy/registry/registry.h"
+
+#include "common/tracing/http_tracer_impl.h"
+
+#include "extensions/tracers/opencensus/opencensus_tracer_impl.h"
+#include "extensions/tracers/well_known_names.h"
+
+namespace Envoy {
+namespace Extensions {
+namespace Tracers {
+namespace OpenCensus {
+
+OpenCensusTracerFactory::OpenCensusTracerFactory() : FactoryBase(TracerNames::get().OpenCensus) {
+  std::cerr << "OpenCensusTracerFactory()\n";
+}
+
+Tracing::HttpTracerPtr OpenCensusTracerFactory::createHttpTracerTyped(
+    const envoy::config::trace::v2::OpenCensusConfig& proto_config, Server::Instance& server) {
+  std::cerr << "OpenCensusTracerFactory::createHttpTracerTyped()\n";
+  Tracing::DriverPtr driver = std::make_unique<Driver>(proto_config);
+  return std::make_unique<Tracing::HttpTracerImpl>(std::move(driver), server.localInfo());
+}
+
+/**
+ * Static registration for the OpenCensus tracer. @see RegisterFactory.
+ */
+static Registry::RegisterFactory<OpenCensusTracerFactory, Server::Configuration::TracerFactory>
+    register_;
+
+} // namespace OpenCensus
+} // namespace Tracers
+} // namespace Extensions
+} // namespace Envoy

source/extensions/tracers/opencensus/config.h

@@ -0,0 +1,32 @@
+#pragma once
+
+#include <string>
+
+#include "envoy/config/trace/v2/trace.pb.validate.h"
+
+#include "extensions/tracers/common/factory_base.h"
+
+namespace Envoy {
+namespace Extensions {
+namespace Tracers {
+namespace OpenCensus {
+
+/**
+ * Config registration for the OpenCensus tracer. @see TracerFactory.
+ */
+class OpenCensusTracerFactory
+    : public Common::FactoryBase<envoy::config::trace::v2::OpenCensusConfig> {
+public:
+  OpenCensusTracerFactory();
+
+private:
+  // FactoryBase
+  Tracing::HttpTracerPtr
+  createHttpTracerTyped(const envoy::config::trace::v2::OpenCensusConfig& proto_config,
+                        Server::Instance& server) override;
+};
+
+} // namespace OpenCensus
+} // namespace Tracers
+} // namespace Extensions
+} // namespace Envoy