INNER CODE UNIT · Go

newBlobReadSeekCloser

psviderski/unregistry · internal/storage/containerd/blob.go:166

func newBlobReadSeekCloser(ctx context.Context, provider content.Provider, desc ocispec.Descriptor) (
	io.ReadSeekCloser, error,
) {
	ra, err := provider.ReaderAt(ctx, desc)
	if err != nil {
		return nil, err
	}

	return &blobReadSeekCloser{
		SectionReader: io.NewSectionReader(ra, 0, ra.Size()),
		ra:            ra,
	}, nil
}

func (rsc *blobReadSeekCloser) Close() error {
	return rsc.ra.Close()
}

View source record →