(ctx context.Context)
| 64 | } |
| 65 | |
| 66 | func (q *Queue) ReadTail(ctx context.Context) (ID, ID, error) { |
| 67 | return readID(ctx, q.engine, q.tailPath) |
| 68 | } |
| 69 | |
| 70 | func (q *Queue) writeTail(ctx context.Context, id, base ID) error { |
| 71 | r := strings.NewReader(fmt.Sprintf("%d %d", id, base)) |