opentelemetry-zipkin: Add Environment Variables

As described in https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/sdk-environment-variables.md
* Add support for:
** OTEL_EXPORTER_ZIPKIN_ENDPOINT
** OTEL_EXPORTER_ZIPKIN_TIMEOUT
* Update Default to use

Closes open-telemetry#534

Signed-off-by: Harold Dost <h.dost@criteo.com>

opentelemetry-zipkin/Cargo.toml

@@ -34,6 +34,7 @@ serde_json = "1.0"
 serde = { version = "1.0", features = ["derive"] }
 typed-builder = "0.9"
 lazy_static = "1.4"
+log = "0.4"
 http = "0.2"
 reqwest = { version = "0.11", optional = true, default-features = false }
 surf = { version = "2.0", optional = true, default-features = false }

opentelemetry-zipkin/src/exporter/env.rs

@@ -0,0 +1,74 @@
+use crate::ZipkinPipelineBuilder;
+use log::warn;
+use std::env;
+use std::time::Duration;
+
+/// HTTP endpoint for Zipkin collector.
+/// e.g. "http://localhost:9411/api/v2/spans"
+#[cfg(any(
+    feature = "reqwest-client",
+    feature = "surf-client",
+    feature = "reqwest-blocking-client"
+))]
+const ENV_ENDPOINT: &str = "OTEL_EXPORTER_ZIPKIN_ENDPOINT";
+
+/// Maximum time the Zipkin exporter will wait for each batch export
+#[cfg(any(
+    feature = "reqwest-client",
+    feature = "surf-client",
+    feature = "reqwest-blocking-client"
+))]
+const ENV_TIMEOUT: &str = "OTEL_EXPORTER_ZIPKIN_TIMEOUT";
+
+/// Assign builder attributes from env
+pub(crate) fn assign_attrs(mut builder: ZipkinPipelineBuilder) -> ZipkinPipelineBuilder {
+    #[cfg(any(
+        feature = "reqwest-client",
+        feature = "surf-client",
+        feature = "reqwest-blocking-client"
+    ))]
+    {
+        if let Some(endpoint) = env::var(ENV_ENDPOINT).ok().filter(|var| !var.is_empty()) {
+            builder = builder.with_collector_endpoint(endpoint);
+        }
+    }
+
+    #[cfg(any(
+        feature = "reqwest-client",
+        feature = "surf-client",
+        feature = "reqwest-blocking-client"
+    ))]
+    {
+        if let Some(timeout) = env::var(ENV_TIMEOUT).ok().filter(|var| !var.is_empty()) {
+            let timeout = match timeout.parse() {
+                Ok(timeout) => Duration::from_millis(timeout),
+                Err(e) => {
+                    warn!("{} malformed defaulting to 10000: {}", ENV_TIMEOUT, e);
+                    Duration::from_millis(10_000)
+                }
+            };
+
+            #[cfg(feature = "reqwest-blocking-client")]
+            let client = reqwest::blocking::Client::builder()
+                .timeout(timeout)
+                .build()
+                .unwrap();
+            #[cfg(all(
+                not(feature = "reqwest-blocking-client"),
+                not(feature = "surf-client"),
+                feature = "reqwest-client"
+            ))]
+            let client = reqwest::Client::builder().timeout(timeout).build().unwrap();
+            #[cfg(all(
+                not(feature = "reqwest-client"),
+                not(feature = "reqwest-blocking-client"),
+                feature = "surf-client"
+            ))]
+            let client: surf::Client = surf::Config::new().set_timeout(Some(timeout)).into();
+
+            builder = builder.with_http_client(client);
+        }
+    }
+
+    builder
+}

opentelemetry-zipkin/src/exporter/mod.rs

@@ -1,3 +1,4 @@
+mod env;
 mod model;
 mod uploader;
 
@@ -57,7 +58,7 @@ pub struct ZipkinPipelineBuilder {
 
 impl Default for ZipkinPipelineBuilder {
     fn default() -> Self {
-        ZipkinPipelineBuilder {
+        let builder_defaults = ZipkinPipelineBuilder {
             #[cfg(feature = "reqwest-blocking-client")]
             client: Some(Box::new(reqwest::blocking::Client::new())),
             #[cfg(all(
@@ -83,7 +84,10 @@ impl Default for ZipkinPipelineBuilder {
             service_addr: None,
             collector_endpoint: DEFAULT_COLLECTOR_ENDPOINT.to_string(),
             trace_config: None,
-        }
+        };
+
+        // Override above defaults with env vars if set
+        env::assign_attrs(builder_defaults)
     }
 }