Method Enqueue

src/blobcache/queues.go:102–102

Insert adds the messages to the end of the queue.

(ctx context.Context, q Handle, msgs []Message)

	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 {