Expose http option for OTLP

Fixes #647

Author: dandavison

temporalio/bridge/runtime.py

@@ -69,6 +69,7 @@ class OpenTelemetryConfig:
     metric_periodicity_millis: Optional[int]
     metric_temporality_delta: bool
     durations_as_seconds: bool
+    http: bool
 
 
 @dataclass(frozen=True)

temporalio/bridge/src/runtime.rs

@@ -17,7 +17,7 @@ use temporal_sdk_core::{CoreRuntime, TokioRuntimeBuilder};
 use temporal_sdk_core_api::telemetry::metrics::{CoreMeter, MetricCallBufferer};
 use temporal_sdk_core_api::telemetry::{
     CoreLog, Logger, MetricTemporality, OtelCollectorOptionsBuilder,
-    PrometheusExporterOptionsBuilder, TelemetryOptionsBuilder,
+    PrometheusExporterOptionsBuilder, TelemetryOptionsBuilder, OtlpProtocol
 };
 use tokio::task::JoinHandle;
 use tokio_stream::StreamExt;
@@ -74,6 +74,7 @@ pub struct OpenTelemetryConfig {
     metric_periodicity_millis: Option<u64>,
     metric_temporality_delta: bool,
     durations_as_seconds: bool,
+    http: bool,
 }
 
 #[derive(FromPyObject)]
@@ -322,6 +323,9 @@ impl TryFrom<MetricsConfig> for Arc<dyn CoreMeter> {
             if let Some(global_tags) = conf.global_tags {
                 build.global_tags(global_tags);
             }
+            if otel_conf.http {
+                build.protocol(OtlpProtocol::Http);
+            }
             let otel_options = build
                 .build()
                 .map_err(|err| PyValueError::new_err(format!("Invalid OTel config: {}", err)))?;

temporalio/runtime.py

@@ -259,17 +259,22 @@ class OpenTelemetryConfig:
         OpenTelemetryMetricTemporality.CUMULATIVE
     )
     durations_as_seconds: bool = False
+    http: bool = False
 
     def _to_bridge_config(self) -> temporalio.bridge.runtime.OpenTelemetryConfig:
         return temporalio.bridge.runtime.OpenTelemetryConfig(
             url=self.url,
             headers=self.headers or {},
-            metric_periodicity_millis=None
-            if not self.metric_periodicity
-            else round(self.metric_periodicity.total_seconds() * 1000),
-            metric_temporality_delta=self.metric_temporality
-            == OpenTelemetryMetricTemporality.DELTA,
+            metric_periodicity_millis=(
+                None
+                if not self.metric_periodicity
+                else round(self.metric_periodicity.total_seconds() * 1000)
+            ),
+            metric_temporality_delta=(
+                self.metric_temporality == OpenTelemetryMetricTemporality.DELTA
+            ),
             durations_as_seconds=self.durations_as_seconds,
+            http=self.http,
         )