/dports/misc/perkeep/perkeep-0.11/pkg/test/ |
H A D | fetcher.go | 73 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 D | blob.go | 98 sb, err := ds.ReceiveBlob(context.Background(), tb.BlobRef(), tb.Reader())
|
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/shard/ |
H A D | shard_test.go | 67 ts.sto.ReceiveBlob(ctxbg, thingA.BlobRef(), thingA.Reader()) 68 ts.sto.ReceiveBlob(ctxbg, thingB.BlobRef(), thingB.Reader())
|
H A D | shard.go | 83 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 D | proxycache.go | 252 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 D | ns.go | 125 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 D | overlay_test.go | 84 sb, err := lower.ReceiveBlob(ctxbg, tb.BlobRef(), tb.Reader()) 102 sb, err := sto.ReceiveBlob(ctxbg, tb.BlobRef(), tb.Reader())
|
H A D | overlay.go | 120 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 D | receive.go | 26 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 D | discard.go | 32 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 D | receive.go | 35 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 D | receive.go | 29 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 D | noimpl.go | 38 func (NoImplStorage) ReceiveBlob(context.Context, blob.Ref, io.Reader) (sb blob.SizedRef, err error… func
|
H A D | interface.go | 55 ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error) methodSpec
|
H A D | receive.go | 60 sb, err = dst.ReceiveBlob(ctx, br, src)
|
/dports/misc/perkeep/perkeep-0.11/pkg/blobserver/s3/ |
H A D | receive.go | 29 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 D | packblobs.go | 104 _, err = cl.ReceiveBlob(ctxbg, fileRef, &buf)
|
/dports/lang/spidermonkey60/firefox-60.9.0/dom/base/ |
H A D | ImageEncoder.h | 118 virtual nsresult ReceiveBlob(already_AddRefed<Blob> aBlob) = 0;
|
/dports/www/firefox-legacy/firefox-52.8.0esr/dom/base/ |
H A D | ImageEncoder.h | 129 virtual nsresult ReceiveBlob(already_AddRefed<Blob> aBlob) = 0;
|
/dports/misc/perkeep/perkeep-0.11/pkg/client/android/ |
H A D | androidx.go | 315 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 D | index_test.go | 373 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 D | receive.go | 42 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 D | statreceiver.go | 70 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 D | remote.go | 117 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 D | CaptureTask.cpp | 107 nsresult ReceiveBlob(already_AddRefed<dom::Blob> aBlob) override { in SetCurrentFrames() function in mozilla::CaptureTask::SetCurrentFrames::EncodeComplete
|