v1

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 24, 2023 License: Apache-2.0, MIT Imports: 18 Imported by: 24

Documentation

Overview

Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.

Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.

Index

Constants

View Source 
const APINamespace = "v1.IMarket"
View Source 
const MajorVersion = 1
View Source 
const MethodNamespace = "VENUS_MARKET"

Variables

This section is empty.

Functions

This section is empty.

Types

type IMarket 

type IMarket interface {
	ActorUpsert(context.Context, market.User) (bool, error)                   //perm:admin
	ActorDelete(context.Context, address.Address) error                       //perm:admin
	ActorList(context.Context) ([]market.User, error)                         //perm:read
	ActorExist(ctx context.Context, addr address.Address) (bool, error)       //perm:read
	ActorSectorSize(context.Context, address.Address) (abi.SectorSize, error) //perm:read

	MarketImportDealData(ctx context.Context, propcid cid.Cid, path string) error                                                                                                                               //perm:admin
	MarketImportPublishedDeal(ctx context.Context, deal market.MinerDeal) error                                                                                                                                 //perm:write
	MarketListDeals(ctx context.Context, addrs []address.Address) ([]*types.MarketDeal, error)                                                                                                                  //perm:read
	MarketGetDeal(ctx context.Context, dealPropCid cid.Cid) (*market.MinerDeal, error)                                                                                                                          //perm:read
	MarketListRetrievalDeals(ctx context.Context, params *market.RetrievalDealQueryParams) ([]market.ProviderDealState, error)                                                                                  //perm:read
	MarketGetRetrievalDeal(ctx context.Context, receiver peer.ID, dealID uint64) (*market.ProviderDealState, error)                                                                                             //perm:read
	MarketGetDealUpdates(ctx context.Context) (<-chan market.MinerDeal, error)                                                                                                                                  //perm:admin
	MarketListIncompleteDeals(ctx context.Context, params *market.StorageDealQueryParams) ([]market.MinerDeal, error)                                                                                           //perm:read
	MarketSetAsk(ctx context.Context, mAddr address.Address, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error //perm:admin
	MarketGetAsk(ctx context.Context, mAddr address.Address) (*market.SignedStorageAsk, error)                                                                                                                  //perm:read
	MarketListStorageAsk(ctx context.Context) ([]*market.SignedStorageAsk, error)                                                                                                                               //perm:read
	MarketSetRetrievalAsk(ctx context.Context, mAddr address.Address, rask *retrievalmarket.Ask) error                                                                                                          //perm:admin
	MarketGetRetrievalAsk(ctx context.Context, mAddr address.Address) (*retrievalmarket.Ask, error)                                                                                                             //perm:read
	MarketListRetrievalAsk(ctx context.Context) ([]*market.RetrievalAsk, error)                                                                                                                                 //perm:read
	MarketListDataTransfers(ctx context.Context) ([]market.DataTransferChannel, error)                                                                                                                          //perm:admin
	MarketDataTransferUpdates(ctx context.Context) (<-chan market.DataTransferChannel, error)                                                                                                                   //perm:admin
	// MarketRestartDataTransfer attempts to restart a data transfer with the given transfer ID and other peer
	MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error //perm:admin
	// MarketCancelDataTransfer cancels a data transfer with the given transfer ID and other peer
	MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error //perm:admin
	MarketPendingDeals(ctx context.Context) ([]market.PendingDealInfo, error)                                                    //perm:write
	MarketPublishPendingDeals(ctx context.Context) error                                                                         //perm:admin

	PiecesListPieces(ctx context.Context) ([]cid.Cid, error)                                 //perm:read
	PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)                               //perm:read
	PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error) //perm:read
	PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)   //perm:read

	DealsImportData(ctx context.Context, dealPropCid cid.Cid, file string, skipCommP bool) error //perm:admin
	OfflineDealImport(ctx context.Context, deal market.MinerDeal) error                          //perm:admin

	DealsConsiderOnlineStorageDeals(context.Context, address.Address) (bool, error)      //perm:read
	DealsSetConsiderOnlineStorageDeals(context.Context, address.Address, bool) error     //perm:write
	DealsConsiderOnlineRetrievalDeals(context.Context, address.Address) (bool, error)    //perm:read
	DealsSetConsiderOnlineRetrievalDeals(context.Context, address.Address, bool) error   //perm:write
	DealsPieceCidBlocklist(context.Context, address.Address) ([]cid.Cid, error)          //perm:read
	DealsSetPieceCidBlocklist(context.Context, address.Address, []cid.Cid) error         //perm:write
	DealsConsiderOfflineStorageDeals(context.Context, address.Address) (bool, error)     //perm:read
	DealsSetConsiderOfflineStorageDeals(context.Context, address.Address, bool) error    //perm:write
	DealsConsiderOfflineRetrievalDeals(context.Context, address.Address) (bool, error)   //perm:read
	DealsSetConsiderOfflineRetrievalDeals(context.Context, address.Address, bool) error  //perm:write
	DealsConsiderVerifiedStorageDeals(context.Context, address.Address) (bool, error)    //perm:read
	DealsSetConsiderVerifiedStorageDeals(context.Context, address.Address, bool) error   //perm:write
	DealsConsiderUnverifiedStorageDeals(context.Context, address.Address) (bool, error)  //perm:read
	DealsSetConsiderUnverifiedStorageDeals(context.Context, address.Address, bool) error //perm:write
	// SectorGetExpectedSealDuration gets the time that a newly-created sector
	// waits for more deals before it starts sealing
	SectorGetExpectedSealDuration(context.Context, address.Address) (time.Duration, error) //perm:read
	// SectorSetExpectedSealDuration sets the expected time for a sector to seal
	SectorSetExpectedSealDuration(context.Context, address.Address, time.Duration) error    //perm:write
	DealsMaxStartDelay(context.Context, address.Address) (time.Duration, error)             //perm:read
	DealsSetMaxStartDelay(context.Context, address.Address, time.Duration) error            //perm:write
	MarketDataTransferPath(context.Context, address.Address) (string, error)                //perm:admin
	MarketSetDataTransferPath(context.Context, address.Address, string) error               //perm:admin
	DealsPublishMsgPeriod(context.Context, address.Address) (time.Duration, error)          //perm:read
	DealsSetPublishMsgPeriod(context.Context, address.Address, time.Duration) error         //perm:write
	MarketMaxDealsPerPublishMsg(context.Context, address.Address) (uint64, error)           //perm:read
	MarketSetMaxDealsPerPublishMsg(context.Context, address.Address, uint64) error          //perm:write
	DealsMaxProviderCollateralMultiplier(context.Context, address.Address) (uint64, error)  //perm:read
	DealsSetMaxProviderCollateralMultiplier(context.Context, address.Address, uint64) error //perm:write
	DealsMaxPublishFee(context.Context, address.Address) (types.FIL, error)                 //perm:read
	DealsSetMaxPublishFee(context.Context, address.Address, types.FIL) error                //perm:write
	MarketMaxBalanceAddFee(context.Context, address.Address) (types.FIL, error)             //perm:read
	MarketSetMaxBalanceAddFee(context.Context, address.Address, types.FIL) error            //perm:write

	// messager
	MessagerWaitMessage(ctx context.Context, mid cid.Cid) (*types.MsgLookup, error)                            //perm:read
	MessagerPushMessage(ctx context.Context, msg *types.Message, meta *types.MessageSendSpec) (cid.Cid, error) //perm:write
	MessagerGetMessage(ctx context.Context, mid cid.Cid) (*types.Message, error)                               //perm:read

	MarketAddBalance(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, error)                   //perm:sign
	MarketGetReserved(ctx context.Context, addr address.Address) (types.BigInt, error)                                       //perm:sign
	MarketReserveFunds(ctx context.Context, wallet address.Address, addr address.Address, amt types.BigInt) (cid.Cid, error) //perm:sign
	MarketReleaseFunds(ctx context.Context, addr address.Address, amt types.BigInt) error                                    //perm:sign
	MarketWithdraw(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, error)                     //perm:sign

	NetAddrsListen(context.Context) (peer.AddrInfo, error) //perm:read
	ID(context.Context) (peer.ID, error)                   //perm:read

	// DagstoreListShards returns information about all shards known to the
	// DAG store. Only available on nodes running the markets subsystem.
	DagstoreListShards(ctx context.Context) ([]market.DagstoreShardInfo, error) //perm:admin

	// DagstoreInitializeShard initializes an uninitialized shard.
	//
	// Initialization consists of fetching the shard's data (deal payload) from
	// the storage subsystem, generating an index, and persisting the index
	// to facilitate later retrievals, and/or to publish to external sources.
	//
	// This operation is intended to complement the initial migration. The
	// migration registers a shard for every unique piece CID, with lazy
	// initialization. Thus, shards are not initialized immediately to avoid
	// IO activity competing with proving. Instead, shard are initialized
	// when first accessed. This method forces the initialization of a shard by
	// accessing it and immediately releasing it. This is useful to warm up the
	// cache to facilitate subsequent retrievals, and to generate the indexes
	// to publish them externally.
	//
	// This operation fails if the shard is not in ShardStateNew state.
	// It blocks until initialization finishes.
	DagstoreInitializeShard(ctx context.Context, key string) error //perm:admin

	// DagstoreRecoverShard attempts to recover a failed shard.
	//
	// This operation fails if the shard is not in ShardStateErrored state.
	// It blocks until recovery finishes. If recovery failed, it returns the
	// error.
	DagstoreRecoverShard(ctx context.Context, key string) error //perm:admin

	// DagstoreInitializeAll initializes all uninitialized shards in bulk,
	// according to the policy passed in the parameters.
	//
	// It is recommended to set a maximum concurrency to avoid extreme
	// IO pressure if the storage subsystem has a large amount of deals.
	//
	// It returns a stream of events to report progress.
	DagstoreInitializeAll(ctx context.Context, params market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error) //perm:admin

	// DagstoreInitializeStorage initializes all pieces in specify storage
	DagstoreInitializeStorage(context.Context, string, market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error) //perm:admin

	// DagstoreGC runs garbage collection on the DAG store.
	DagstoreGC(ctx context.Context) ([]market.DagstoreShardResult, error) //perm:admin

	// DagstoreDestroyShard destroy shard by key
	DagstoreDestroyShard(ctx context.Context, key string) error //perm:admin

	MarkDealsAsPacking(ctx context.Context, miner address.Address, deals []abi.DealID) error                                                                          //perm:write
	UpdateDealOnPacking(ctx context.Context, miner address.Address, dealID abi.DealID, sectorid abi.SectorNumber, offset abi.PaddedPieceSize) error                   //perm:write
	UpdateDealStatus(ctx context.Context, miner address.Address, dealID abi.DealID, pieceStatus market.PieceStatus, dealStatus storagemarket.StorageDealStatus) error //perm:write
	GetDeals(ctx context.Context, miner address.Address, pageIndex, pageSize int) ([]*market.DealInfo, error)                                                         //perm:read
	AssignUnPackedDeals(ctx context.Context, sid abi.SectorID, ssize abi.SectorSize, spec *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)                 //perm:write
	// ReleaseDeals is used to release the deals that have been assigned by AssignUnPackedDeals method.
	ReleaseDeals(ctx context.Context, miner address.Address, deals []abi.DealID) error                                                                //perm:write
	GetUnPackedDeals(ctx context.Context, miner address.Address, spec *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)                     //perm:read
	UpdateStorageDealStatus(ctx context.Context, dealProposalCid cid.Cid, state storagemarket.StorageDealStatus, pieceState market.PieceStatus) error //perm:write
	// market event
	ResponseMarketEvent(ctx context.Context, resp *gateway.ResponseEvent) error                                        //perm:read
	ListenMarketEvent(ctx context.Context, policy *gateway.MarketRegisterPolicy) (<-chan *gateway.RequestEvent, error) //perm:read

	// Paych
	PaychVoucherList(ctx context.Context, pch address.Address) ([]*paych.SignedVoucher, error) //perm:read

	AddFsPieceStorage(ctx context.Context, name string, path string, readonly bool) error //perm:admin

	AddS3PieceStorage(ctx context.Context, name, endpoit, bucket, subdir, accessKey, secretKey, token string, readonly bool) error //perm:admin

	RemovePieceStorage(ctx context.Context, name string) error //perm:admin

	ListPieceStorageInfos(ctx context.Context) market.PieceStorageInfos //perm:read

	// GetStorageDealStatistic get storage deal statistic information
	// if set miner address to address.Undef, return all storage deal info
	GetStorageDealStatistic(ctx context.Context, miner address.Address) (*market.StorageDealStatistic, error) //perm:read

	// GetRetrievalDealStatistic get retrieval deal statistic information
	// todo address undefined is invalid, it is currently not possible to directly associate an order with a miner
	GetRetrievalDealStatistic(ctx context.Context, miner address.Address) (*market.RetrievalDealStatistic, error) //perm:read

	api.Version
}

func DialIMarketRPC 

func DialIMarketRPC(ctx context.Context, addr string, token string, requestHeader http.Header, opts ...jsonrpc.Option) (IMarket, jsonrpc.ClientCloser, error)

DialIMarketRPC is a more convinient way of building client, as it resolves any format (url, multiaddr) of addr string.

func NewIMarketRPC 

func NewIMarketRPC(ctx context.Context, addr string, requestHeader http.Header, opts ...jsonrpc.Option) (IMarket, jsonrpc.ClientCloser, error)

NewIMarketRPC creates a new httpparse jsonrpc remotecli.

type IMarketStruct 

type IMarketStruct struct {
	Internal struct {
		ActorDelete                             func(context.Context, address.Address) error                                                                                                                                                        `perm:"admin"`
		ActorExist                              func(ctx context.Context, addr address.Address) (bool, error)                                                                                                                                       `perm:"read"`
		ActorList                               func(context.Context) ([]market.User, error)                                                                                                                                                        `perm:"read"`
		ActorSectorSize                         func(context.Context, address.Address) (abi.SectorSize, error)                                                                                                                                      `perm:"read"`
		ActorUpsert                             func(context.Context, market.User) (bool, error)                                                                                                                                                    `perm:"admin"`
		AddFsPieceStorage                       func(ctx context.Context, name string, path string, readonly bool) error                                                                                                                            `perm:"admin"`
		AddS3PieceStorage                       func(ctx context.Context, name, endpoit, bucket, subdir, accessKey, secretKey, token string, readonly bool) error                                                                                   `perm:"admin"`
		AssignUnPackedDeals                     func(ctx context.Context, sid abi.SectorID, ssize abi.SectorSize, spec *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)                                                                  `perm:"write"`
		DagstoreDestroyShard                    func(ctx context.Context, key string) error                                                                                                                                                         `perm:"admin"`
		DagstoreGC                              func(ctx context.Context) ([]market.DagstoreShardResult, error)                                                                                                                                     `perm:"admin"`
		DagstoreInitializeAll                   func(ctx context.Context, params market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)                                                                              `perm:"admin"`
		DagstoreInitializeShard                 func(ctx context.Context, key string) error                                                                                                                                                         `perm:"admin"`
		DagstoreInitializeStorage               func(context.Context, string, market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)                                                                                 `perm:"admin"`
		DagstoreListShards                      func(ctx context.Context) ([]market.DagstoreShardInfo, error)                                                                                                                                       `perm:"admin"`
		DagstoreRecoverShard                    func(ctx context.Context, key string) error                                                                                                                                                         `perm:"admin"`
		DealsConsiderOfflineRetrievalDeals      func(context.Context, address.Address) (bool, error)                                                                                                                                                `perm:"read"`
		DealsConsiderOfflineStorageDeals        func(context.Context, address.Address) (bool, error)                                                                                                                                                `perm:"read"`
		DealsConsiderOnlineRetrievalDeals       func(context.Context, address.Address) (bool, error)                                                                                                                                                `perm:"read"`
		DealsConsiderOnlineStorageDeals         func(context.Context, address.Address) (bool, error)                                                                                                                                                `perm:"read"`
		DealsConsiderUnverifiedStorageDeals     func(context.Context, address.Address) (bool, error)                                                                                                                                                `perm:"read"`
		DealsConsiderVerifiedStorageDeals       func(context.Context, address.Address) (bool, error)                                                                                                                                                `perm:"read"`
		DealsImportData                         func(ctx context.Context, dealPropCid cid.Cid, file string, skipCommP bool) error                                                                                                                   `perm:"admin"`
		DealsMaxProviderCollateralMultiplier    func(context.Context, address.Address) (uint64, error)                                                                                                                                              `perm:"read"`
		DealsMaxPublishFee                      func(context.Context, address.Address) (types.FIL, error)                                                                                                                                           `perm:"read"`
		DealsMaxStartDelay                      func(context.Context, address.Address) (time.Duration, error)                                                                                                                                       `perm:"read"`
		DealsPieceCidBlocklist                  func(context.Context, address.Address) ([]cid.Cid, error)                                                                                                                                           `perm:"read"`
		DealsPublishMsgPeriod                   func(context.Context, address.Address) (time.Duration, error)                                                                                                                                       `perm:"read"`
		DealsSetConsiderOfflineRetrievalDeals   func(context.Context, address.Address, bool) error                                                                                                                                                  `perm:"write"`
		DealsSetConsiderOfflineStorageDeals     func(context.Context, address.Address, bool) error                                                                                                                                                  `perm:"write"`
		DealsSetConsiderOnlineRetrievalDeals    func(context.Context, address.Address, bool) error                                                                                                                                                  `perm:"write"`
		DealsSetConsiderOnlineStorageDeals      func(context.Context, address.Address, bool) error                                                                                                                                                  `perm:"write"`
		DealsSetConsiderUnverifiedStorageDeals  func(context.Context, address.Address, bool) error                                                                                                                                                  `perm:"write"`
		DealsSetConsiderVerifiedStorageDeals    func(context.Context, address.Address, bool) error                                                                                                                                                  `perm:"write"`
		DealsSetMaxProviderCollateralMultiplier func(context.Context, address.Address, uint64) error                                                                                                                                                `perm:"write"`
		DealsSetMaxPublishFee                   func(context.Context, address.Address, types.FIL) error                                                                                                                                             `perm:"write"`
		DealsSetMaxStartDelay                   func(context.Context, address.Address, time.Duration) error                                                                                                                                         `perm:"write"`
		DealsSetPieceCidBlocklist               func(context.Context, address.Address, []cid.Cid) error                                                                                                                                             `perm:"write"`
		DealsSetPublishMsgPeriod                func(context.Context, address.Address, time.Duration) error                                                                                                                                         `perm:"write"`
		GetDeals                                func(ctx context.Context, miner address.Address, pageIndex, pageSize int) ([]*market.DealInfo, error)                                                                                               `perm:"read"`
		GetRetrievalDealStatistic               func(ctx context.Context, miner address.Address) (*market.RetrievalDealStatistic, error)                                                                                                            `perm:"read"`
		GetStorageDealStatistic                 func(ctx context.Context, miner address.Address) (*market.StorageDealStatistic, error)                                                                                                              `perm:"read"`
		GetUnPackedDeals                        func(ctx context.Context, miner address.Address, spec *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)                                                                                   `perm:"read"`
		ID                                      func(context.Context) (peer.ID, error)                                                                                                                                                              `perm:"read"`
		ListPieceStorageInfos                   func(ctx context.Context) market.PieceStorageInfos                                                                                                                                                  `perm:"read"`
		ListenMarketEvent                       func(ctx context.Context, policy *gateway.MarketRegisterPolicy) (<-chan *gateway.RequestEvent, error)                                                                                               `perm:"read"`
		MarkDealsAsPacking                      func(ctx context.Context, miner address.Address, deals []abi.DealID) error                                                                                                                          `perm:"write"`
		MarketAddBalance                        func(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, error)                                                                                                          `perm:"sign"`
		MarketCancelDataTransfer                func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error                                                                                            `perm:"admin"`
		MarketDataTransferPath                  func(context.Context, address.Address) (string, error)                                                                                                                                              `perm:"admin"`
		MarketDataTransferUpdates               func(ctx context.Context) (<-chan market.DataTransferChannel, error)                                                                                                                                `perm:"admin"`
		MarketGetAsk                            func(ctx context.Context, mAddr address.Address) (*market.SignedStorageAsk, error)                                                                                                                  `perm:"read"`
		MarketGetDeal                           func(ctx context.Context, dealPropCid cid.Cid) (*market.MinerDeal, error)                                                                                                                           `perm:"read"`
		MarketGetDealUpdates                    func(ctx context.Context) (<-chan market.MinerDeal, error)                                                                                                                                          `perm:"admin"`
		MarketGetReserved                       func(ctx context.Context, addr address.Address) (types.BigInt, error)                                                                                                                               `perm:"sign"`
		MarketGetRetrievalAsk                   func(ctx context.Context, mAddr address.Address) (*retrievalmarket.Ask, error)                                                                                                                      `perm:"read"`
		MarketGetRetrievalDeal                  func(ctx context.Context, receiver peer.ID, dealID uint64) (*market.ProviderDealState, error)                                                                                                       `perm:"read"`
		MarketImportDealData                    func(ctx context.Context, propcid cid.Cid, path string) error                                                                                                                                       `perm:"admin"`
		MarketImportPublishedDeal               func(ctx context.Context, deal market.MinerDeal) error                                                                                                                                              `perm:"write"`
		MarketListDataTransfers                 func(ctx context.Context) ([]market.DataTransferChannel, error)                                                                                                                                     `perm:"admin"`
		MarketListDeals                         func(ctx context.Context, addrs []address.Address) ([]*types.MarketDeal, error)                                                                                                                     `perm:"read"`
		MarketListIncompleteDeals               func(ctx context.Context, params *market.StorageDealQueryParams) ([]market.MinerDeal, error)                                                                                                        `perm:"read"`
		MarketListRetrievalAsk                  func(ctx context.Context) ([]*market.RetrievalAsk, error)                                                                                                                                           `perm:"read"`
		MarketListRetrievalDeals                func(ctx context.Context, params *market.RetrievalDealQueryParams) ([]market.ProviderDealState, error)                                                                                              `perm:"read"`
		MarketListStorageAsk                    func(ctx context.Context) ([]*market.SignedStorageAsk, error)                                                                                                                                       `perm:"read"`
		MarketMaxBalanceAddFee                  func(context.Context, address.Address) (types.FIL, error)                                                                                                                                           `perm:"read"`
		MarketMaxDealsPerPublishMsg             func(context.Context, address.Address) (uint64, error)                                                                                                                                              `perm:"read"`
		MarketPendingDeals                      func(ctx context.Context) ([]market.PendingDealInfo, error)                                                                                                                                         `perm:"write"`
		MarketPublishPendingDeals               func(ctx context.Context) error                                                                                                                                                                     `perm:"admin"`
		MarketReleaseFunds                      func(ctx context.Context, addr address.Address, amt types.BigInt) error                                                                                                                             `perm:"sign"`
		MarketReserveFunds                      func(ctx context.Context, wallet address.Address, addr address.Address, amt types.BigInt) (cid.Cid, error)                                                                                          `perm:"sign"`
		MarketRestartDataTransfer               func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error                                                                                            `perm:"admin"`
		MarketSetAsk                            func(ctx context.Context, mAddr address.Address, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error `perm:"admin"`
		MarketSetDataTransferPath               func(context.Context, address.Address, string) error                                                                                                                                                `perm:"admin"`
		MarketSetMaxBalanceAddFee               func(context.Context, address.Address, types.FIL) error                                                                                                                                             `perm:"write"`
		MarketSetMaxDealsPerPublishMsg          func(context.Context, address.Address, uint64) error                                                                                                                                                `perm:"write"`
		MarketSetRetrievalAsk                   func(ctx context.Context, mAddr address.Address, rask *retrievalmarket.Ask) error                                                                                                                   `perm:"admin"`
		MarketWithdraw                          func(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, error)                                                                                                          `perm:"sign"`
		MessagerGetMessage                      func(ctx context.Context, mid cid.Cid) (*types.Message, error)                                                                                                                                      `perm:"read"`
		MessagerPushMessage                     func(ctx context.Context, msg *types.Message, meta *types.MessageSendSpec) (cid.Cid, error)                                                                                                         `perm:"write"`
		MessagerWaitMessage                     func(ctx context.Context, mid cid.Cid) (*types.MsgLookup, error)                                                                                                                                    `perm:"read"`
		NetAddrsListen                          func(context.Context) (peer.AddrInfo, error)                                                                                                                                                        `perm:"read"`
		OfflineDealImport                       func(ctx context.Context, deal market.MinerDeal) error                                                                                                                                              `perm:"admin"`
		PaychVoucherList                        func(ctx context.Context, pch address.Address) ([]*paych.SignedVoucher, error)                                                                                                                      `perm:"read"`
		PiecesGetCIDInfo                        func(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)                                                                                                                          `perm:"read"`
		PiecesGetPieceInfo                      func(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)                                                                                                                          `perm:"read"`
		PiecesListCidInfos                      func(ctx context.Context) ([]cid.Cid, error)                                                                                                                                                        `perm:"read"`
		PiecesListPieces                        func(ctx context.Context) ([]cid.Cid, error)                                                                                                                                                        `perm:"read"`
		ReleaseDeals                            func(ctx context.Context, miner address.Address, deals []abi.DealID) error                                                                                                                          `perm:"write"`
		RemovePieceStorage                      func(ctx context.Context, name string) error                                                                                                                                                        `perm:"admin"`
		ResponseMarketEvent                     func(ctx context.Context, resp *gateway.ResponseEvent) error                                                                                                                                        `perm:"read"`
		SectorGetExpectedSealDuration           func(context.Context, address.Address) (time.Duration, error)                                                                                                                                       `perm:"read"`
		SectorSetExpectedSealDuration           func(context.Context, address.Address, time.Duration) error                                                                                                                                         `perm:"write"`
		UpdateDealOnPacking                     func(ctx context.Context, miner address.Address, dealID abi.DealID, sectorid abi.SectorNumber, offset abi.PaddedPieceSize) error                                                                    `perm:"write"`
		UpdateDealStatus                        func(ctx context.Context, miner address.Address, dealID abi.DealID, pieceStatus market.PieceStatus, dealStatus storagemarket.StorageDealStatus) error                                               `perm:"write"`
		UpdateStorageDealStatus                 func(ctx context.Context, dealProposalCid cid.Cid, state storagemarket.StorageDealStatus, pieceState market.PieceStatus) error                                                                      `perm:"write"`
		Version                                 func(ctx context.Context) (types.Version, error)                                                                                                                                                    `perm:"read"`
	}
}

func (*IMarketStruct) ActorDelete added in v1.10.1 

func (s *IMarketStruct) ActorDelete(p0 context.Context, p1 address.Address) error

func (*IMarketStruct) ActorExist 

func (s *IMarketStruct) ActorExist(p0 context.Context, p1 address.Address) (bool, error)

func (*IMarketStruct) ActorList 

func (s *IMarketStruct) ActorList(p0 context.Context) ([]market.User, error)

func (*IMarketStruct) ActorSectorSize 

func (s *IMarketStruct) ActorSectorSize(p0 context.Context, p1 address.Address) (abi.SectorSize, error)

func (*IMarketStruct) ActorUpsert added in v1.10.1 

func (s *IMarketStruct) ActorUpsert(p0 context.Context, p1 market.User) (bool, error)

func (*IMarketStruct) AddFsPieceStorage 

func (s *IMarketStruct) AddFsPieceStorage(p0 context.Context, p1 string, p2 string, p3 bool) error

func (*IMarketStruct) AddS3PieceStorage 

func (s *IMarketStruct) AddS3PieceStorage(p0 context.Context, p1, p2, p3, p4, p5, p6, p7 string, p8 bool) error

func (*IMarketStruct) AssignUnPackedDeals 

func (s *IMarketStruct) AssignUnPackedDeals(p0 context.Context, p1 abi.SectorID, p2 abi.SectorSize, p3 *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)

func (*IMarketStruct) DagstoreDestroyShard added in v1.11.0 

func (s *IMarketStruct) DagstoreDestroyShard(p0 context.Context, p1 string) error

func (*IMarketStruct) DagstoreGC 

func (s *IMarketStruct) DagstoreGC(p0 context.Context) ([]market.DagstoreShardResult, error)

func (*IMarketStruct) DagstoreInitializeAll 

func (s *IMarketStruct) DagstoreInitializeAll(p0 context.Context, p1 market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)

func (*IMarketStruct) DagstoreInitializeShard 

func (s *IMarketStruct) DagstoreInitializeShard(p0 context.Context, p1 string) error

func (*IMarketStruct) DagstoreInitializeStorage 

func (s *IMarketStruct) DagstoreInitializeStorage(p0 context.Context, p1 string, p2 market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)

func (*IMarketStruct) DagstoreListShards 

func (s *IMarketStruct) DagstoreListShards(p0 context.Context) ([]market.DagstoreShardInfo, error)

func (*IMarketStruct) DagstoreRecoverShard 

func (s *IMarketStruct) DagstoreRecoverShard(p0 context.Context, p1 string) error

func (*IMarketStruct) DealsConsiderOfflineRetrievalDeals 

func (s *IMarketStruct) DealsConsiderOfflineRetrievalDeals(p0 context.Context, p1 address.Address) (bool, error)

func (*IMarketStruct) DealsConsiderOfflineStorageDeals 

func (s *IMarketStruct) DealsConsiderOfflineStorageDeals(p0 context.Context, p1 address.Address) (bool, error)

func (*IMarketStruct) DealsConsiderOnlineRetrievalDeals 

func (s *IMarketStruct) DealsConsiderOnlineRetrievalDeals(p0 context.Context, p1 address.Address) (bool, error)

func (*IMarketStruct) DealsConsiderOnlineStorageDeals 

func (s *IMarketStruct) DealsConsiderOnlineStorageDeals(p0 context.Context, p1 address.Address) (bool, error)

func (*IMarketStruct) DealsConsiderUnverifiedStorageDeals 

func (s *IMarketStruct) DealsConsiderUnverifiedStorageDeals(p0 context.Context, p1 address.Address) (bool, error)

func (*IMarketStruct) DealsConsiderVerifiedStorageDeals 

func (s *IMarketStruct) DealsConsiderVerifiedStorageDeals(p0 context.Context, p1 address.Address) (bool, error)

func (*IMarketStruct) DealsImportData 

func (s *IMarketStruct) DealsImportData(p0 context.Context, p1 cid.Cid, p2 string, p3 bool) error

func (*IMarketStruct) DealsMaxProviderCollateralMultiplier 

func (s *IMarketStruct) DealsMaxProviderCollateralMultiplier(p0 context.Context, p1 address.Address) (uint64, error)

func (*IMarketStruct) DealsMaxPublishFee 

func (s *IMarketStruct) DealsMaxPublishFee(p0 context.Context, p1 address.Address) (types.FIL, error)

func (*IMarketStruct) DealsMaxStartDelay 

func (s *IMarketStruct) DealsMaxStartDelay(p0 context.Context, p1 address.Address) (time.Duration, error)

func (*IMarketStruct) DealsPieceCidBlocklist 

func (s *IMarketStruct) DealsPieceCidBlocklist(p0 context.Context, p1 address.Address) ([]cid.Cid, error)

func (*IMarketStruct) DealsPublishMsgPeriod 

func (s *IMarketStruct) DealsPublishMsgPeriod(p0 context.Context, p1 address.Address) (time.Duration, error)

func (*IMarketStruct) DealsSetConsiderOfflineRetrievalDeals 

func (s *IMarketStruct) DealsSetConsiderOfflineRetrievalDeals(p0 context.Context, p1 address.Address, p2 bool) error

func (*IMarketStruct) DealsSetConsiderOfflineStorageDeals 

func (s *IMarketStruct) DealsSetConsiderOfflineStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error

func (*IMarketStruct) DealsSetConsiderOnlineRetrievalDeals 

func (s *IMarketStruct) DealsSetConsiderOnlineRetrievalDeals(p0 context.Context, p1 address.Address, p2 bool) error

func (*IMarketStruct) DealsSetConsiderOnlineStorageDeals 

func (s *IMarketStruct) DealsSetConsiderOnlineStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error

func (*IMarketStruct) DealsSetConsiderUnverifiedStorageDeals 

func (s *IMarketStruct) DealsSetConsiderUnverifiedStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error

func (*IMarketStruct) DealsSetConsiderVerifiedStorageDeals 

func (s *IMarketStruct) DealsSetConsiderVerifiedStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error

func (*IMarketStruct) DealsSetMaxProviderCollateralMultiplier 

func (s *IMarketStruct) DealsSetMaxProviderCollateralMultiplier(p0 context.Context, p1 address.Address, p2 uint64) error

func (*IMarketStruct) DealsSetMaxPublishFee 

func (s *IMarketStruct) DealsSetMaxPublishFee(p0 context.Context, p1 address.Address, p2 types.FIL) error

func (*IMarketStruct) DealsSetMaxStartDelay 

func (s *IMarketStruct) DealsSetMaxStartDelay(p0 context.Context, p1 address.Address, p2 time.Duration) error

func (*IMarketStruct) DealsSetPieceCidBlocklist 

func (s *IMarketStruct) DealsSetPieceCidBlocklist(p0 context.Context, p1 address.Address, p2 []cid.Cid) error

func (*IMarketStruct) DealsSetPublishMsgPeriod 

func (s *IMarketStruct) DealsSetPublishMsgPeriod(p0 context.Context, p1 address.Address, p2 time.Duration) error

func (*IMarketStruct) GetDeals 

func (s *IMarketStruct) GetDeals(p0 context.Context, p1 address.Address, p2, p3 int) ([]*market.DealInfo, error)

func (*IMarketStruct) GetRetrievalDealStatistic 

func (s *IMarketStruct) GetRetrievalDealStatistic(p0 context.Context, p1 address.Address) (*market.RetrievalDealStatistic, error)

func (*IMarketStruct) GetStorageDealStatistic 

func (s *IMarketStruct) GetStorageDealStatistic(p0 context.Context, p1 address.Address) (*market.StorageDealStatistic, error)

func (*IMarketStruct) GetUnPackedDeals 

func (s *IMarketStruct) GetUnPackedDeals(p0 context.Context, p1 address.Address, p2 *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)

func (*IMarketStruct) ID 

func (s *IMarketStruct) ID(p0 context.Context) (peer.ID, error)

func (*IMarketStruct) ListPieceStorageInfos 

func (s *IMarketStruct) ListPieceStorageInfos(p0 context.Context) market.PieceStorageInfos

func (*IMarketStruct) ListenMarketEvent 

func (s *IMarketStruct) ListenMarketEvent(p0 context.Context, p1 *gateway.MarketRegisterPolicy) (<-chan *gateway.RequestEvent, error)

func (*IMarketStruct) MarkDealsAsPacking 

func (s *IMarketStruct) MarkDealsAsPacking(p0 context.Context, p1 address.Address, p2 []abi.DealID) error

func (*IMarketStruct) MarketAddBalance 

func (s *IMarketStruct) MarketAddBalance(p0 context.Context, p1, p2 address.Address, p3 types.BigInt) (cid.Cid, error)

func (*IMarketStruct) MarketCancelDataTransfer 

func (s *IMarketStruct) MarketCancelDataTransfer(p0 context.Context, p1 datatransfer.TransferID, p2 peer.ID, p3 bool) error

func (*IMarketStruct) MarketDataTransferPath 

func (s *IMarketStruct) MarketDataTransferPath(p0 context.Context, p1 address.Address) (string, error)

func (*IMarketStruct) MarketDataTransferUpdates 

func (s *IMarketStruct) MarketDataTransferUpdates(p0 context.Context) (<-chan market.DataTransferChannel, error)

func (*IMarketStruct) MarketGetAsk 

func (s *IMarketStruct) MarketGetAsk(p0 context.Context, p1 address.Address) (*market.SignedStorageAsk, error)

func (*IMarketStruct) MarketGetDeal added in v1.11.0 

func (s *IMarketStruct) MarketGetDeal(p0 context.Context, p1 cid.Cid) (*market.MinerDeal, error)

func (*IMarketStruct) MarketGetDealUpdates 

func (s *IMarketStruct) MarketGetDealUpdates(p0 context.Context) (<-chan market.MinerDeal, error)

func (*IMarketStruct) MarketGetReserved 

func (s *IMarketStruct) MarketGetReserved(p0 context.Context, p1 address.Address) (types.BigInt, error)

func (*IMarketStruct) MarketGetRetrievalAsk 

func (s *IMarketStruct) MarketGetRetrievalAsk(p0 context.Context, p1 address.Address) (*retrievalmarket.Ask, error)

func (*IMarketStruct) MarketGetRetrievalDeal added in v1.11.0 

func (s *IMarketStruct) MarketGetRetrievalDeal(p0 context.Context, p1 peer.ID, p2 uint64) (*market.ProviderDealState, error)

func (*IMarketStruct) MarketImportDealData 

func (s *IMarketStruct) MarketImportDealData(p0 context.Context, p1 cid.Cid, p2 string) error

func (*IMarketStruct) MarketImportPublishedDeal 

func (s *IMarketStruct) MarketImportPublishedDeal(p0 context.Context, p1 market.MinerDeal) error

func (*IMarketStruct) MarketListDataTransfers 

func (s *IMarketStruct) MarketListDataTransfers(p0 context.Context) ([]market.DataTransferChannel, error)

func (*IMarketStruct) MarketListDeals 

func (s *IMarketStruct) MarketListDeals(p0 context.Context, p1 []address.Address) ([]*types.MarketDeal, error)

func (*IMarketStruct) MarketListIncompleteDeals 

func (s *IMarketStruct) MarketListIncompleteDeals(p0 context.Context, p1 *market.StorageDealQueryParams) ([]market.MinerDeal, error)

func (*IMarketStruct) MarketListRetrievalAsk 

func (s *IMarketStruct) MarketListRetrievalAsk(p0 context.Context) ([]*market.RetrievalAsk, error)

func (*IMarketStruct) MarketListRetrievalDeals 

func (s *IMarketStruct) MarketListRetrievalDeals(p0 context.Context, p1 *market.RetrievalDealQueryParams) ([]market.ProviderDealState, error)

func (*IMarketStruct) MarketListStorageAsk 

func (s *IMarketStruct) MarketListStorageAsk(p0 context.Context) ([]*market.SignedStorageAsk, error)

func (*IMarketStruct) MarketMaxBalanceAddFee 

func (s *IMarketStruct) MarketMaxBalanceAddFee(p0 context.Context, p1 address.Address) (types.FIL, error)

func (*IMarketStruct) MarketMaxDealsPerPublishMsg 

func (s *IMarketStruct) MarketMaxDealsPerPublishMsg(p0 context.Context, p1 address.Address) (uint64, error)

func (*IMarketStruct) MarketPendingDeals 

func (s *IMarketStruct) MarketPendingDeals(p0 context.Context) ([]market.PendingDealInfo, error)

func (*IMarketStruct) MarketPublishPendingDeals 

func (s *IMarketStruct) MarketPublishPendingDeals(p0 context.Context) error

func (*IMarketStruct) MarketReleaseFunds 

func (s *IMarketStruct) MarketReleaseFunds(p0 context.Context, p1 address.Address, p2 types.BigInt) error

func (*IMarketStruct) MarketReserveFunds 

func (s *IMarketStruct) MarketReserveFunds(p0 context.Context, p1 address.Address, p2 address.Address, p3 types.BigInt) (cid.Cid, error)

func (*IMarketStruct) MarketRestartDataTransfer 

func (s *IMarketStruct) MarketRestartDataTransfer(p0 context.Context, p1 datatransfer.TransferID, p2 peer.ID, p3 bool) error

func (*IMarketStruct) MarketSetAsk 

func (s *IMarketStruct) MarketSetAsk(p0 context.Context, p1 address.Address, p2 types.BigInt, p3 types.BigInt, p4 abi.ChainEpoch, p5 abi.PaddedPieceSize, p6 abi.PaddedPieceSize) error

func (*IMarketStruct) MarketSetDataTransferPath 

func (s *IMarketStruct) MarketSetDataTransferPath(p0 context.Context, p1 address.Address, p2 string) error

func (*IMarketStruct) MarketSetMaxBalanceAddFee 

func (s *IMarketStruct) MarketSetMaxBalanceAddFee(p0 context.Context, p1 address.Address, p2 types.FIL) error

func (*IMarketStruct) MarketSetMaxDealsPerPublishMsg 

func (s *IMarketStruct) MarketSetMaxDealsPerPublishMsg(p0 context.Context, p1 address.Address, p2 uint64) error

func (*IMarketStruct) MarketSetRetrievalAsk 

func (s *IMarketStruct) MarketSetRetrievalAsk(p0 context.Context, p1 address.Address, p2 *retrievalmarket.Ask) error

func (*IMarketStruct) MarketWithdraw 

func (s *IMarketStruct) MarketWithdraw(p0 context.Context, p1, p2 address.Address, p3 types.BigInt) (cid.Cid, error)

func (*IMarketStruct) MessagerGetMessage 

func (s *IMarketStruct) MessagerGetMessage(p0 context.Context, p1 cid.Cid) (*types.Message, error)

func (*IMarketStruct) MessagerPushMessage 

func (s *IMarketStruct) MessagerPushMessage(p0 context.Context, p1 *types.Message, p2 *types.MessageSendSpec) (cid.Cid, error)

func (*IMarketStruct) MessagerWaitMessage 

func (s *IMarketStruct) MessagerWaitMessage(p0 context.Context, p1 cid.Cid) (*types.MsgLookup, error)

func (*IMarketStruct) NetAddrsListen 

func (s *IMarketStruct) NetAddrsListen(p0 context.Context) (peer.AddrInfo, error)

func (*IMarketStruct) OfflineDealImport 

func (s *IMarketStruct) OfflineDealImport(p0 context.Context, p1 market.MinerDeal) error

func (*IMarketStruct) PaychVoucherList 

func (s *IMarketStruct) PaychVoucherList(p0 context.Context, p1 address.Address) ([]*paych.SignedVoucher, error)

func (*IMarketStruct) PiecesGetCIDInfo 

func (s *IMarketStruct) PiecesGetCIDInfo(p0 context.Context, p1 cid.Cid) (*piecestore.CIDInfo, error)

func (*IMarketStruct) PiecesGetPieceInfo 

func (s *IMarketStruct) PiecesGetPieceInfo(p0 context.Context, p1 cid.Cid) (*piecestore.PieceInfo, error)

func (*IMarketStruct) PiecesListCidInfos 

func (s *IMarketStruct) PiecesListCidInfos(p0 context.Context) ([]cid.Cid, error)

func (*IMarketStruct) PiecesListPieces 

func (s *IMarketStruct) PiecesListPieces(p0 context.Context) ([]cid.Cid, error)

func (*IMarketStruct) ReleaseDeals added in v1.11.0 

func (s *IMarketStruct) ReleaseDeals(p0 context.Context, p1 address.Address, p2 []abi.DealID) error

func (*IMarketStruct) RemovePieceStorage 

func (s *IMarketStruct) RemovePieceStorage(p0 context.Context, p1 string) error

func (*IMarketStruct) ResponseMarketEvent 

func (s *IMarketStruct) ResponseMarketEvent(p0 context.Context, p1 *gateway.ResponseEvent) error

func (*IMarketStruct) SectorGetExpectedSealDuration 

func (s *IMarketStruct) SectorGetExpectedSealDuration(p0 context.Context, p1 address.Address) (time.Duration, error)

func (*IMarketStruct) SectorSetExpectedSealDuration 

func (s *IMarketStruct) SectorSetExpectedSealDuration(p0 context.Context, p1 address.Address, p2 time.Duration) error

func (*IMarketStruct) UpdateDealOnPacking 

func (s *IMarketStruct) UpdateDealOnPacking(p0 context.Context, p1 address.Address, p2 abi.DealID, p3 abi.SectorNumber, p4 abi.PaddedPieceSize) error

func (*IMarketStruct) UpdateDealStatus 

func (s *IMarketStruct) UpdateDealStatus(p0 context.Context, p1 address.Address, p2 abi.DealID, p3 market.PieceStatus, p4 storagemarket.StorageDealStatus) error

func (*IMarketStruct) UpdateStorageDealStatus 

func (s *IMarketStruct) UpdateStorageDealStatus(p0 context.Context, p1 cid.Cid, p2 storagemarket.StorageDealStatus, p3 market.PieceStatus) error

func (*IMarketStruct) Version 

func (s *IMarketStruct) Version(p0 context.Context) (types.Version, error)

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.