MCPcopy Create free account
hub / github.com/blobcache/blobcache / Dequeue

Method Dequeue

src/bccore/backend.go:60–60  ·  view source on GitHub ↗

Dequeue removes messages from the Queue.

(ctx context.Context, buf []blobcache.Message, opts blobcache.DequeueOpts)

Source from the content-addressed store, hash-verified

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.

Callers 7

handleQueueMethod · 0.65
DequeueMethod · 0.65
DequeueMethod · 0.65
ServeBCPMethod · 0.65
DequeueMethod · 0.65
DequeueMethod · 0.65
loopMethod · 0.65

Implementers 2

Queuesrc/internal/backend/memory/queue.go
Queuesrc/internal/backend/remotebe/queue.go

Calls

no outgoing calls

Tested by

no test coverage detected