Method Dequeue

src/bclocal/bclocal.go:365–367 · view source on GitHub ↗

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

Source from the content-addressed store, hash-verified

363	}
364
365	func (s *Service) Dequeue(ctx context.Context, qh blobcache.Handle, buf []blobcache.Message, opts blobcache.DequeueOpts) (int, error) {
366	return s.sys.Dequeue(ctx, qh, buf, opts)
367	}
368
369	func (s Service) Enqueue(ctx context.Context, qh blobcache.Handle, msgs []blobcache.Message) (blobcache.InsertResp, error) {
370	return s.sys.Enqueue(ctx, qh, msgs)

nothing calls this directly

Clientsrc/bchttp/client.go

Servicesrc/blobcachecmd/service.go

Servicesrc/bclocal/bclocal.go

Servicesrc/bcremote/bcremote.go

Clientsrc/bcipc/client.go

lib.rsclient/rs/src/lib.rs

http.rsclient/rs/src/http.rs

unix.rsclient/rs/src/unix.rs

DequeueMethod · 0.65

no test coverage detected