MCPcopy
hub / github.com/perkeep/perkeep / ReceiveBlob

Method ReceiveBlob

pkg/blobserver/interface.go:55–55  ·  view source on GitHub ↗

ReceiveBlob accepts a newly uploaded blob and writes it to permanent storage. Implementations of BlobReceiver downstream of the HTTP server can trust that the source isn't larger than MaxBlobSize and that its digest matches the provided blob ref. (If not, the read of the source will fail before EOF

(ctx context.Context, br blob.Ref, source io.Reader)

Source from the content-addressed store, hash-verified

53 // take care of notifying the BlobReceiver's "BlobHub"
54 // notification bus for observers.
55 ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error)
56}
57
58// BlobStatter is the interface for checking the size and existence of blobs.

Callers 15

ReceiveBlobMethod · 0.65
newSignerFunction · 0.65
addBlobMethod · 0.65
initTestsFunction · 0.65
receiveFunction · 0.65
TestDeleteFunction · 0.65
ReceiveBlobMethod · 0.65
TestOptFunction · 0.65
testSubFetcherMethod · 0.65
ReceiveBlobMethod · 0.65
TestShardFunction · 0.65
ReceiveBlobMethod · 0.65

Implementers 15

Clientpkg/client/client.go
StatusReceiverpkg/client/android/androidx.go
NoImplStoragepkg/blobserver/noimpl.go
remoteStoragepkg/blobserver/remote/remote.go
storagepkg/blobserver/diskpacked/diskpacked.g
nstopkg/blobserver/namespace/ns.go
Storagepkg/blobserver/files/files.go
unionStoragepkg/blobserver/union/union.go
azureStoragepkg/blobserver/azure/azure.go
mongoStoragepkg/blobserver/mongo/mongo.go
Storagepkg/blobserver/memory/mem.go
replicaStoragepkg/blobserver/replica/replica.go

Calls

no outgoing calls

Tested by 12

newSignerFunction · 0.52
addBlobMethod · 0.52
initTestsFunction · 0.52
TestDeleteFunction · 0.52
TestOptFunction · 0.52
TestShardFunction · 0.52
TestDeleteFunction · 0.52
testOutOfOrderIndexingFunction · 0.52
copyBlobFunction · 0.52
TestFixMissingWholerefFunction · 0.52
putRawMethod · 0.52