Method Fetch

pkg/blobserver/mongo/fetch.go:29–39

(ctx context.Context, ref blob.Ref)

)

func (m *mongoStorage) Fetch(ctx context.Context, ref blob.Ref) (io.ReadCloser, uint32, error) {
	var b blobDoc
	err := m.c.Find(bson.M{"key": ref.String()}).One(&b)
	if err != nil {
		return nil, 0, err
	}
	if len(b.Blob) != int(b.Size) {
		return nil, 0, fmt.Errorf("blob data size %d doesn't match meta size %d", len(b.Blob), b.Size)
	}
	return io.NopCloser(bytes.NewReader(b.Blob)), b.Size, nil
}