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 ¶
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)
Source Files
Click to show internal directories.
Click to hide internal directories.