bridge

func (b BridgeBs) AllKeysChan(ctx ctx.Context) (<-chan cid.Cid, error)

func (c BridgeBs) Close() error

func (b BridgeBs) DeleteBlock(ctx.Context, cid.Cid) error

func (b BridgeBs) Get(ctx ctx.Context, key cid.Cid) (blocks.Block, error)

func (b BridgeBs) GetRaw(ctx ctx.Context, key cid.Cid) (value []byte, err error)

func (b BridgeBs) GetSize(ctx ctx.Context, key cid.Cid) (size int, err error)

func (b BridgeBs) Has(ctx ctx.Context, key cid.Cid) (exists bool, err error)

func (b BridgeBs) HashOnRead(enabled bool)

func (b BridgeBs) Put(ctx.Context, blocks.Block) error

func (b BridgeBs) PutMany(ctx.Context, []blocks.Block) error

func (b BridgeDs) Batch(ctx ctx.Context) (ds.Batch, error)

func (c BridgeDs) Close() error

func (b BridgeDs) Delete(ctx ctx.Context, key ds.Key) error

func (b BridgeDs) Get(ctx ctx.Context, key ds.Key) (value []byte, err error)

func (b BridgeDs) GetSize(ctx ctx.Context, key ds.Key) (size int, err error)

func (b BridgeDs) Has(ctx ctx.Context, key ds.Key) (exists bool, err error)

func (b BridgeDs) Put(ctx ctx.Context, key ds.Key, value []byte) error

func (b BridgeDs) Query(ctx ctx.Context, q dsq.Query) (dsq.Results, error)

func (b BridgeDs) Sync(ctx ctx.Context, prefix ds.Key) error

func (*BridgePlugin) DatastoreConfigParser() fsrepo.ConfigFromMap

func (*BridgePlugin) DatastoreTypeName() string

func (*BridgePlugin) Init(env *plugin.Environment) error

func (*BridgePlugin) Name() string

func (*BridgePlugin) Version() string

func (cfg *SwhClientConfig) Create(string) (repo.Datastore, error)

func (c *SwhClientConfig) DiskSpec() fsrepo.DiskSpec