Dequeue removes messages from the Queue.
(ctx context.Context, buf []blobcache.Message, opts blobcache.DequeueOpts)
| 58 | Enqueue(ctx context.Context, msgs []blobcache.Message) (int, error) |
| 59 | // Dequeue removes messages from the Queue. |
| 60 | Dequeue(ctx context.Context, buf []blobcache.Message, opts blobcache.DequeueOpts) (int, error) |
| 61 | // Down is called when the queue has no remaining handles |
| 62 | Down(ctx context.Context) error |
| 63 | // Config returns the QueueConfig for this queue. |