market

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 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 storagemarket.MinerDeal, error)                                                                                                                           //perm:read
	MarketListIncompleteDeals(ctx context.Context, mAddr address.Address) ([]storagemarket.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) 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 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 storagemarket.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) ([]storagemarket.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) 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 storagemarket.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) ([]storagemarket.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) 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.

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.