market

package

v1.7.1 Latest Latest Go to latest Published: Sep 5, 2022 License: Apache-2.0, MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/filecoin-project/venus

Links

Open Source Insights

Documentation ¶

Overview ¶

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

Index ¶

Constants
type IMarket
- func DialIMarketRPC(ctx context.Context, addr string, token string, requestHeader http.Header, ...) (IMarket, jsonrpc.ClientCloser, error)
- func NewIMarketRPC(ctx context.Context, addr string, requestHeader http.Header, ...) (IMarket, jsonrpc.ClientCloser, error)
type IMarketStruct

Constants ¶

View Source

const APINamespace = "market.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 {
	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:write
	MarketImportPublishedDeal(ctx context.Context, deal market.MinerDeal) error                                                                                                                                 //perm:write
	MarketListDeals(ctx context.Context, addrs []address.Address) ([]*types.MarketDeal, error)                                                                                                                  //perm:read
	MarketListRetrievalDeals(ctx context.Context, mAddr address.Address) ([]market.ProviderDealState, error)                                                                                                    //perm:read
	MarketGetDealUpdates(ctx context.Context) (<-chan market.MinerDeal, error)                                                                                                                                  //perm:read
	MarketListIncompleteDeals(ctx context.Context, mAddr address.Address) ([]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) (*storagemarket.SignedStorageAsk, error)                                                                                                           //perm:read
	MarketListAsk(ctx context.Context) ([]*storagemarket.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:write
	MarketDataTransferUpdates(ctx context.Context) (<-chan market.DataTransferChannel, error)                                                                                                                   //perm:write
	// 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:write
	// 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:write
	MarketPendingDeals(ctx context.Context) ([]market.PendingDealInfo, error)                                                    //perm:write
	MarketPublishPendingDeals(ctx context.Context) error                                                                         //perm:admin

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

	DealsImportData(ctx context.Context, dealPropCid cid.Cid, file string) error //perm:admin
	OfflineDealImport(ctx context.Context, deal market.MinerDeal) error          //perm:admin
	DealsConsiderOnlineStorageDeals(context.Context) (bool, error)               //perm:admin
	DealsSetConsiderOnlineStorageDeals(context.Context, bool) error              //perm:admin
	DealsConsiderOnlineRetrievalDeals(context.Context) (bool, error)             //perm:admin
	DealsSetConsiderOnlineRetrievalDeals(context.Context, bool) error            //perm:admin
	DealsPieceCidBlocklist(context.Context) ([]cid.Cid, error)                   //perm:admin
	DealsSetPieceCidBlocklist(context.Context, []cid.Cid) error                  //perm:admin
	DealsConsiderOfflineStorageDeals(context.Context) (bool, error)              //perm:admin
	DealsSetConsiderOfflineStorageDeals(context.Context, bool) error             //perm:admin
	DealsConsiderOfflineRetrievalDeals(context.Context) (bool, error)            //perm:admin
	DealsSetConsiderOfflineRetrievalDeals(context.Context, bool) error           //perm:admin
	DealsConsiderVerifiedStorageDeals(context.Context) (bool, error)             //perm:admin
	DealsSetConsiderVerifiedStorageDeals(context.Context, bool) error            //perm:admin
	DealsConsiderUnverifiedStorageDeals(context.Context) (bool, error)           //perm:admin
	DealsSetConsiderUnverifiedStorageDeals(context.Context, bool) error          //perm:admin
	// SectorGetSealDelay gets the time that a newly-created sector
	// waits for more deals before it starts sealing
	SectorGetSealDelay(context.Context) (time.Duration, error) //perm:read
	// SectorSetExpectedSealDuration sets the expected time for a sector to seal
	SectorSetExpectedSealDuration(context.Context, time.Duration) 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

	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

	ImportV1Data(ctx context.Context, src string) error //perm:write

	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 ¶ added in v1.2.2

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 {
		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"`
		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"`
		DagstoreGC                             func(ctx context.Context) ([]market.DagstoreShardResult, error)                                                                                                                                     `perm:"admin"`
		DagstoreInitializeAll                  func(ctx context.Context, params market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)                                                                              `perm:"admin"`
		DagstoreInitializeShard                func(ctx context.Context, key string) error                                                                                                                                                         `perm:"admin"`
		DagstoreInitializeStorage              func(context.Context, string, market.DagstoreInitializeAllParams) (<-chan market.DagstoreInitializeAllEvent, error)                                                                                 `perm:"admin"`
		DagstoreListShards                     func(ctx context.Context) ([]market.DagstoreShardInfo, error)                                                                                                                                       `perm:"admin"`
		DagstoreRecoverShard                   func(ctx context.Context, key string) error                                                                                                                                                         `perm:"admin"`
		DealsConsiderOfflineRetrievalDeals     func(context.Context) (bool, error)                                                                                                                                                                 `perm:"admin"`
		DealsConsiderOfflineStorageDeals       func(context.Context) (bool, error)                                                                                                                                                                 `perm:"admin"`
		DealsConsiderOnlineRetrievalDeals      func(context.Context) (bool, error)                                                                                                                                                                 `perm:"admin"`
		DealsConsiderOnlineStorageDeals        func(context.Context) (bool, error)                                                                                                                                                                 `perm:"admin"`
		DealsConsiderUnverifiedStorageDeals    func(context.Context) (bool, error)                                                                                                                                                                 `perm:"admin"`
		DealsConsiderVerifiedStorageDeals      func(context.Context) (bool, error)                                                                                                                                                                 `perm:"admin"`
		DealsImportData                        func(ctx context.Context, dealPropCid cid.Cid, file string) error                                                                                                                                   `perm:"admin"`
		DealsPieceCidBlocklist                 func(context.Context) ([]cid.Cid, error)                                                                                                                                                            `perm:"admin"`
		DealsSetConsiderOfflineRetrievalDeals  func(context.Context, bool) error                                                                                                                                                                   `perm:"admin"`
		DealsSetConsiderOfflineStorageDeals    func(context.Context, bool) error                                                                                                                                                                   `perm:"admin"`
		DealsSetConsiderOnlineRetrievalDeals   func(context.Context, bool) error                                                                                                                                                                   `perm:"admin"`
		DealsSetConsiderOnlineStorageDeals     func(context.Context, bool) error                                                                                                                                                                   `perm:"admin"`
		DealsSetConsiderUnverifiedStorageDeals func(context.Context, bool) error                                                                                                                                                                   `perm:"admin"`
		DealsSetConsiderVerifiedStorageDeals   func(context.Context, bool) error                                                                                                                                                                   `perm:"admin"`
		DealsSetPieceCidBlocklist              func(context.Context, []cid.Cid) error                                                                                                                                                              `perm:"admin"`
		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"`
		ImportV1Data                           func(ctx context.Context, src string) error                                                                                                                                                         `perm:"write"`
		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:"write"`
		MarketDataTransferUpdates              func(ctx context.Context) (<-chan market.DataTransferChannel, error)                                                                                                                                `perm:"write"`
		MarketGetAsk                           func(ctx context.Context, mAddr address.Address) (*storagemarket.SignedStorageAsk, error)                                                                                                           `perm:"read"`
		MarketGetDealUpdates                   func(ctx context.Context) (<-chan market.MinerDeal, error)                                                                                                                                          `perm:"read"`
		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"`
		MarketImportDealData                   func(ctx context.Context, propcid cid.Cid, path string) error                                                                                                                                       `perm:"write"`
		MarketImportPublishedDeal              func(ctx context.Context, deal market.MinerDeal) error                                                                                                                                              `perm:"write"`
		MarketListAsk                          func(ctx context.Context) ([]*storagemarket.SignedStorageAsk, error)                                                                                                                                `perm:"read"`
		MarketListDataTransfers                func(ctx context.Context) ([]market.DataTransferChannel, error)                                                                                                                                     `perm:"write"`
		MarketListDeals                        func(ctx context.Context, addrs []address.Address) ([]*types.MarketDeal, error)                                                                                                                     `perm:"read"`
		MarketListIncompleteDeals              func(ctx context.Context, mAddr address.Address) ([]market.MinerDeal, error)                                                                                                                        `perm:"read"`
		MarketListRetrievalAsk                 func(ctx context.Context) ([]*market.RetrievalAsk, error)                                                                                                                                           `perm:"read"`
		MarketListRetrievalDeals               func(ctx context.Context, mAddr address.Address) ([]market.ProviderDealState, 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:"write"`
		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"`
		MarketSetRetrievalAsk                  func(ctx context.Context, mAddr address.Address, rask *retrievalmarket.Ask) error                                                                                                                   `perm:"admin"`
		MarketWithdraw                         func(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, error)                                                                                                          `perm:"sign"`
		MessagerGetMessage                     func(ctx context.Context, mid cid.Cid) (*types.Message, error)                                                                                                                                      `perm:"read"`
		MessagerPushMessage                    func(ctx context.Context, msg *types.Message, meta *types.MessageSendSpec) (cid.Cid, error)                                                                                                         `perm:"write"`
		MessagerWaitMessage                    func(ctx context.Context, mid cid.Cid) (*types.MsgLookup, error)                                                                                                                                    `perm:"read"`
		NetAddrsListen                         func(context.Context) (peer.AddrInfo, error)                                                                                                                                                        `perm:"read"`
		OfflineDealImport                      func(ctx context.Context, deal market.MinerDeal) error                                                                                                                                              `perm:"admin"`
		PaychVoucherList                       func(ctx context.Context, pch address.Address) ([]*paych.SignedVoucher, error)                                                                                                                      `perm:"read"`
		PiecesGetCIDInfo                       func(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)                                                                                                                          `perm:"read"`
		PiecesGetPieceInfo                     func(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)                                                                                                                          `perm:"read"`
		PiecesListCidInfos                     func(ctx context.Context) ([]cid.Cid, error)                                                                                                                                                        `perm:"read"`
		PiecesListPieces                       func(ctx context.Context) ([]cid.Cid, error)                                                                                                                                                        `perm:"read"`
		RemovePieceStorage                     func(ctx context.Context, name string) error                                                                                                                                                        `perm:"admin"`
		ResponseMarketEvent                    func(ctx context.Context, resp *gateway.ResponseEvent) error                                                                                                                                        `perm:"read"`
		SectorGetSealDelay                     func(context.Context) (time.Duration, error)                                                                                                                                                        `perm:"read"`
		SectorSetExpectedSealDuration          func(context.Context, 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) 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) AddFsPieceStorage ¶ added in v1.6.1

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

func (*IMarketStruct) AddS3PieceStorage ¶ added in v1.6.1

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) 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 ¶ added in v1.7.0

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

func (*IMarketStruct) DagstoreListShards ¶

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

func (*IMarketStruct) DagstoreRecoverShard ¶

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

func (*IMarketStruct) DealsConsiderOfflineRetrievalDeals ¶

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

func (*IMarketStruct) DealsConsiderOfflineStorageDeals ¶

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

func (*IMarketStruct) DealsConsiderOnlineRetrievalDeals ¶

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

func (*IMarketStruct) DealsConsiderOnlineStorageDeals ¶

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

func (*IMarketStruct) DealsConsiderUnverifiedStorageDeals ¶

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

func (*IMarketStruct) DealsConsiderVerifiedStorageDeals ¶

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

func (*IMarketStruct) DealsImportData ¶

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

func (*IMarketStruct) DealsPieceCidBlocklist ¶

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

func (*IMarketStruct) DealsSetConsiderOfflineRetrievalDeals ¶

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

func (*IMarketStruct) DealsSetConsiderOfflineStorageDeals ¶

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

func (*IMarketStruct) DealsSetConsiderOnlineRetrievalDeals ¶

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

func (*IMarketStruct) DealsSetConsiderOnlineStorageDeals ¶

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

func (*IMarketStruct) DealsSetConsiderUnverifiedStorageDeals ¶

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

func (*IMarketStruct) DealsSetConsiderVerifiedStorageDeals ¶

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

func (*IMarketStruct) DealsSetPieceCidBlocklist ¶

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

func (*IMarketStruct) GetDeals ¶

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

func (*IMarketStruct) GetRetrievalDealStatistic ¶ added in v1.7.0

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

func (*IMarketStruct) GetStorageDealStatistic ¶ added in v1.7.0

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

func (*IMarketStruct) GetUnPackedDeals ¶

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

func (*IMarketStruct) ID ¶

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

func (*IMarketStruct) ImportV1Data ¶

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

func (*IMarketStruct) ListPieceStorageInfos ¶ added in v1.7.0

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) 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) (*storagemarket.SignedStorageAsk, 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) MarketImportDealData ¶

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

func (*IMarketStruct) MarketImportPublishedDeal ¶ added in v1.2.4

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

func (*IMarketStruct) MarketListAsk ¶

func (s *IMarketStruct) MarketListAsk(p0 context.Context) ([]*storagemarket.SignedStorageAsk, 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 address.Address) ([]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 address.Address) ([]market.ProviderDealState, error)

func (*IMarketStruct) MarketPendingDeals ¶

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

func (*IMarketStruct) MarketPublishPendingDeals ¶

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

func (*IMarketStruct) MarketReleaseFunds ¶

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

func (*IMarketStruct) MarketReserveFunds ¶

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

func (*IMarketStruct) MarketRestartDataTransfer ¶

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

func (*IMarketStruct) MarketSetAsk ¶

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

func (*IMarketStruct) MarketSetRetrievalAsk ¶

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

func (*IMarketStruct) MarketWithdraw ¶

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

func (*IMarketStruct) MessagerGetMessage ¶

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

func (*IMarketStruct) MessagerPushMessage ¶

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

func (*IMarketStruct) MessagerWaitMessage ¶

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

func (*IMarketStruct) NetAddrsListen ¶

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

func (*IMarketStruct) OfflineDealImport ¶ added in v1.7.0

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

func (*IMarketStruct) PaychVoucherList ¶

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

func (*IMarketStruct) PiecesGetCIDInfo ¶

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

func (*IMarketStruct) PiecesGetPieceInfo ¶

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

func (*IMarketStruct) PiecesListCidInfos ¶

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

func (*IMarketStruct) PiecesListPieces ¶

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

func (*IMarketStruct) RemovePieceStorage ¶ added in v1.6.1

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) SectorGetSealDelay ¶

func (s *IMarketStruct) SectorGetSealDelay(p0 context.Context) (time.Duration, error)

func (*IMarketStruct) SectorSetExpectedSealDuration ¶

func (s *IMarketStruct) SectorSetExpectedSealDuration(p0 context.Context, p1 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 ¶ added in v1.7.0

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen.	Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen.
mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL