storage

Oct 12, 2023

Changes in this version

type DuplicateAdderCar

+ func NewDuplicateAdderCarForPath(ctx context.Context, outPath string, root cid.Cid, path string, ...) *DuplicateAdderCar

Sep 19, 2023

Changes in this version

+ func AsIdentity(key string) (digest []byte, ok bool, err error)

May 25, 2023

Changes in this version

+ type DeferredWriter interface

+ BlockWriteOpener func() linking.BlockWriteOpener

+ OnPut func(cb func(int), once bool)

+ type DuplicateAdderCar struct

+ func NewDuplicateAdderCarForStream(ctx context.Context, root cid.Cid, path string, scope types.DagScope, ...) *DuplicateAdderCar

+ func (da *DuplicateAdderCar) BlockWriteOpener() linking.BlockWriteOpener

+ func (da *DuplicateAdderCar) Close() error

Mar 31, 2023

Changes in this version

+ type CachingTempStore struct

+ func NewCachingTempStore(outWriter linking.BlockWriteOpener, tempDir string) *CachingTempStore

+ func (ttrw *CachingTempStore) Close() error

+ func (ttrw *CachingTempStore) Get(ctx context.Context, key string) ([]byte, error)

+ func (ttrw *CachingTempStore) GetStream(ctx context.Context, key string) (io.ReadCloser, error)

+ func (ttrw *CachingTempStore) Has(ctx context.Context, key string) (bool, error)

+ func (ttrw *CachingTempStore) PreloadStore() types.ReadableWritableStorage

+ func (ttrw *CachingTempStore) Put(ctx context.Context, key string, data []byte) error

+ type DeferredCarWriter struct

+ func NewDeferredCarWriterForPath(root cid.Cid, outPath string) *DeferredCarWriter

+ func NewDeferredCarWriterForStream(root cid.Cid, outStream io.Writer) *DeferredCarWriter

+ func (dcw *DeferredCarWriter) BlockWriteOpener() linking.BlockWriteOpener

+ func (dcw *DeferredCarWriter) Close() error

+ func (dcw *DeferredCarWriter) Has(ctx context.Context, key string) (bool, error)

+ func (dcw *DeferredCarWriter) OnPut(cb func(int), once bool)

+ func (dcw *DeferredCarWriter) Put(ctx context.Context, key string, content []byte) error

+ type DeferredStorageCar struct

+ func NewDeferredStorageCar(tempDir string) *DeferredStorageCar

+ func (dcs *DeferredStorageCar) Close() error

+ func (dcs *DeferredStorageCar) Get(ctx context.Context, key string) ([]byte, error)

+ func (dcs *DeferredStorageCar) GetStream(ctx context.Context, key string) (io.ReadCloser, error)

+ func (dcs *DeferredStorageCar) Has(ctx context.Context, key string) (bool, error)

+ func (dcs *DeferredStorageCar) Put(ctx context.Context, key string, data []byte) error

+ type ReadableWritableStorage interface