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

Method Dequeue

src/blobcache/queues.go:100–100  ·  view source on GitHub ↗

Dequeue reads from the queue. It reads into buf until buf is full or another criteria is fulfilled.

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

Source from the content-addressed store, hash-verified

98 // Dequeue reads from the queue.
99 // It reads into buf until buf is full or another criteria is fulfilled.
100 Dequeue(ctx context.Context, q Handle, buf []Message, opts DequeueOpts) (int, error)
101 // Insert adds the messages to the end of the queue.
102 Enqueue(ctx context.Context, q Handle, msgs []Message) (*InsertResp, error)
103}

Callers 2

QueueAPIFunction · 0.65
TestVolumeSubscribeFunction · 0.65

Implementers 6

Clientsrc/bchttp/client.go
Servicesrc/blobcachecmd/service.go
Servicesrc/bclocal/bclocal.go
Systemsrc/bccore/bccore.go
Servicesrc/bcremote/bcremote.go
Clientsrc/bcipc/client.go

Calls

no outgoing calls

Tested by 1

TestVolumeSubscribeFunction · 0.52