Interface QueueAPI

src/blobcache/queues.go:95–103

)

type QueueAPI interface {
	// InspectQueue returns information about a queue.
	InspectQueue(ctx context.Context, qh Handle) (QueueInfo, error)
	// Dequeue reads from the queue.
	// It reads into buf until buf is full or another criteria is fulfilled.
	Dequeue(ctx context.Context, q Handle, buf []Message, opts DequeueOpts) (int, error)
	// Insert adds the messages to the end of the queue.
	Enqueue(ctx context.Context, q Handle, msgs []Message) (*InsertResp, error)
}

type SubcriptionAPI interface {
	// SubToVolume causes all changes to a Volume's cell to be