Documentation ¶
Index ¶
- func NewFixedBlockstoreAccessor(bs bstore.Blockstore) retrievalmarket.BlockstoreAccessor
- func NewRetrievalClientNode(payAPI payapi.PaychAPI, chainAPI full.ChainAPI, stateAPI full.StateAPI) retrievalmarket.RetrievalClientNode
- func NewRetrievalProviderNode(full v1api.FullNode) retrievalmarket.RetrievalProviderNode
- 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(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 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)
Click to show internal directories.
Click to hide internal directories.