remoteblockstore

Documentation

Index

• func NewRemoteBlockstore(api RemoteBlockstoreAPI) blockstore.Blockstore
• type RemoteBlockstore
  • func (ro *RemoteBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
  • func (ro *RemoteBlockstore) DeleteBlock(context.Context, cid.Cid) error
  • func (ro *RemoteBlockstore) Get(ctx context.Context, c cid.Cid) (b blocks.Block, err error)
  • func (ro *RemoteBlockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)
  • func (ro *RemoteBlockstore) Has(ctx context.Context, c cid.Cid) (bool, error)
  • func (ro *RemoteBlockstore) HashOnRead(_ bool)
  • func (ro *RemoteBlockstore) Put(context.Context, blocks.Block) error
  • func (ro *RemoteBlockstore) PutMany(context.Context, []blocks.Block) error
• type RemoteBlockstoreAPI

Functions

func NewRemoteBlockstore

func NewRemoteBlockstore(api RemoteBlockstoreAPI) blockstore.Blockstore

Types

type RemoteBlockstore

type RemoteBlockstore struct {
	// contains filtered or unexported fields
}

RemoteBlockstore is a read-only blockstore over all cids across all pieces on a provider.

func (*RemoteBlockstore) AllKeysChan

func (ro *RemoteBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

func (*RemoteBlockstore) DeleteBlock

func (ro *RemoteBlockstore) DeleteBlock(context.Context, cid.Cid) error

--- UNSUPPORTED BLOCKSTORE METHODS -------

func (*RemoteBlockstore) Get

func (ro *RemoteBlockstore) Get(ctx context.Context, c cid.Cid) (b blocks.Block, err error)

func (*RemoteBlockstore) GetSize

func (ro *RemoteBlockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)

func (*RemoteBlockstore) Has

func (ro *RemoteBlockstore) Has(ctx context.Context, c cid.Cid) (bool, error)

func (*RemoteBlockstore) HashOnRead

func (ro *RemoteBlockstore) HashOnRead(_ bool)

func (*RemoteBlockstore) Put

func (ro *RemoteBlockstore) Put(context.Context, blocks.Block) error

func (*RemoteBlockstore) PutMany

func (ro *RemoteBlockstore) PutMany(context.Context, []blocks.Block) error

type RemoteBlockstoreAPI

type RemoteBlockstoreAPI interface {
	BlockstoreGet(ctx context.Context, c cid.Cid) ([]byte, error)
	BlockstoreHas(ctx context.Context, c cid.Cid) (bool, error)
	BlockstoreGetSize(ctx context.Context, c cid.Cid) (int, error)
}