Method Enqueue

src/bccore/backend.go:58–58

Enqueue adds messages to the Queue. It returns the number of messages accepted.

(ctx context.Context, msgs []blobcache.Message)

	// Enqueue adds messages to the Queue.
	// It returns the number of messages accepted.
	Enqueue(ctx context.Context, msgs []blobcache.Message) (int, error)
	// Dequeue removes messages from the Queue.
	Dequeue(ctx context.Context, buf []blobcache.Message, opts blobcache.DequeueOpts) (int, error)
	// Down is called when the queue has no remaining handles