(ctx context.Context, name string)
| 634 | } |
| 635 | |
| 636 | func (rw *readerWriter) readAll(ctx context.Context, name string) ([]byte, error) { |
| 637 | options := getObjectOptions(rw) |
| 638 | reader, info, _, err := rw.hedgedCore.GetObject(ctx, rw.cfg.Bucket, name, options) |
| 639 | if err != nil { |
| 640 | // do not change or wrap this error |
| 641 | // we need to compare the specific err message |
| 642 | return nil, err |
| 643 | } |
| 644 | defer reader.Close() |
| 645 | |
| 646 | return tempo_io.ReadAllWithEstimate(reader, info.Size) |
| 647 | } |
| 648 | |
| 649 | func (rw *readerWriter) readAllWithObjInfo(ctx context.Context, name string) ([]byte, minio.ObjectInfo, error) { |
| 650 | options := getObjectOptions(rw) |
no test coverage detected