Method ConsumeTraces

integration/util/harness_api_writes.go:244–257

ConsumeTraces converts OTLP traces to Jaeger format and sends them via gRPC

(ctx context.Context, traces ptrace.Traces)

// ConsumeTraces converts OTLP traces to Jaeger format and sends them via gRPC
func (e *JaegerGRPCExporter) ConsumeTraces(ctx context.Context, traces ptrace.Traces) error {
	batches := jaeger.ProtoFromTraces(traces)

	for _, batch := range batches {
		_, err := e.collector.PostSpans(ctx, &api_v2.PostSpansRequest{
			Batch: *batch,
		})
		if err != nil {
			return err
		}
	}

	return nil
}

// Capabilities implements consumer.Traces
func (e *JaegerGRPCExporter) Capabilities() consumer.Capabilities {