(ts time.Time, tenant string, req *tempopb.PushBytesRequest)
| 61 | } |
| 62 | |
| 63 | func (p *writer) pushBytes(ts time.Time, tenant string, req *tempopb.PushBytesRequest) error { |
| 64 | level.Debug(p.logger).Log( |
| 65 | "msg", "pushing bytes", |
| 66 | "tenant", tenant, |
| 67 | "num_traces", len(req.Traces), |
| 68 | "id", idsToString(req.Ids), |
| 69 | ) |
| 70 | |
| 71 | i, err := p.instanceForTenant(tenant) |
| 72 | if err != nil { |
| 73 | return err |
| 74 | } |
| 75 | |
| 76 | for j, trace := range req.Traces { |
| 77 | if err := i.AppendTrace(req.Ids[j], trace.Slice, ts); err != nil { |
| 78 | return err |
| 79 | } |
| 80 | } |
| 81 | |
| 82 | return nil |
| 83 | } |
| 84 | |
| 85 | func (p *writer) flush(ctx context.Context, r tempodb.Reader, w tempodb.Writer, c tempodb.Compactor) error { |
| 86 | // TODO - Retry with backoff? |
nothing calls this directly
no test coverage detected