MCPcopy Index your code
hub / github.com/perkeep/perkeep / SubFetch

Method SubFetch

pkg/test/fetcher.go:60–71  ·  view source on GitHub ↗
(ctx context.Context, ref blob.Ref, offset, length int64)

Source from the content-addressed store, hash-verified

58}
59
60func (tf *Fetcher) SubFetch(ctx context.Context, ref blob.Ref, offset, length int64) (io.ReadCloser, error) {
61 if tf.FetchErr != nil {
62 if err := tf.FetchErr(); err != nil {
63 return nil, err
64 }
65 }
66 rc, err := tf.Storage.SubFetch(ctx, ref, offset, length)
67 if err != nil {
68 return rc, err
69 }
70 return rc, nil
71}
72
73func (tf *Fetcher) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error) {
74 sb, err := tf.Storage.ReceiveBlob(ctx, br, source)

Callers

nothing calls this directly

Implementers 15

Clientpkg/client/client.go
serialFetcherpkg/blob/fetcher.go
DirFetcherpkg/blob/fetcher.go
CachingFetcherpkg/cacher/cacher.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

Calls 1

SubFetchMethod · 0.65

Tested by

no test coverage detected