stores

Aug 3, 2022

Changes in this version

+ func DestroyShardSync(ctx context.Context, ds DAGStoreWrapper, pieceCid cid.Cid) error

type DAGStoreWrapper

+ DestroyShard func(ctx context.Context, pieceCid cid.Cid, resch chan dagstore.ShardResult) error

Jan 12, 2022

Changes in this version

type DAGStoreWrapper

+ GetIterableIndexForPiece func(pieceCid cid.Cid) (carindex.IterableIndex, error)

+ GetPiecesContainingBlock func(blockCID cid.Cid) ([]cid.Cid, error)

Dec 6, 2021

Changes in this version

+ func AllowDuplicatePuts(allow bool) carv2.Option

+ func HeaderSize(h *CarHeader) (uint64, error)

+ func LdRead(r io.Reader, zeroLenAsEOF bool) ([]byte, error)

+ func LdSize(d ...[]byte) uint64

+ func LdWrite(w io.Writer, d ...[]byte) error

+ func ReadNode(r io.Reader, zeroLenAsEOF bool) (cid.Cid, []byte, error)

+ func ToByteReader(r io.Reader) io.ByteReader

+ func ToReaderAt(rs io.ReadSeeker) io.ReaderAt

+ func UseWholeCIDs(enable bool) carv2.Option

+ func WithAsyncErrorHandler(ctx context.Context, errHandler func(error)) context.Context

+ func WriteCar(ctx context.Context, ds format.NodeGetter, roots []cid.Cid, w io.Writer) error

+ func WriteHeader(h *CarHeader, w io.Writer) error

+ type ByteReadSeeker interface

+ func ToByteReadSeeker(r io.Reader) ByteReadSeeker

+ type BytesReader interface

+ type CarHeader struct

+ Roots []cid.Cid

+ Version uint64

+ func LoadCar(s Store, r io.Reader) (*CarHeader, error)

+ func ReadHeader(r io.Reader) (*CarHeader, error)

+ func (h CarHeader) Matches(other CarHeader) bool

+ type CarReader struct

+ Header *CarHeader

+ func NewCarReader(r io.Reader) (*CarReader, error)

+ func NewCarReaderWithZeroLengthSectionAsEOF(r io.Reader) (*CarReader, error)

+ func (cr *CarReader) Next() (blocks.Block, error)

+ type OffsetReadSeeker struct

+ func NewOffsetReadSeeker(r io.ReaderAt, off int64) *OffsetReadSeeker

+ func (o *OffsetReadSeeker) Offset() int64

+ func (o *OffsetReadSeeker) Position() int64

+ func (o *OffsetReadSeeker) Read(p []byte) (n int, err error)

+ func (o *OffsetReadSeeker) ReadAt(p []byte, off int64) (n int, err error)

+ func (o *OffsetReadSeeker) ReadByte() (byte, error)

+ func (o *OffsetReadSeeker) Seek(offset int64, whence int) (int64, error)

+ type OffsetWriteSeeker struct

+ func NewOffsetWriter(w io.WriterAt, off int64) *OffsetWriteSeeker

+ func (ow *OffsetWriteSeeker) Position() int64

+ func (ow *OffsetWriteSeeker) Seek(offset int64, whence int) (int64, error)

+ func (ow *OffsetWriteSeeker) Write(b []byte) (n int, err error)

+ type ReadOnly struct

+ func NewReadOnly(backing io.ReaderAt, idx index.Index, opts ...carv2.Option) (*ReadOnly, error)

+ func OpenReadOnly(path string, opts ...carv2.Option) (*ReadOnly, error)

+ func (b *ReadOnly) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

+ func (b *ReadOnly) Close() error

+ func (b *ReadOnly) DeleteBlock(_ cid.Cid) error

+ func (b *ReadOnly) Get(key cid.Cid) (blocks.Block, error)

+ func (b *ReadOnly) GetSize(key cid.Cid) (int, error)

+ func (b *ReadOnly) Has(key cid.Cid) (bool, error)

+ func (b *ReadOnly) HashOnRead(bool)

+ func (b *ReadOnly) Put(blocks.Block) error

+ func (b *ReadOnly) PutMany([]blocks.Block) error

+ func (b *ReadOnly) Roots() ([]cid.Cid, error)

+ type ReadStore interface

+ Get func(cid.Cid) (blocks.Block, error)

+ type ReadWrite struct

+ func OpenReadWrite(path string, roots []cid.Cid, opts ...carv2.Option) (*ReadWrite, error)

+ func (b *ReadWrite) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

+ func (b *ReadWrite) DeleteBlock(_ cid.Cid) error

+ func (b *ReadWrite) Discard()

+ func (b *ReadWrite) Finalize() error

+ func (b *ReadWrite) Get(key cid.Cid) (blocks.Block, error)

+ func (b *ReadWrite) GetSize(key cid.Cid) (int, error)

+ func (b *ReadWrite) Has(key cid.Cid) (bool, error)

+ func (b *ReadWrite) HashOnRead(enable bool)

+ func (b *ReadWrite) Put(blk blocks.Block) error

+ func (b *ReadWrite) PutMany(blks []blocks.Block) error

+ func (b *ReadWrite) Roots() ([]cid.Cid, error)

+ type Store interface

+ Put func(blocks.Block) error

Aug 16, 2021

Changes in this version

+ var ErrNotFound = xerrors.New("not found")

+ func FilestoreOf(bs bstore.Blockstore) (bstore.Blockstore, error)

+ func IsNotFound(err error) bool

+ func RegisterShardSync(ctx context.Context, ds DAGStoreWrapper, pieceCid cid.Cid, carPath string, ...) error

+ type ClosableBlockstore interface

+ func ReadOnlyFilestore(path string) (ClosableBlockstore, error)

+ func ReadWriteFilestore(path string, roots ...cid.Cid) (ClosableBlockstore, error)

+ type DAGStoreWrapper interface

+ Close func() error

+ LoadShard func(ctx context.Context, pieceCid cid.Cid) (ClosableBlockstore, error)

+ MigrateDeals func(ctx context.Context, deals []storagemarket.MinerDeal) (bool, error)

+ RegisterShard func(ctx context.Context, pieceCid cid.Cid, carPath string, eagerInit bool, ...) error

+ type ReadOnlyBlockstores struct

+ func NewReadOnlyBlockstores() *ReadOnlyBlockstores

+ func (r *ReadOnlyBlockstores) Get(key string) (bstore.Blockstore, error)

+ func (r *ReadOnlyBlockstores) Track(key string, bs bstore.Blockstore) (bool, error)

+ func (r *ReadOnlyBlockstores) Untrack(key string) error

+ type ReadWriteBlockstores struct

+ func NewReadWriteBlockstores() *ReadWriteBlockstores

+ func (r *ReadWriteBlockstores) Get(key string) (*blockstore.ReadWrite, error)

+ func (r *ReadWriteBlockstores) GetOrOpen(key string, path string, rootCid cid.Cid) (*blockstore.ReadWrite, error)

+ func (r *ReadWriteBlockstores) Untrack(key string) error