NewReader returns a BSUP reader that concatenates the journal files in sequence from tail to head. Since BSUP is stored in the journal, concatenation produce valid BSUP.
(ctx context.Context, head, tail ID)
| 138 | // in sequence from tail to head. Since BSUP is stored in the journal, |
| 139 | // concatenation produce valid BSUP. |
| 140 | func (q *Queue) NewReader(ctx context.Context, head, tail ID) *Reader { |
| 141 | return newReader(ctx, q, head, tail) |
| 142 | } |
| 143 | |
| 144 | func (q *Queue) uri(id ID) *storage.URI { |
| 145 | return q.path.JoinPath(fmt.Sprintf("%d.%s", id, ext)) |