v0

package
v1.15.2 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2024 License: Apache-2.0, MIT Imports: 18 Imported by: 2

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 = "v0.IMarket"
View Source
const MajorVersion = 0
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, ref market.ImportDataRef, skipCommP bool) error                      //perm:admin
	DealsBatchImportData(ctx context.Context, refs market.ImportDataRefs) ([]*market.ImportDataResult, error) //perm:admin
	DealsImport(ctx context.Context, deals []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) 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
	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"`
		DealsBatchImportData                    func(ctx context.Context, refs market.ImportDataRefs) ([]*market.ImportDataResult, 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"`
		DealsImport                             func(ctx context.Context, deals []market.MinerDeal) error                                                                                                                                           `perm:"admin"`
		DealsImportData                         func(ctx context.Context, ref market.ImportDataRef, 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"`
		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"`
		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) 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 (*IMarketStruct) DagstoreInitializeAll

func (*IMarketStruct) DagstoreInitializeShard

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

func (*IMarketStruct) DagstoreInitializeStorage

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) DealsBatchImportData added in v1.12.0

func (s *IMarketStruct) DealsBatchImportData(p0 context.Context, p1 market.ImportDataRefs) ([]*market.ImportDataResult, 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) DealsImport added in v1.12.0

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

func (*IMarketStruct) DealsImportData

func (s *IMarketStruct) DealsImportData(p0 context.Context, p1 market.ImportDataRef, p2 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 (*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 (*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 (*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) 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) 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) 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)

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