Method StatBlobs

pkg/blobserver/diskpacked/diskpacked.go:446–457

arbitrary

(ctx context.Context, blobs []blob.Ref, fn func(blob.SizedRef) error)

var statGate = syncutil.NewGate(20) // arbitrary

func (s *storage) StatBlobs(ctx context.Context, blobs []blob.Ref, fn func(blob.SizedRef) error) error {
	return blobserver.StatBlobsParallelHelper(ctx, blobs, fn, statGate, func(br blob.Ref) (sb blob.SizedRef, err error) {
		m, err := s.meta(br)
		if err == nil {
			return m.SizedRef(br), nil
		}
		if errors.Is(err, os.ErrNotExist) {
			return sb, nil
		}
		return sb, err
	})
}

func (s *storage) EnumerateBlobs(ctx context.Context, dest chan<- blob.SizedRef, after string, limit int) (err error) {
	defer close(dest)