Home
last modified time | relevance | path

Searched refs:ReceiveBlob (Results 1 – 25 of 53) sorted by relevance

123

/dports/misc/perkeep/perkeep-0.11/pkg/test/
H A Dfetcher.go73 func (tf *Fetcher) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, … func
74 sb, err := tf.Storage.ReceiveBlob(ctx, br, source)
86 _, err := tf.ReceiveBlob(context.Background(), b.BlobRef(), b.Reader())
H A Dblob.go98 sb, err := ds.ReceiveBlob(context.Background(), tb.BlobRef(), tb.Reader())
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/shard/
H A Dshard_test.go67 ts.sto.ReceiveBlob(ctxbg, thingA.BlobRef(), thingA.Reader())
68 ts.sto.ReceiveBlob(ctxbg, thingB.BlobRef(), thingB.Reader())
H A Dshard.go83 func (sto *shardStorage) ReceiveBlob(ctx context.Context, b blob.Ref, source io.Reader) (sb blob.Si… func
84 return sto.shard(b).ReceiveBlob(ctx, b, source)
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/proxycache/
H A Dproxycache.go252 func (sto *Storage) ReceiveBlob(ctx context.Context, br blob.Ref, src io.Reader) (blob.SizedRef, er… func
259 sb, err := sto.origin.ReceiveBlob(ctx, br, bytes.NewReader(buf.Bytes()))
264 if _, err := sto.cache.ReceiveBlob(ctx, br, bytes.NewReader(buf.Bytes())); err != nil {
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/namespace/
H A Dns.go125 func (ns *nsto) ReceiveBlob(ctx context.Context, br blob.Ref, src io.Reader) (sb blob.SizedRef, err… func
137 sb, err = ns.master.ReceiveBlob(ctx, br, &buf)
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/overlay/
H A Doverlay_test.go84 sb, err := lower.ReceiveBlob(ctxbg, tb.BlobRef(), tb.Reader())
102 sb, err := sto.ReceiveBlob(ctxbg, tb.BlobRef(), tb.Reader())
H A Doverlay.go120 func (sto *overlayStorage) ReceiveBlob(ctx context.Context, br blob.Ref, src io.Reader) (sb blob.Si… func
121 sb, err = sto.upper.ReceiveBlob(ctx, br, src)
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/google/drive/
H A Dreceive.go26 func (sto *driveStorage) ReceiveBlob(ctx context.Context, b blob.Ref, source io.Reader) (blob.Sized… func
/dports/misc/perkeep/perkeep-0.11/cmd/pk-put/
H A Ddiscard.go32 func (discardStorage) ReceiveBlob(ctx context.Context, br blob.Ref, r io.Reader) (sb blob.SizedRef,… func
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/mongo/
H A Dreceive.go35 func (m *mongoStorage) ReceiveBlob(ctx context.Context, ref blob.Ref, source io.Reader) (blob.Sized… func
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/azure/
H A Dreceive.go29 func (sto *azureStorage) ReceiveBlob(ctx context.Context, b blob.Ref, source io.Reader) (sr blob.Si… func
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/
H A Dnoimpl.go38 func (NoImplStorage) ReceiveBlob(context.Context, blob.Ref, io.Reader) (sb blob.SizedRef, err error… func
H A Dinterface.go55 ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error) methodSpec
H A Dreceive.go60 sb, err = dst.ReceiveBlob(ctx, br, src)
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/s3/
H A Dreceive.go29 func (sto *s3Storage) ReceiveBlob(ctx context.Context, b blob.Ref, source io.Reader) (sr blob.Sized… func
/dports/misc/perkeep/perkeep-0.11/cmd/pk/
H A Dpackblobs.go104 _, err = cl.ReceiveBlob(ctxbg, fileRef, &buf)
/dports/lang/spidermonkey60/firefox-60.9.0/dom/base/
H A DImageEncoder.h118 virtual nsresult ReceiveBlob(already_AddRefed<Blob> aBlob) = 0;
/dports/www/firefox-legacy/firefox-52.8.0esr/dom/base/
H A DImageEncoder.h129 virtual nsresult ReceiveBlob(already_AddRefed<Blob> aBlob) = 0;
/dports/misc/perkeep/perkeep-0.11/pkg/client/android/
H A Dandroidx.go315 func (asr StatusReceiver) ReceiveBlob(ctx context.Context, blob blob.Ref, source io.Reader) (blob.S… func
320 sb, err := asr.Sr.ReceiveBlob(ctx, blob, io.TeeReader(source, writeUntilSliceFull{&contents}))
/dports/misc/perkeep/perkeep-0.11/pkg/index/
H A Dindex_test.go373 if _, err := ix.ReceiveBlob(ctxbg, b.BlobRef(), b.Reader()); err != nil {
501 _, err = dst.ReceiveBlob(ctxbg, br, rc)
521 if _, err := ix.ReceiveBlob(ctxbg, b.BlobRef(), b.Reader()); err != nil {
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/files/
H A Dreceive.go42 func (ds *Storage) ReceiveBlob(ctx context.Context, blobRef blob.Ref, source io.Reader) (blob.Sized… func
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/stats/
H A Dstatreceiver.go70 func (sr *Receiver) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (sb blob.SizedR… func
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/remote/
H A Dremote.go117 func (sto *remoteStorage) ReceiveBlob(ctx context.Context, blob blob.Ref, source io.Reader) (outsb … func
/dports/lang/spidermonkey60/firefox-60.9.0/dom/media/imagecapture/
H A DCaptureTask.cpp107 nsresult ReceiveBlob(already_AddRefed<dom::Blob> aBlob) override { in SetCurrentFrames() function in mozilla::CaptureTask::SetCurrentFrames::EncodeComplete

123