(ctx context.Context, traces ptrace.Traces)
| 387 | } |
| 388 | |
| 389 | func (d *Distributor) extractBasicInfo(ctx context.Context, traces ptrace.Traces) (userID string, spanCount, tracesSize int, err error) { |
| 390 | orgID, e := validation.ExtractValidTenantID(ctx) |
| 391 | if e != nil { |
| 392 | return "", 0, 0, status.Error(codes.InvalidArgument, e.Error()) |
| 393 | } |
| 394 | |
| 395 | return orgID, traces.SpanCount(), (&ptrace.ProtoMarshaler{}).TracesSize(traces), nil |
| 396 | } |
| 397 | |
| 398 | // PushTraces pushes a batch of traces |
| 399 | func (d *Distributor) PushTraces(ctx context.Context, traces ptrace.Traces) (*tempopb.PushResponse, error) { |
no test coverage detected