| 83 | } |
| 84 | |
| 85 | func (h *TempoHarness) WriteTraceInfo(traceInfo *util.TraceInfo, tenant string) error { |
| 86 | endpoint := h.Services[ServiceDistributor].Endpoint(4317) |
| 87 | exporter, err := NewJaegerToOTLPExporterWithAuth(endpoint, tenant, "", false) |
| 88 | if err != nil { |
| 89 | return err |
| 90 | } |
| 91 | if err := traceInfo.EmitAllBatches(exporter); err != nil { |
| 92 | return err |
| 93 | } |
| 94 | h.recordWrite() |
| 95 | return nil |
| 96 | } |
| 97 | |
| 98 | func (h *TempoHarness) WriteJaegerBatch(batch *thrift.Batch, tenant string) error { |
| 99 | endpoint := h.Services[ServiceDistributor].Endpoint(4317) |