retrievaladapter

Mar 8, 2023

Changes in this version

+ func NewFixedBlockstoreAccessor(bs bstore.Blockstore) retrievalmarket.BlockstoreAccessor

+ func NewRetrievalClientNode(forceOffChain bool, payAPI payapi.PaychAPI, chainAPI full.ChainAPI, ...) retrievalmarket.RetrievalClientNode

+ func NewRetrievalProviderNode(full v1api.FullNode) retrievalmarket.RetrievalProviderNode

+ type CARBlockstoreAccessor struct

+ func NewCARBlockstoreAccessor(rootdir string) *CARBlockstoreAccessor

+ func (c *CARBlockstoreAccessor) Done(id retrievalmarket.DealID) error

+ func (c *CARBlockstoreAccessor) Get(id retrievalmarket.DealID, payloadCid retrievalmarket.PayloadCID) (bstore.Blockstore, error)

+ func (c *CARBlockstoreAccessor) PathFor(id retrievalmarket.DealID) string

+ type ProxyBlockstoreAccessor struct

+ Blockstore bstore.Blockstore

+ func (p *ProxyBlockstoreAccessor) Done(_ retrievalmarket.DealID) error

+ func (p *ProxyBlockstoreAccessor) Get(_ retrievalmarket.DealID, _ retrievalmarket.PayloadCID) (bstore.Blockstore, error)