market

package
v1.3.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2022 License: Apache-2.0, MIT Imports: 18 Imported by: 0

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 = "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
	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
	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:read

	// 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:write

	// 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:write

	// 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:write

	// 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 string) error                                              //perm:write
	GetDeals(ctx context.Context, miner address.Address, pageIndex, pageSize int) ([]*market.DealInfo, error)                                              //perm:read
	AssignUnPackedDeals(ctx context.Context, miner address.Address, 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 string) 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

	//piece storage
	GetReadUrl(context.Context, string) (string, error)               //perm:read
	GetWriteUrl(ctx context.Context, resource string) (string, error) //perm:read

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

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"`
		AssignUnPackedDeals                    func(ctx context.Context, miner address.Address, 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:"write"`
		DagstoreInitializeShard                func(ctx context.Context, key string) error                                                                                                                                                         `perm:"write"`
		DagstoreListShards                     func(ctx context.Context) ([]market.DagstoreShardInfo, error)                                                                                                                                       `perm:"read"`
		DagstoreRecoverShard                   func(ctx context.Context, key string) error                                                                                                                                                         `perm:"write"`
		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"`
		GetReadUrl                             func(context.Context, string) (string, error)                                                                                                                                                       `perm:"read"`
		GetUnPackedDeals                       func(ctx context.Context, miner address.Address, spec *market.GetDealSpec) ([]*market.DealInfoIncludePath, error)                                                                                   `perm:"read"`
		GetWriteUrl                            func(ctx context.Context, resource string) (string, error)                                                                                                                                          `perm:"read"`
		ID                                     func(context.Context) (peer.ID, error)                                                                                                                                                              `perm:"read"`
		ImportV1Data                           func(ctx context.Context, src string) error                                                                                                                                                         `perm:"write"`
		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"`
		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"`
		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"`
		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 string) error                                                                                                       `perm:"write"`
		UpdateStorageDealStatus                func(ctx context.Context, dealProposalCid cid.Cid, state storagemarket.StorageDealStatus, pieceState string) error                                                                                  `perm:"write"`
	}
}

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) AssignUnPackedDeals 

func (s *IMarketStruct) AssignUnPackedDeals(p0 context.Context, p1 address.Address, 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) 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) GetReadUrl 

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

func (*IMarketStruct) GetUnPackedDeals 

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

func (*IMarketStruct) GetWriteUrl 

func (s *IMarketStruct) GetWriteUrl(p0 context.Context, p1 string) (string, 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) 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) 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) 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) 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 string) error

func (*IMarketStruct) UpdateStorageDealStatus 

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

Source Files

View all Source files

Directories

Path Synopsis
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.
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

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