(ctx context.Context, name string)
| 475 | } |
| 476 | |
| 477 | func (rw *readerWriter) readAll(ctx context.Context, name string) ([]byte, *storage.ReaderObjectAttrs, error) { |
| 478 | r, err := rw.hedgedBucket.Object(name).NewReader(ctx) |
| 479 | if err != nil { |
| 480 | return nil, nil, err |
| 481 | } |
| 482 | defer r.Close() |
| 483 | |
| 484 | buf, err := tempo_io.ReadAllWithEstimate(r, r.Attrs.Size) |
| 485 | if err != nil { |
| 486 | return nil, nil, err |
| 487 | } |
| 488 | |
| 489 | return buf, &r.Attrs, nil |
| 490 | } |
| 491 | |
| 492 | func (rw *readerWriter) readRange(ctx context.Context, name string, offset int64, buffer []byte) error { |
| 493 | r, err := rw.hedgedBucket.Object(name).NewRangeReader(ctx, offset, int64(len(buffer))) |
no test coverage detected