EmitBatch converts a Jaeger Thrift batch to OpenTelemetry traces formats and forwards them to the configured OTLP endpoint.
(ctx context.Context, b *thrift.Batch)
| 204 | // EmitBatch converts a Jaeger Thrift batch to OpenTelemetry traces formats |
| 205 | // and forwards them to the configured OTLP endpoint. |
| 206 | func (c *JaegerToOTLPExporter) EmitBatch(ctx context.Context, b *thrift.Batch) error { |
| 207 | traces, err := jaeger.ThriftToTraces(b) |
| 208 | if err != nil { |
| 209 | return err |
| 210 | } |
| 211 | return c.exporter.ConsumeTraces(ctx, traces) |
| 212 | } |
| 213 | |
| 214 | // JaegerGRPCExporter wraps a gRPC client that sends traces to the Jaeger gRPC receiver (port 14250) |
| 215 | type JaegerGRPCExporter struct { |
nothing calls this directly
no test coverage detected