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
- type IMarket
- type IMarketStruct
- func (s *IMarketStruct) ActorDelete(p0 context.Context, p1 address.Address) error
- func (s *IMarketStruct) ActorExist(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMarketStruct) ActorList(p0 context.Context) ([]market.User, error)
- func (s *IMarketStruct) ActorSectorSize(p0 context.Context, p1 address.Address) (abi.SectorSize, error)
- func (s *IMarketStruct) ActorUpsert(p0 context.Context, p1 market.User) (bool, error)
- func (s *IMarketStruct) AddFsPieceStorage(p0 context.Context, p1 string, p2 string, p3 bool) error
- func (s *IMarketStruct) AddS3PieceStorage(p0 context.Context, p1, p2, p3, p4, p5, p6, p7 string, p8 bool) error
- func (s *IMarketStruct) AssignUnPackedDeals(p0 context.Context, p1 abi.SectorID, p2 abi.SectorSize, p3 *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)
- func (s *IMarketStruct) DagstoreDestroyShard(p0 context.Context, p1 string) error
- func (s *IMarketStruct) DagstoreGC(p0 context.Context) ([]market.DagstoreShardResult, error)
- func (s *IMarketStruct) DagstoreInitializeAll(p0 context.Context, p1 market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)
- func (s *IMarketStruct) DagstoreInitializeShard(p0 context.Context, p1 string) error
- func (s *IMarketStruct) DagstoreInitializeStorage(p0 context.Context, p1 string, p2 market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)
- func (s *IMarketStruct) DagstoreListShards(p0 context.Context) ([]market.DagstoreShardInfo, error)
- func (s *IMarketStruct) DagstoreRecoverShard(p0 context.Context, p1 string) error
- func (s *IMarketStruct) DealsBatchImportData(p0 context.Context, p1 market.ImportDataRefs) ([]*market.ImportDataResult, error)
- func (s *IMarketStruct) DealsConsiderOfflineRetrievalDeals(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMarketStruct) DealsConsiderOfflineStorageDeals(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMarketStruct) DealsConsiderOnlineRetrievalDeals(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMarketStruct) DealsConsiderOnlineStorageDeals(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMarketStruct) DealsConsiderUnverifiedStorageDeals(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMarketStruct) DealsConsiderVerifiedStorageDeals(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMarketStruct) DealsImport(p0 context.Context, p1 []market.MinerDeal) error
- func (s *IMarketStruct) DealsImportData(p0 context.Context, p1 market.ImportDataRef, p2 bool) error
- func (s *IMarketStruct) DealsMaxProviderCollateralMultiplier(p0 context.Context, p1 address.Address) (uint64, error)
- func (s *IMarketStruct) DealsMaxPublishFee(p0 context.Context, p1 address.Address) (types.FIL, error)
- func (s *IMarketStruct) DealsMaxStartDelay(p0 context.Context, p1 address.Address) (time.Duration, error)
- func (s *IMarketStruct) DealsPieceCidBlocklist(p0 context.Context, p1 address.Address) ([]cid.Cid, error)
- func (s *IMarketStruct) DealsPublishMsgPeriod(p0 context.Context, p1 address.Address) (time.Duration, error)
- func (s *IMarketStruct) DealsSetConsiderOfflineRetrievalDeals(p0 context.Context, p1 address.Address, p2 bool) error
- func (s *IMarketStruct) DealsSetConsiderOfflineStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error
- func (s *IMarketStruct) DealsSetConsiderOnlineRetrievalDeals(p0 context.Context, p1 address.Address, p2 bool) error
- func (s *IMarketStruct) DealsSetConsiderOnlineStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error
- func (s *IMarketStruct) DealsSetConsiderUnverifiedStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error
- func (s *IMarketStruct) DealsSetConsiderVerifiedStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error
- func (s *IMarketStruct) DealsSetMaxProviderCollateralMultiplier(p0 context.Context, p1 address.Address, p2 uint64) error
- func (s *IMarketStruct) DealsSetMaxPublishFee(p0 context.Context, p1 address.Address, p2 types.FIL) error
- func (s *IMarketStruct) DealsSetMaxStartDelay(p0 context.Context, p1 address.Address, p2 time.Duration) error
- func (s *IMarketStruct) DealsSetPieceCidBlocklist(p0 context.Context, p1 address.Address, p2 []cid.Cid) error
- func (s *IMarketStruct) DealsSetPublishMsgPeriod(p0 context.Context, p1 address.Address, p2 time.Duration) error
- func (s *IMarketStruct) GetDeals(p0 context.Context, p1 address.Address, p2, p3 int) ([]*market.DealInfo, error)
- func (s *IMarketStruct) GetRetrievalDealStatistic(p0 context.Context, p1 address.Address) (*market.RetrievalDealStatistic, error)
- func (s *IMarketStruct) GetStorageDealStatistic(p0 context.Context, p1 address.Address) (*market.StorageDealStatistic, error)
- func (s *IMarketStruct) GetUnPackedDeals(p0 context.Context, p1 address.Address, p2 *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)
- func (s *IMarketStruct) ID(p0 context.Context) (peer.ID, error)
- func (s *IMarketStruct) ListPieceStorageInfos(p0 context.Context) market.PieceStorageInfos
- func (s *IMarketStruct) ListenMarketEvent(p0 context.Context, p1 *gateway.MarketRegisterPolicy) (<-chan *gateway.RequestEvent, error)
- func (s *IMarketStruct) MarkDealsAsPacking(p0 context.Context, p1 address.Address, p2 []abi.DealID) error
- func (s *IMarketStruct) MarketAddBalance(p0 context.Context, p1, p2 address.Address, p3 types.BigInt) (cid.Cid, error)
- func (s *IMarketStruct) MarketCancelDataTransfer(p0 context.Context, p1 datatransfer.TransferID, p2 peer.ID, p3 bool) error
- func (s *IMarketStruct) MarketDataTransferPath(p0 context.Context, p1 address.Address) (string, error)
- func (s *IMarketStruct) MarketDataTransferUpdates(p0 context.Context) (<-chan market.DataTransferChannel, error)
- func (s *IMarketStruct) MarketGetAsk(p0 context.Context, p1 address.Address) (*market.SignedStorageAsk, error)
- func (s *IMarketStruct) MarketGetDeal(p0 context.Context, p1 cid.Cid) (*market.MinerDeal, error)
- func (s *IMarketStruct) MarketGetDealUpdates(p0 context.Context) (<-chan market.MinerDeal, error)
- func (s *IMarketStruct) MarketGetReserved(p0 context.Context, p1 address.Address) (types.BigInt, error)
- func (s *IMarketStruct) MarketGetRetrievalAsk(p0 context.Context, p1 address.Address) (*retrievalmarket.Ask, error)
- func (s *IMarketStruct) MarketGetRetrievalDeal(p0 context.Context, p1 peer.ID, p2 uint64) (*market.ProviderDealState, error)
- func (s *IMarketStruct) MarketImportDealData(p0 context.Context, p1 cid.Cid, p2 string) error
- func (s *IMarketStruct) MarketImportPublishedDeal(p0 context.Context, p1 market.MinerDeal) error
- func (s *IMarketStruct) MarketListDataTransfers(p0 context.Context) ([]market.DataTransferChannel, error)
- func (s *IMarketStruct) MarketListDeals(p0 context.Context, p1 []address.Address) ([]*types.MarketDeal, error)
- func (s *IMarketStruct) MarketListIncompleteDeals(p0 context.Context, p1 *market.StorageDealQueryParams) ([]market.MinerDeal, error)
- func (s *IMarketStruct) MarketListRetrievalAsk(p0 context.Context) ([]*market.RetrievalAsk, error)
- func (s *IMarketStruct) MarketListRetrievalDeals(p0 context.Context, p1 *market.RetrievalDealQueryParams) ([]market.ProviderDealState, error)
- func (s *IMarketStruct) MarketListStorageAsk(p0 context.Context) ([]*market.SignedStorageAsk, error)
- func (s *IMarketStruct) MarketMaxBalanceAddFee(p0 context.Context, p1 address.Address) (types.FIL, error)
- func (s *IMarketStruct) MarketMaxDealsPerPublishMsg(p0 context.Context, p1 address.Address) (uint64, error)
- func (s *IMarketStruct) MarketPendingDeals(p0 context.Context) ([]market.PendingDealInfo, error)
- func (s *IMarketStruct) MarketPublishPendingDeals(p0 context.Context) error
- func (s *IMarketStruct) MarketReleaseFunds(p0 context.Context, p1 address.Address, p2 types.BigInt) error
- func (s *IMarketStruct) MarketReserveFunds(p0 context.Context, p1 address.Address, p2 address.Address, p3 types.BigInt) (cid.Cid, error)
- func (s *IMarketStruct) MarketRestartDataTransfer(p0 context.Context, p1 datatransfer.TransferID, p2 peer.ID, p3 bool) error
- func (s *IMarketStruct) MarketSetAsk(p0 context.Context, p1 address.Address, p2 types.BigInt, p3 types.BigInt, ...) error
- func (s *IMarketStruct) MarketSetDataTransferPath(p0 context.Context, p1 address.Address, p2 string) error
- func (s *IMarketStruct) MarketSetMaxBalanceAddFee(p0 context.Context, p1 address.Address, p2 types.FIL) error
- func (s *IMarketStruct) MarketSetMaxDealsPerPublishMsg(p0 context.Context, p1 address.Address, p2 uint64) error
- func (s *IMarketStruct) MarketSetRetrievalAsk(p0 context.Context, p1 address.Address, p2 *retrievalmarket.Ask) error
- func (s *IMarketStruct) MarketWithdraw(p0 context.Context, p1, p2 address.Address, p3 types.BigInt) (cid.Cid, error)
- func (s *IMarketStruct) MessagerGetMessage(p0 context.Context, p1 cid.Cid) (*types.Message, error)
- func (s *IMarketStruct) MessagerPushMessage(p0 context.Context, p1 *types.Message, p2 *types.MessageSendSpec) (cid.Cid, error)
- func (s *IMarketStruct) MessagerWaitMessage(p0 context.Context, p1 cid.Cid) (*types.MsgLookup, error)
- func (s *IMarketStruct) NetAddrsListen(p0 context.Context) (peer.AddrInfo, error)
- func (s *IMarketStruct) PaychVoucherList(p0 context.Context, p1 address.Address) ([]*paych.SignedVoucher, error)
- func (s *IMarketStruct) PiecesGetCIDInfo(p0 context.Context, p1 cid.Cid) (*piecestore.CIDInfo, error)
- func (s *IMarketStruct) PiecesGetPieceInfo(p0 context.Context, p1 cid.Cid) (*piecestore.PieceInfo, error)
- func (s *IMarketStruct) PiecesListCidInfos(p0 context.Context) ([]cid.Cid, error)
- func (s *IMarketStruct) PiecesListPieces(p0 context.Context) ([]cid.Cid, error)
- func (s *IMarketStruct) RemovePieceStorage(p0 context.Context, p1 string) error
- func (s *IMarketStruct) ResponseMarketEvent(p0 context.Context, p1 *gateway.ResponseEvent) error
- func (s *IMarketStruct) SectorGetExpectedSealDuration(p0 context.Context, p1 address.Address) (time.Duration, error)
- func (s *IMarketStruct) SectorSetExpectedSealDuration(p0 context.Context, p1 address.Address, p2 time.Duration) error
- func (s *IMarketStruct) UpdateDealOnPacking(p0 context.Context, p1 address.Address, p2 abi.DealID, p3 abi.SectorNumber, ...) error
- func (s *IMarketStruct) UpdateDealStatus(p0 context.Context, p1 address.Address, p2 abi.DealID, p3 market.PieceStatus) error
- func (s *IMarketStruct) UpdateStorageDealStatus(p0 context.Context, p1 cid.Cid, p2 storagemarket.StorageDealStatus, ...) error
- func (s *IMarketStruct) Version(p0 context.Context) (types.Version, error)
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
}
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 (*IMarketStruct) ActorExist ¶
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 (*IMarketStruct) AddFsPieceStorage ¶
func (*IMarketStruct) AddS3PieceStorage ¶
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) DealsBatchImportData ¶ added in v1.12.0
func (s *IMarketStruct) DealsBatchImportData(p0 context.Context, p1 market.ImportDataRefs) ([]*market.ImportDataResult, error)
func (*IMarketStruct) DealsConsiderOfflineRetrievalDeals ¶
func (*IMarketStruct) DealsConsiderOfflineStorageDeals ¶
func (*IMarketStruct) DealsConsiderOnlineRetrievalDeals ¶
func (*IMarketStruct) DealsConsiderOnlineStorageDeals ¶
func (*IMarketStruct) DealsConsiderUnverifiedStorageDeals ¶
func (*IMarketStruct) DealsConsiderVerifiedStorageDeals ¶
func (*IMarketStruct) DealsImport ¶ added in v1.12.0
func (*IMarketStruct) DealsImportData ¶
func (s *IMarketStruct) DealsImportData(p0 context.Context, p1 market.ImportDataRef, p2 bool) error
func (*IMarketStruct) DealsMaxProviderCollateralMultiplier ¶
func (*IMarketStruct) DealsMaxPublishFee ¶
func (*IMarketStruct) DealsMaxStartDelay ¶
func (*IMarketStruct) DealsPieceCidBlocklist ¶
func (*IMarketStruct) DealsPublishMsgPeriod ¶
func (*IMarketStruct) DealsSetConsiderOfflineRetrievalDeals ¶
func (*IMarketStruct) DealsSetConsiderOfflineStorageDeals ¶
func (*IMarketStruct) DealsSetConsiderOnlineRetrievalDeals ¶
func (*IMarketStruct) DealsSetConsiderOnlineStorageDeals ¶
func (*IMarketStruct) DealsSetConsiderUnverifiedStorageDeals ¶
func (*IMarketStruct) DealsSetConsiderVerifiedStorageDeals ¶
func (*IMarketStruct) DealsSetMaxProviderCollateralMultiplier ¶
func (*IMarketStruct) DealsSetMaxPublishFee ¶
func (*IMarketStruct) DealsSetMaxStartDelay ¶
func (*IMarketStruct) DealsSetPieceCidBlocklist ¶
func (*IMarketStruct) DealsSetPublishMsgPeriod ¶
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) 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 (*IMarketStruct) MarketAddBalance ¶
func (*IMarketStruct) MarketCancelDataTransfer ¶
func (s *IMarketStruct) MarketCancelDataTransfer(p0 context.Context, p1 datatransfer.TransferID, p2 peer.ID, p3 bool) error
func (*IMarketStruct) MarketDataTransferPath ¶
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 (*IMarketStruct) MarketGetDealUpdates ¶
func (*IMarketStruct) MarketGetReserved ¶
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 (*IMarketStruct) MarketImportPublishedDeal ¶
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 (*IMarketStruct) MarketMaxDealsPerPublishMsg ¶
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 (*IMarketStruct) MarketReserveFunds ¶
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 (*IMarketStruct) MarketSetMaxBalanceAddFee ¶
func (*IMarketStruct) MarketSetMaxDealsPerPublishMsg ¶
func (*IMarketStruct) MarketSetRetrievalAsk ¶
func (s *IMarketStruct) MarketSetRetrievalAsk(p0 context.Context, p1 address.Address, p2 *retrievalmarket.Ask) error
func (*IMarketStruct) MarketWithdraw ¶
func (*IMarketStruct) MessagerGetMessage ¶
func (*IMarketStruct) MessagerPushMessage ¶
func (s *IMarketStruct) MessagerPushMessage(p0 context.Context, p1 *types.Message, p2 *types.MessageSendSpec) (cid.Cid, error)
func (*IMarketStruct) MessagerWaitMessage ¶
func (*IMarketStruct) NetAddrsListen ¶
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 (*IMarketStruct) PiecesListPieces ¶
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 (*IMarketStruct) SectorSetExpectedSealDuration ¶
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
Click to show internal directories.
Click to hide internal directories.