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 (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
- type ProxyBlockstoreAccessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFixedBlockstoreAccessor ¶ added in v1.11.2
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 ¶ added in v1.19.0
type APIBlockstoreAccessor struct {
// contains filtered or unexported fields
}
APIBlockstoreAccessor adds support to API-specified remote blockstores
func NewAPIBlockstoreAdapter ¶ added in v1.19.0
func NewAPIBlockstoreAdapter(sub retrievalmarket.BlockstoreAccessor) *APIBlockstoreAccessor
func (*APIBlockstoreAccessor) Done ¶ added in v1.19.0
func (a *APIBlockstoreAccessor) Done(id retrievalmarket.DealID) error
func (*APIBlockstoreAccessor) Get ¶ added in v1.19.0
func (a *APIBlockstoreAccessor) Get(id retrievalmarket.DealID, payloadCID retrievalmarket.PayloadCID) (bstore.Blockstore, error)
func (*APIBlockstoreAccessor) RegisterApiStore ¶ added in v1.19.0
func (a *APIBlockstoreAccessor) RegisterApiStore(sid api.RemoteStoreID, st *lbstore.NetworkStore) error
func (*APIBlockstoreAccessor) RegisterDealToRetrievalStore ¶ added in v1.19.0
func (a *APIBlockstoreAccessor) RegisterDealToRetrievalStore(id retrievalmarket.DealID, sid api.RemoteStoreID) error
type CARBlockstoreAccessor ¶ added in v1.11.2
type CARBlockstoreAccessor struct {
// contains filtered or unexported fields
}
func NewCARBlockstoreAccessor ¶ added in v1.11.2
func NewCARBlockstoreAccessor(rootdir string) *CARBlockstoreAccessor
func (*CARBlockstoreAccessor) Done ¶ added in v1.11.2
func (c *CARBlockstoreAccessor) Done(id retrievalmarket.DealID) error
func (*CARBlockstoreAccessor) Get ¶ added in v1.11.2
func (c *CARBlockstoreAccessor) Get(id retrievalmarket.DealID, payloadCid retrievalmarket.PayloadCID) (bstore.Blockstore, error)
func (*CARBlockstoreAccessor) PathFor ¶ added in v1.11.2
func (c *CARBlockstoreAccessor) PathFor(id retrievalmarket.DealID) string
type ProxyBlockstoreAccessor ¶ added in v1.11.2
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 ¶ added in v1.11.2
func (p *ProxyBlockstoreAccessor) Done(_ retrievalmarket.DealID) error
func (*ProxyBlockstoreAccessor) Get ¶ added in v1.11.2
func (p *ProxyBlockstoreAccessor) Get(_ retrievalmarket.DealID, _ retrievalmarket.PayloadCID) (bstore.Blockstore, error)
Source Files
Click to show internal directories.
Click to hide internal directories.