Documentation
¶
Index ¶
- type SqliteBlockstore
- func (bs *SqliteBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
- func (bs *SqliteBlockstore) DeleteBlock(ctx context.Context, c cid.Cid) error
- func (bs *SqliteBlockstore) DeleteMany(ctx context.Context, cids []cid.Cid) error
- func (bs *SqliteBlockstore) Get(ctx context.Context, cid cid.Cid) (blocks.Block, error)
- func (bs *SqliteBlockstore) GetSize(context.Context, cid.Cid) (int, error)
- func (bs *SqliteBlockstore) Has(context.Context, cid.Cid) (bool, error)
- func (bs *SqliteBlockstore) HashOnRead(enabled bool)
- func (bs *SqliteBlockstore) Put(ctx context.Context, block blocks.Block) error
- func (bs *SqliteBlockstore) PutMany(ctx context.Context, blocks []blocks.Block) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SqliteBlockstore ¶
type SqliteBlockstore struct {
// contains filtered or unexported fields
}
func NewReadOnly ¶
func NewReadOnly(did string, db *db.DB) *SqliteBlockstore
func (*SqliteBlockstore) AllKeysChan ¶
func (*SqliteBlockstore) DeleteBlock ¶
func (*SqliteBlockstore) DeleteMany ¶ added in v0.11.2
DeleteMany removes the given blocks from the underlying storage. Blocks that are not present are ignored (delete is idempotent), matching the reference PDS behavior for removedCids.
func (*SqliteBlockstore) HashOnRead ¶
func (bs *SqliteBlockstore) HashOnRead(enabled bool)
Source Files
Click to show internal directories.
Click to hide internal directories.