(ctx context.Context, id, base ID)
| 68 | } |
| 69 | |
| 70 | func (q *Queue) writeTail(ctx context.Context, id, base ID) error { |
| 71 | r := strings.NewReader(fmt.Sprintf("%d %d", id, base)) |
| 72 | return storage.Put(ctx, q.engine, q.tailPath, r) |
| 73 | } |
| 74 | |
| 75 | // MoveTail moves the tail of the journal to the indicated ID and does |
| 76 | // no validation. Use with caution. This update must be made by an |