retrievaladapter

Documentation

Index

• 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 APIBlockstoreAccessor
  • func NewAPIBlockstoreAdapter(sub retrievalmarket.BlockstoreAccessor) *APIBlockstoreAccessor
  • func (a *APIBlockstoreAccessor) Done(id retrievalmarket.DealID) error
  • func (a *APIBlockstoreAccessor) Get(id retrievalmarket.DealID, payloadCID retrievalmarket.PayloadCID) (bstore.Blockstore, error)
  • func (a *APIBlockstoreAccessor) RegisterApiStore(sid api.RemoteStoreID, st *lbstore.NetworkStore) error
  • func (a *APIBlockstoreAccessor) RegisterDealToRetrievalStore(id retrievalmarket.DealID, sid api.RemoteStoreID) error
• type CARBlockstoreAccessor
  • 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
  • func (p *ProxyBlockstoreAccessor) Done(_ retrievalmarket.DealID) error
  • func (p *ProxyBlockstoreAccessor) Get(_ retrievalmarket.DealID, _ retrievalmarket.PayloadCID) (bstore.Blockstore, error)

Functions

func NewFixedBlockstoreAccessor

func NewFixedBlockstoreAccessor(bs bstore.Blockstore) retrievalmarket.BlockstoreAccessor

func NewRetrievalClientNode

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

NewRetrievalClientNode returns a new node adapter for a retrieval client that talks to the Lotus Node

func NewRetrievalProviderNode

func NewRetrievalProviderNode(full v1api.FullNode) retrievalmarket.RetrievalProviderNode

NewRetrievalProviderNode returns a new node adapter for a retrieval provider that talks to the Lotus Node

Types

type APIBlockstoreAccessor

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

APIBlockstoreAccessor adds support to API-specified remote blockstores

func NewAPIBlockstoreAdapter

func NewAPIBlockstoreAdapter(sub retrievalmarket.BlockstoreAccessor) *APIBlockstoreAccessor

func (*APIBlockstoreAccessor) Done

func (a *APIBlockstoreAccessor) Done(id retrievalmarket.DealID) error

func (*APIBlockstoreAccessor) Get

func (a *APIBlockstoreAccessor) Get(id retrievalmarket.DealID, payloadCID retrievalmarket.PayloadCID) (bstore.Blockstore, error)

func (*APIBlockstoreAccessor) RegisterApiStore

func (a *APIBlockstoreAccessor) RegisterApiStore(sid api.RemoteStoreID, st *lbstore.NetworkStore) error

func (*APIBlockstoreAccessor) RegisterDealToRetrievalStore

func (a *APIBlockstoreAccessor) RegisterDealToRetrievalStore(id retrievalmarket.DealID, sid api.RemoteStoreID) error

type CARBlockstoreAccessor

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

func NewCARBlockstoreAccessor

func NewCARBlockstoreAccessor(rootdir string) *CARBlockstoreAccessor

func (*CARBlockstoreAccessor) Done

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

func (*CARBlockstoreAccessor) Get

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

func (*CARBlockstoreAccessor) PathFor

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

type ProxyBlockstoreAccessor

type ProxyBlockstoreAccessor struct {
	Blockstore bstore.Blockstore
}

ProxyBlockstoreAccessor is an accessor that returns a fixed blockstore. To be used in combination with IPFS integration.

func (*ProxyBlockstoreAccessor) Done

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

func (*ProxyBlockstoreAccessor) Get

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