MCPcopy
hub / github.com/perkeep/perkeep / StreamBlobs

Method StreamBlobs

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

BlobStream is an optional interface that may be implemented by Storage implementations. StreamBlobs sends blobs to dest in an unspecified order. It is expected that a Storage implementation implementing BlobStreamer will send blobs to dest in the most efficient order possible. The provided continu

(ctx context.Context, dest chan<- BlobAndToken, contToken string)

Source from the content-addressed store, hash-verified

124 //
125 // When StreamBlobs reaches the end, the return value is nil.
126 StreamBlobs(ctx context.Context, dest chan<- BlobAndToken, contToken string) error
127}
128
129// Cache is the minimal interface expected of a blob cache.

Callers 5

StreamBlobsMethod · 0.65
streamAllFunction · 0.65
TestStreamerFunction · 0.65
StreamBlobsMethod · 0.65
StreamBlobsMethod · 0.65

Implementers 6

multiStreamerpkg/blobserver/multistream.go
storagepkg/blobserver/diskpacked/diskpacked.g
Storagepkg/blobserver/memory/mem.go
storagepkg/blobserver/blobpacked/blobpacked.g
smallBlobStreamerpkg/blobserver/blobpacked/stream.go
largeBlobStreamerpkg/blobserver/blobpacked/stream.go

Calls

no outgoing calls

Tested by 2

streamAllFunction · 0.52
TestStreamerFunction · 0.52