@@ -24,7 +24,7 @@ import io.opentelemetry.sdk.metrics.`export`.MetricExporter
24
24
import io .opentelemetry .sdk .metrics .data .MetricData
25
25
import io .opentelemetry .sdk .trace .`export` .SpanExporter
26
26
import io .opentelemetry .sdk .trace .data .SpanData
27
- import kamon .otel .OpenTelemetryConfiguration .Component .Trace
27
+ import kamon .otel .OpenTelemetryConfiguration .Component .{ Metrics , Trace }
28
28
import org .slf4j .LoggerFactory
29
29
30
30
import java .io .Closeable
@@ -106,18 +106,18 @@ private[otel] object OtlpMetricsService {
106
106
* @param config
107
107
* @return
108
108
*/
109
- def apply (config : Config ): MetricsService = new OtlpMetricsService (OpenTelemetryConfiguration (config, Trace ))
109
+ def apply (config : Config ): MetricsService = new OtlpMetricsService (OpenTelemetryConfiguration (config, Metrics ))
110
110
}
111
111
112
112
private [otel] class OtlpMetricsService (c : OpenTelemetryConfiguration ) extends MetricsService {
113
113
private val compressionMethod = if (c.compressionEnabled) " gzip" else " none"
114
114
private val delegate : MetricExporter = c.protocol match {
115
115
case " grpc" =>
116
- val builder = OtlpHttpMetricExporter .builder().setEndpoint(c.endpoint).setCompression(compressionMethod).setTimeout(c.timeout)
116
+ val builder = OtlpGrpcMetricExporter .builder().setEndpoint(c.endpoint).setCompression(compressionMethod).setTimeout(c.timeout)
117
117
c.headers.foreach { case (k, v) => builder.addHeader(k, v) }
118
118
builder.build()
119
119
case " http/protobuf" =>
120
- val builder = OtlpGrpcMetricExporter .builder().setEndpoint(c.endpoint).setCompression(compressionMethod).setTimeout(c.timeout)
120
+ val builder = OtlpHttpMetricExporter .builder().setEndpoint(c.endpoint).setCompression(compressionMethod).setTimeout(c.timeout)
121
121
c.headers.foreach { case (k, v) => builder.addHeader(k, v) }
122
122
builder.build()
123
123
}
0 commit comments