retrievalimpl

Documentation

Index

• Variables
• func NewClient(network rmnet.RetrievalMarketNetwork, bs blockstore.Blockstore, ...) (retrievalmarket.RetrievalClient, error)
• func NewProvider(minerAddress address.Address, node retrievalmarket.RetrievalProviderNode, ...) (retrievalmarket.RetrievalProvider, error)

Variables

var ClientDsPrefix = "/retrievals/client"

ClientDsPrefix is the datastore for the client retrievals key

var DefaultPaymentInterval = uint64(1 << 20)

DefaultPaymentInterval is the baseline interval, set to 1Mb if the miner does not explicitly set it otherwise

var DefaultPaymentIntervalIncrease = uint64(1 << 20)

DefaultPaymentIntervalIncrease is the amount interval increases on each payment, set to to 1Mb if the miner does not explicitly set it otherwise

var DefaultPricePerByte = abi.NewTokenAmount(2)

DefaultPricePerByte is the charge per byte retrieved if the miner does not specifically set it

var ProviderDsPrefix = "/retrievals/provider"

ProviderDsPrefix is the datastore for the provider key

Functions

func NewClient

func NewClient(
	network rmnet.RetrievalMarketNetwork,
	bs blockstore.Blockstore,
	node retrievalmarket.RetrievalClientNode,
	resolver retrievalmarket.PeerResolver,
	ds datastore.Batching,
	storedCounter *storedcounter.StoredCounter,
) (retrievalmarket.RetrievalClient, error)

NewClient creates a new retrieval client

func NewProvider

func NewProvider(minerAddress address.Address, node retrievalmarket.RetrievalProviderNode, network rmnet.RetrievalMarketNetwork, pieceStore piecestore.PieceStore, bs blockstore.Blockstore, ds datastore.Batching) (retrievalmarket.RetrievalProvider, error)

NewProvider returns a new retrieval provider