store

Apr 5, 2023

Changes in this version

+ func Finalize(writer io.WriterAt, header carv2.Header, idx *InsertionIndex, dataSize uint64, ...) error

+ func FindCid(reader io.ReaderAt, idx index.Index, key cid.Cid, useWholeCids bool, ...) ([]byte, int64, int, error)

+ func Has(idx *InsertionIndex, c cid.Cid, maxIndexCidSize uint64, storeIdentityCIDs bool, ...) (bool, error)

+ func IsIdentity(key cid.Cid) (digest []byte, ok bool, err error)

+ func ResumableVersion(reader io.Reader, writeAsV1 bool) error

+ func Resume(rw ReaderWriterAt, dataReader io.ReaderAt, ...) error

+ func ShouldPut(idx *InsertionIndex, c cid.Cid, maxIndexCidSize uint64, storeIdentityCIDs bool, ...) (bool, error)

+ type InsertionIndex struct

+ func NewInsertionIndex() *InsertionIndex

+ func (ii *InsertionIndex) Codec() multicodec.Code

+ func (ii *InsertionIndex) Flatten(codec multicodec.Code) (index.Index, error)

+ func (ii *InsertionIndex) ForEach(f func(multihash.Multihash, uint64) error) error

+ func (ii *InsertionIndex) ForEachCid(f func(cid.Cid, uint64) error) error

+ func (ii *InsertionIndex) Get(c cid.Cid) (uint64, error)

+ func (ii *InsertionIndex) GetAll(c cid.Cid, fn func(uint64) bool) error

+ func (ii *InsertionIndex) HasExactCID(c cid.Cid) (bool, error)

+ func (ii *InsertionIndex) HasMultihash(mh multihash.Multihash) (bool, error)

+ func (ii *InsertionIndex) InsertNoReplace(key cid.Cid, n uint64)

+ func (ii *InsertionIndex) Load(rs []index.Record) error

+ func (ii *InsertionIndex) Marshal(w io.Writer) (uint64, error)

+ func (ii *InsertionIndex) Unmarshal(r io.Reader) error

+ type ReaderWriterAt interface