From e4269a83c9e0ee0e99b9bee0e0f85a9fb540850a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=80=E9=A1=B5=E7=B4=A0=E4=B9=A6?= <2931107265@qq.com> Date: Wed, 16 Nov 2022 14:49:17 +0800 Subject: [PATCH] feat: expand market api for self-config --- venus-shared/api/market/api.go | 51 ++- venus-shared/api/market/method.md | 322 +++++++++++++++-- venus-shared/api/market/mock/mock_imarket.go | 343 +++++++++++++++---- venus-shared/api/market/proxy_gen.go | 278 +++++++++------ 4 files changed, 764 insertions(+), 230 deletions(-) diff --git a/venus-shared/api/market/api.go b/venus-shared/api/market/api.go index 7e21ba59d6..b208b15c64 100644 --- a/venus-shared/api/market/api.go +++ b/venus-shared/api/market/api.go @@ -29,7 +29,7 @@ type IMarket interface { 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 + MarketListRetrievalDeals(ctx context.Context) ([]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 @@ -54,25 +54,40 @@ type IMarket interface { 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 + + DealsConsiderOnlineStorageDeals(context.Context, address.Address) (bool, error) //perm:read + DealsSetConsiderOnlineStorageDeals(context.Context, address.Address, bool) error //perm:write + DealsConsiderOnlineRetrievalDeals(context.Context, address.Address) (bool, error) //perm:read + DealsSetConsiderOnlineRetrievalDeals(context.Context, address.Address, bool) error //perm:write + DealsPieceCidBlocklist(context.Context, address.Address) ([]cid.Cid, error) //perm:read + DealsSetPieceCidBlocklist(context.Context, address.Address, []cid.Cid) error //perm:write + DealsConsiderOfflineStorageDeals(context.Context, address.Address) (bool, error) //perm:read + DealsSetConsiderOfflineStorageDeals(context.Context, address.Address, bool) error //perm:write + DealsConsiderOfflineRetrievalDeals(context.Context, address.Address) (bool, error) //perm:read + DealsSetConsiderOfflineRetrievalDeals(context.Context, address.Address, bool) error //perm:write + DealsConsiderVerifiedStorageDeals(context.Context, address.Address) (bool, error) //perm:read + DealsSetConsiderVerifiedStorageDeals(context.Context, address.Address, bool) error //perm:write + DealsConsiderUnverifiedStorageDeals(context.Context, address.Address) (bool, error) //perm:read + DealsSetConsiderUnverifiedStorageDeals(context.Context, address.Address, bool) error //perm:write + // SectorGetExpectedSealDuration gets the time that a newly-created sector // waits for more deals before it starts sealing - SectorGetSealDelay(context.Context) (time.Duration, error) //perm:read + SectorGetExpectedSealDuration(context.Context, address.Address) (time.Duration, error) //perm:read // SectorSetExpectedSealDuration sets the expected time for a sector to seal - SectorSetExpectedSealDuration(context.Context, time.Duration) error //perm:write + SectorSetExpectedSealDuration(context.Context, address.Address, time.Duration) error //perm:write + DealsMaxStartDelay(context.Context, address.Address) (time.Duration, error) //perm:read + DealsSetMaxStartDelay(context.Context, address.Address, time.Duration) error //perm:write + MarketDataTransferPath(context.Context, address.Address) (string, error) //perm:admin + MarketDataSetTransferPath(context.Context, address.Address, string) error //perm:admin + DealsPublishMsgPeriod(context.Context, address.Address) (time.Duration, error) //perm:read + DealsSetPublishMsgPeriod(context.Context, address.Address, time.Duration) error //perm:write + MarketMaxDealsPerPublishMsg(context.Context, address.Address) (uint64, error) //perm:read + MarketSetMaxDealsPerPublishMsg(context.Context, address.Address, uint64) error //perm:write + DealsMaxProviderCollateralMultiplier(context.Context, address.Address) (uint64, error) //perm:read + DealsSetMaxProviderCollateralMultiplier(context.Context, address.Address, uint64) error //perm:write + DealsMaxPublishFee(context.Context, address.Address) (types.FIL, error) //perm:read + DealsSetMaxPublishFee(context.Context, address.Address, types.FIL) error //perm:write + MarketMaxBalanceAddFee(context.Context, address.Address) (types.FIL, error) //perm:read + MarketSetMaxBalanceAddFee(context.Context, address.Address, types.FIL) error //perm:write // messager MessagerWaitMessage(ctx context.Context, mid cid.Cid) (*types.MsgLookup, error) //perm:read diff --git a/venus-shared/api/market/method.md b/venus-shared/api/market/method.md index 559fa9fa93..acd88fce1b 100644 --- a/venus-shared/api/market/method.md +++ b/venus-shared/api/market/method.md @@ -20,14 +20,22 @@ * [DealsConsiderUnverifiedStorageDeals](#dealsconsiderunverifiedstoragedeals) * [DealsConsiderVerifiedStorageDeals](#dealsconsiderverifiedstoragedeals) * [DealsImportData](#dealsimportdata) + * [DealsMaxProviderCollateralMultiplier](#dealsmaxprovidercollateralmultiplier) + * [DealsMaxPublishFee](#dealsmaxpublishfee) + * [DealsMaxStartDelay](#dealsmaxstartdelay) * [DealsPieceCidBlocklist](#dealspiececidblocklist) + * [DealsPublishMsgPeriod](#dealspublishmsgperiod) * [DealsSetConsiderOfflineRetrievalDeals](#dealssetconsiderofflineretrievaldeals) * [DealsSetConsiderOfflineStorageDeals](#dealssetconsiderofflinestoragedeals) * [DealsSetConsiderOnlineRetrievalDeals](#dealssetconsideronlineretrievaldeals) * [DealsSetConsiderOnlineStorageDeals](#dealssetconsideronlinestoragedeals) * [DealsSetConsiderUnverifiedStorageDeals](#dealssetconsiderunverifiedstoragedeals) * [DealsSetConsiderVerifiedStorageDeals](#dealssetconsiderverifiedstoragedeals) + * [DealsSetMaxProviderCollateralMultiplier](#dealssetmaxprovidercollateralmultiplier) + * [DealsSetMaxPublishFee](#dealssetmaxpublishfee) + * [DealsSetMaxStartDelay](#dealssetmaxstartdelay) * [DealsSetPieceCidBlocklist](#dealssetpiececidblocklist) + * [DealsSetPublishMsgPeriod](#dealssetpublishmsgperiod) * [GetDeals](#getdeals) * [GetRetrievalDealStatistic](#getretrievaldealstatistic) * [GetStorageDealStatistic](#getstoragedealstatistic) @@ -39,6 +47,8 @@ * [MarkDealsAsPacking](#markdealsaspacking) * [MarketAddBalance](#marketaddbalance) * [MarketCancelDataTransfer](#marketcanceldatatransfer) + * [MarketDataSetTransferPath](#marketdatasettransferpath) + * [MarketDataTransferPath](#marketdatatransferpath) * [MarketDataTransferUpdates](#marketdatatransferupdates) * [MarketGetAsk](#marketgetask) * [MarketGetDealUpdates](#marketgetdealupdates) @@ -52,12 +62,16 @@ * [MarketListIncompleteDeals](#marketlistincompletedeals) * [MarketListRetrievalAsk](#marketlistretrievalask) * [MarketListRetrievalDeals](#marketlistretrievaldeals) + * [MarketMaxBalanceAddFee](#marketmaxbalanceaddfee) + * [MarketMaxDealsPerPublishMsg](#marketmaxdealsperpublishmsg) * [MarketPendingDeals](#marketpendingdeals) * [MarketPublishPendingDeals](#marketpublishpendingdeals) * [MarketReleaseFunds](#marketreleasefunds) * [MarketReserveFunds](#marketreservefunds) * [MarketRestartDataTransfer](#marketrestartdatatransfer) * [MarketSetAsk](#marketsetask) + * [MarketSetMaxBalanceAddFee](#marketsetmaxbalanceaddfee) + * [MarketSetMaxDealsPerPublishMsg](#marketsetmaxdealsperpublishmsg) * [MarketSetRetrievalAsk](#marketsetretrievalask) * [MarketWithdraw](#marketwithdraw) * [MessagerGetMessage](#messagergetmessage) @@ -72,7 +86,7 @@ * [PiecesListPieces](#pieceslistpieces) * [RemovePieceStorage](#removepiecestorage) * [ResponseMarketEvent](#responsemarketevent) - * [SectorGetSealDelay](#sectorgetsealdelay) + * [SectorGetExpectedSealDuration](#sectorgetexpectedsealduration) * [SectorSetExpectedSealDuration](#sectorsetexpectedsealduration) * [UpdateDealOnPacking](#updatedealonpacking) * [UpdateDealStatus](#updatedealstatus) @@ -373,54 +387,84 @@ Response: `{}` ### DealsConsiderOfflineRetrievalDeals -Perms: admin +Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: `true` ### DealsConsiderOfflineStorageDeals -Perms: admin +Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: `true` ### DealsConsiderOnlineRetrievalDeals -Perms: admin +Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: `true` ### DealsConsiderOnlineStorageDeals -Perms: admin +Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: `true` ### DealsConsiderUnverifiedStorageDeals -Perms: admin +Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: `true` ### DealsConsiderVerifiedStorageDeals -Perms: admin +Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: `true` @@ -441,12 +485,59 @@ Inputs: Response: `{}` +### DealsMaxProviderCollateralMultiplier + + +Perms: read + +Inputs: +```json +[ + "f01234" +] +``` + +Response: `42` + +### DealsMaxPublishFee + + +Perms: read + +Inputs: +```json +[ + "f01234" +] +``` + +Response: `"0 FIL"` + +### DealsMaxStartDelay + + +Perms: read + +Inputs: +```json +[ + "f01234" +] +``` + +Response: `60000000000` + ### DealsPieceCidBlocklist -Perms: admin +Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: ```json @@ -457,14 +548,29 @@ Response: ] ``` +### DealsPublishMsgPeriod + + +Perms: read + +Inputs: +```json +[ + "f01234" +] +``` + +Response: `60000000000` + ### DealsSetConsiderOfflineRetrievalDeals -Perms: admin +Perms: write Inputs: ```json [ + "f01234", true ] ``` @@ -474,11 +580,12 @@ Response: `{}` ### DealsSetConsiderOfflineStorageDeals -Perms: admin +Perms: write Inputs: ```json [ + "f01234", true ] ``` @@ -488,11 +595,12 @@ Response: `{}` ### DealsSetConsiderOnlineRetrievalDeals -Perms: admin +Perms: write Inputs: ```json [ + "f01234", true ] ``` @@ -502,11 +610,12 @@ Response: `{}` ### DealsSetConsiderOnlineStorageDeals -Perms: admin +Perms: write Inputs: ```json [ + "f01234", true ] ``` @@ -516,11 +625,12 @@ Response: `{}` ### DealsSetConsiderUnverifiedStorageDeals -Perms: admin +Perms: write Inputs: ```json [ + "f01234", true ] ``` @@ -530,25 +640,72 @@ Response: `{}` ### DealsSetConsiderVerifiedStorageDeals -Perms: admin +Perms: write Inputs: ```json [ + "f01234", true ] ``` Response: `{}` +### DealsSetMaxProviderCollateralMultiplier + + +Perms: write + +Inputs: +```json +[ + "f01234", + 42 +] +``` + +Response: `{}` + +### DealsSetMaxPublishFee + + +Perms: write + +Inputs: +```json +[ + "f01234", + "0 FIL" +] +``` + +Response: `{}` + +### DealsSetMaxStartDelay + + +Perms: write + +Inputs: +```json +[ + "f01234", + 60000000000 +] +``` + +Response: `{}` + ### DealsSetPieceCidBlocklist -Perms: admin +Perms: write Inputs: ```json [ + "f01234", [ { "/": "bafy2bzacea3wsdh6y3a36tb3skempjoxqpuyompjbmfeyf34fi3uy6uue42v4" @@ -559,6 +716,21 @@ Inputs: Response: `{}` +### DealsSetPublishMsgPeriod + + +Perms: write + +Inputs: +```json +[ + "f01234", + 60000000000 +] +``` + +Response: `{}` + ### GetDeals @@ -850,6 +1022,35 @@ Inputs: Response: `{}` +### MarketDataSetTransferPath + + +Perms: admin + +Inputs: +```json +[ + "f01234", + "string value" +] +``` + +Response: `{}` + +### MarketDataTransferPath + + +Perms: admin + +Inputs: +```json +[ + "f01234" +] +``` + +Response: `"string value"` + ### MarketDataTransferUpdates @@ -1339,12 +1540,7 @@ Response: Perms: read -Inputs: -```json -[ - "f01234" -] -``` +Inputs: `[]` Response: ```json @@ -1384,6 +1580,34 @@ Response: ] ``` +### MarketMaxBalanceAddFee + + +Perms: read + +Inputs: +```json +[ + "f01234" +] +``` + +Response: `"0 FIL"` + +### MarketMaxDealsPerPublishMsg + + +Perms: read + +Inputs: +```json +[ + "f01234" +] +``` + +Response: `42` + ### MarketPendingDeals @@ -1505,6 +1729,36 @@ Inputs: Response: `{}` +### MarketSetMaxBalanceAddFee + + +Perms: write + +Inputs: +```json +[ + "f01234", + "0 FIL" +] +``` + +Response: `{}` + +### MarketSetMaxDealsPerPublishMsg + + +Perms: write + +Inputs: +```json +[ + "f01234", + 42 +] +``` + +Response: `{}` + ### MarketSetRetrievalAsk @@ -1917,14 +2171,19 @@ Inputs: Response: `{}` -### SectorGetSealDelay -SectorGetSealDelay gets the time that a newly-created sector +### SectorGetExpectedSealDuration +SectorGetExpectedSealDuration gets the time that a newly-created sector waits for more deals before it starts sealing Perms: read -Inputs: `[]` +Inputs: +```json +[ + "f01234" +] +``` Response: `60000000000` @@ -1937,6 +2196,7 @@ Perms: write Inputs: ```json [ + "f01234", 60000000000 ] ``` diff --git a/venus-shared/api/market/mock/mock_imarket.go b/venus-shared/api/market/mock/mock_imarket.go index abbf138d27..13465d5ca2 100644 --- a/venus-shared/api/market/mock/mock_imarket.go +++ b/venus-shared/api/market/mock/mock_imarket.go @@ -225,93 +225,93 @@ func (mr *MockIMarketMockRecorder) DagstoreRecoverShard(arg0, arg1 interface{}) } // DealsConsiderOfflineRetrievalDeals mocks base method. -func (m *MockIMarket) DealsConsiderOfflineRetrievalDeals(arg0 context.Context) (bool, error) { +func (m *MockIMarket) DealsConsiderOfflineRetrievalDeals(arg0 context.Context, arg1 address.Address) (bool, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsConsiderOfflineRetrievalDeals", arg0) + ret := m.ctrl.Call(m, "DealsConsiderOfflineRetrievalDeals", arg0, arg1) ret0, _ := ret[0].(bool) ret1, _ := ret[1].(error) return ret0, ret1 } // DealsConsiderOfflineRetrievalDeals indicates an expected call of DealsConsiderOfflineRetrievalDeals. -func (mr *MockIMarketMockRecorder) DealsConsiderOfflineRetrievalDeals(arg0 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsConsiderOfflineRetrievalDeals(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOfflineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOfflineRetrievalDeals), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOfflineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOfflineRetrievalDeals), arg0, arg1) } // DealsConsiderOfflineStorageDeals mocks base method. -func (m *MockIMarket) DealsConsiderOfflineStorageDeals(arg0 context.Context) (bool, error) { +func (m *MockIMarket) DealsConsiderOfflineStorageDeals(arg0 context.Context, arg1 address.Address) (bool, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsConsiderOfflineStorageDeals", arg0) + ret := m.ctrl.Call(m, "DealsConsiderOfflineStorageDeals", arg0, arg1) ret0, _ := ret[0].(bool) ret1, _ := ret[1].(error) return ret0, ret1 } // DealsConsiderOfflineStorageDeals indicates an expected call of DealsConsiderOfflineStorageDeals. -func (mr *MockIMarketMockRecorder) DealsConsiderOfflineStorageDeals(arg0 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsConsiderOfflineStorageDeals(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOfflineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOfflineStorageDeals), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOfflineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOfflineStorageDeals), arg0, arg1) } // DealsConsiderOnlineRetrievalDeals mocks base method. -func (m *MockIMarket) DealsConsiderOnlineRetrievalDeals(arg0 context.Context) (bool, error) { +func (m *MockIMarket) DealsConsiderOnlineRetrievalDeals(arg0 context.Context, arg1 address.Address) (bool, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsConsiderOnlineRetrievalDeals", arg0) + ret := m.ctrl.Call(m, "DealsConsiderOnlineRetrievalDeals", arg0, arg1) ret0, _ := ret[0].(bool) ret1, _ := ret[1].(error) return ret0, ret1 } // DealsConsiderOnlineRetrievalDeals indicates an expected call of DealsConsiderOnlineRetrievalDeals. -func (mr *MockIMarketMockRecorder) DealsConsiderOnlineRetrievalDeals(arg0 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsConsiderOnlineRetrievalDeals(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOnlineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOnlineRetrievalDeals), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOnlineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOnlineRetrievalDeals), arg0, arg1) } // DealsConsiderOnlineStorageDeals mocks base method. -func (m *MockIMarket) DealsConsiderOnlineStorageDeals(arg0 context.Context) (bool, error) { +func (m *MockIMarket) DealsConsiderOnlineStorageDeals(arg0 context.Context, arg1 address.Address) (bool, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsConsiderOnlineStorageDeals", arg0) + ret := m.ctrl.Call(m, "DealsConsiderOnlineStorageDeals", arg0, arg1) ret0, _ := ret[0].(bool) ret1, _ := ret[1].(error) return ret0, ret1 } // DealsConsiderOnlineStorageDeals indicates an expected call of DealsConsiderOnlineStorageDeals. -func (mr *MockIMarketMockRecorder) DealsConsiderOnlineStorageDeals(arg0 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsConsiderOnlineStorageDeals(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOnlineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOnlineStorageDeals), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderOnlineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderOnlineStorageDeals), arg0, arg1) } // DealsConsiderUnverifiedStorageDeals mocks base method. -func (m *MockIMarket) DealsConsiderUnverifiedStorageDeals(arg0 context.Context) (bool, error) { +func (m *MockIMarket) DealsConsiderUnverifiedStorageDeals(arg0 context.Context, arg1 address.Address) (bool, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsConsiderUnverifiedStorageDeals", arg0) + ret := m.ctrl.Call(m, "DealsConsiderUnverifiedStorageDeals", arg0, arg1) ret0, _ := ret[0].(bool) ret1, _ := ret[1].(error) return ret0, ret1 } // DealsConsiderUnverifiedStorageDeals indicates an expected call of DealsConsiderUnverifiedStorageDeals. -func (mr *MockIMarketMockRecorder) DealsConsiderUnverifiedStorageDeals(arg0 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsConsiderUnverifiedStorageDeals(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderUnverifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderUnverifiedStorageDeals), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderUnverifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderUnverifiedStorageDeals), arg0, arg1) } // DealsConsiderVerifiedStorageDeals mocks base method. -func (m *MockIMarket) DealsConsiderVerifiedStorageDeals(arg0 context.Context) (bool, error) { +func (m *MockIMarket) DealsConsiderVerifiedStorageDeals(arg0 context.Context, arg1 address.Address) (bool, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsConsiderVerifiedStorageDeals", arg0) + ret := m.ctrl.Call(m, "DealsConsiderVerifiedStorageDeals", arg0, arg1) ret0, _ := ret[0].(bool) ret1, _ := ret[1].(error) return ret0, ret1 } // DealsConsiderVerifiedStorageDeals indicates an expected call of DealsConsiderVerifiedStorageDeals. -func (mr *MockIMarketMockRecorder) DealsConsiderVerifiedStorageDeals(arg0 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsConsiderVerifiedStorageDeals(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderVerifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderVerifiedStorageDeals), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsConsiderVerifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsConsiderVerifiedStorageDeals), arg0, arg1) } // DealsImportData mocks base method. @@ -328,117 +328,233 @@ func (mr *MockIMarketMockRecorder) DealsImportData(arg0, arg1, arg2 interface{}) return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsImportData", reflect.TypeOf((*MockIMarket)(nil).DealsImportData), arg0, arg1, arg2) } +// DealsMaxProviderCollateralMultiplier mocks base method. +func (m *MockIMarket) DealsMaxProviderCollateralMultiplier(arg0 context.Context, arg1 address.Address) (uint64, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsMaxProviderCollateralMultiplier", arg0, arg1) + ret0, _ := ret[0].(uint64) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// DealsMaxProviderCollateralMultiplier indicates an expected call of DealsMaxProviderCollateralMultiplier. +func (mr *MockIMarketMockRecorder) DealsMaxProviderCollateralMultiplier(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsMaxProviderCollateralMultiplier", reflect.TypeOf((*MockIMarket)(nil).DealsMaxProviderCollateralMultiplier), arg0, arg1) +} + +// DealsMaxPublishFee mocks base method. +func (m *MockIMarket) DealsMaxPublishFee(arg0 context.Context, arg1 address.Address) (internal.FIL, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsMaxPublishFee", arg0, arg1) + ret0, _ := ret[0].(internal.FIL) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// DealsMaxPublishFee indicates an expected call of DealsMaxPublishFee. +func (mr *MockIMarketMockRecorder) DealsMaxPublishFee(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsMaxPublishFee", reflect.TypeOf((*MockIMarket)(nil).DealsMaxPublishFee), arg0, arg1) +} + +// DealsMaxStartDelay mocks base method. +func (m *MockIMarket) DealsMaxStartDelay(arg0 context.Context, arg1 address.Address) (time.Duration, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsMaxStartDelay", arg0, arg1) + ret0, _ := ret[0].(time.Duration) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// DealsMaxStartDelay indicates an expected call of DealsMaxStartDelay. +func (mr *MockIMarketMockRecorder) DealsMaxStartDelay(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsMaxStartDelay", reflect.TypeOf((*MockIMarket)(nil).DealsMaxStartDelay), arg0, arg1) +} + // DealsPieceCidBlocklist mocks base method. -func (m *MockIMarket) DealsPieceCidBlocklist(arg0 context.Context) ([]cid.Cid, error) { +func (m *MockIMarket) DealsPieceCidBlocklist(arg0 context.Context, arg1 address.Address) ([]cid.Cid, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsPieceCidBlocklist", arg0) + ret := m.ctrl.Call(m, "DealsPieceCidBlocklist", arg0, arg1) ret0, _ := ret[0].([]cid.Cid) ret1, _ := ret[1].(error) return ret0, ret1 } // DealsPieceCidBlocklist indicates an expected call of DealsPieceCidBlocklist. -func (mr *MockIMarketMockRecorder) DealsPieceCidBlocklist(arg0 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsPieceCidBlocklist(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsPieceCidBlocklist", reflect.TypeOf((*MockIMarket)(nil).DealsPieceCidBlocklist), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsPieceCidBlocklist", reflect.TypeOf((*MockIMarket)(nil).DealsPieceCidBlocklist), arg0, arg1) +} + +// DealsPublishMsgPeriod mocks base method. +func (m *MockIMarket) DealsPublishMsgPeriod(arg0 context.Context, arg1 address.Address) (time.Duration, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsPublishMsgPeriod", arg0, arg1) + ret0, _ := ret[0].(time.Duration) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// DealsPublishMsgPeriod indicates an expected call of DealsPublishMsgPeriod. +func (mr *MockIMarketMockRecorder) DealsPublishMsgPeriod(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsPublishMsgPeriod", reflect.TypeOf((*MockIMarket)(nil).DealsPublishMsgPeriod), arg0, arg1) } // DealsSetConsiderOfflineRetrievalDeals mocks base method. -func (m *MockIMarket) DealsSetConsiderOfflineRetrievalDeals(arg0 context.Context, arg1 bool) error { +func (m *MockIMarket) DealsSetConsiderOfflineRetrievalDeals(arg0 context.Context, arg1 address.Address, arg2 bool) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsSetConsiderOfflineRetrievalDeals", arg0, arg1) + ret := m.ctrl.Call(m, "DealsSetConsiderOfflineRetrievalDeals", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // DealsSetConsiderOfflineRetrievalDeals indicates an expected call of DealsSetConsiderOfflineRetrievalDeals. -func (mr *MockIMarketMockRecorder) DealsSetConsiderOfflineRetrievalDeals(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsSetConsiderOfflineRetrievalDeals(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOfflineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOfflineRetrievalDeals), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOfflineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOfflineRetrievalDeals), arg0, arg1, arg2) } // DealsSetConsiderOfflineStorageDeals mocks base method. -func (m *MockIMarket) DealsSetConsiderOfflineStorageDeals(arg0 context.Context, arg1 bool) error { +func (m *MockIMarket) DealsSetConsiderOfflineStorageDeals(arg0 context.Context, arg1 address.Address, arg2 bool) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsSetConsiderOfflineStorageDeals", arg0, arg1) + ret := m.ctrl.Call(m, "DealsSetConsiderOfflineStorageDeals", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // DealsSetConsiderOfflineStorageDeals indicates an expected call of DealsSetConsiderOfflineStorageDeals. -func (mr *MockIMarketMockRecorder) DealsSetConsiderOfflineStorageDeals(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsSetConsiderOfflineStorageDeals(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOfflineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOfflineStorageDeals), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOfflineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOfflineStorageDeals), arg0, arg1, arg2) } // DealsSetConsiderOnlineRetrievalDeals mocks base method. -func (m *MockIMarket) DealsSetConsiderOnlineRetrievalDeals(arg0 context.Context, arg1 bool) error { +func (m *MockIMarket) DealsSetConsiderOnlineRetrievalDeals(arg0 context.Context, arg1 address.Address, arg2 bool) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsSetConsiderOnlineRetrievalDeals", arg0, arg1) + ret := m.ctrl.Call(m, "DealsSetConsiderOnlineRetrievalDeals", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // DealsSetConsiderOnlineRetrievalDeals indicates an expected call of DealsSetConsiderOnlineRetrievalDeals. -func (mr *MockIMarketMockRecorder) DealsSetConsiderOnlineRetrievalDeals(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsSetConsiderOnlineRetrievalDeals(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOnlineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOnlineRetrievalDeals), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOnlineRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOnlineRetrievalDeals), arg0, arg1, arg2) } // DealsSetConsiderOnlineStorageDeals mocks base method. -func (m *MockIMarket) DealsSetConsiderOnlineStorageDeals(arg0 context.Context, arg1 bool) error { +func (m *MockIMarket) DealsSetConsiderOnlineStorageDeals(arg0 context.Context, arg1 address.Address, arg2 bool) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsSetConsiderOnlineStorageDeals", arg0, arg1) + ret := m.ctrl.Call(m, "DealsSetConsiderOnlineStorageDeals", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // DealsSetConsiderOnlineStorageDeals indicates an expected call of DealsSetConsiderOnlineStorageDeals. -func (mr *MockIMarketMockRecorder) DealsSetConsiderOnlineStorageDeals(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsSetConsiderOnlineStorageDeals(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOnlineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOnlineStorageDeals), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderOnlineStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderOnlineStorageDeals), arg0, arg1, arg2) } // DealsSetConsiderUnverifiedStorageDeals mocks base method. -func (m *MockIMarket) DealsSetConsiderUnverifiedStorageDeals(arg0 context.Context, arg1 bool) error { +func (m *MockIMarket) DealsSetConsiderUnverifiedStorageDeals(arg0 context.Context, arg1 address.Address, arg2 bool) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsSetConsiderUnverifiedStorageDeals", arg0, arg1) + ret := m.ctrl.Call(m, "DealsSetConsiderUnverifiedStorageDeals", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // DealsSetConsiderUnverifiedStorageDeals indicates an expected call of DealsSetConsiderUnverifiedStorageDeals. -func (mr *MockIMarketMockRecorder) DealsSetConsiderUnverifiedStorageDeals(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsSetConsiderUnverifiedStorageDeals(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderUnverifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderUnverifiedStorageDeals), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderUnverifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderUnverifiedStorageDeals), arg0, arg1, arg2) } // DealsSetConsiderVerifiedStorageDeals mocks base method. -func (m *MockIMarket) DealsSetConsiderVerifiedStorageDeals(arg0 context.Context, arg1 bool) error { +func (m *MockIMarket) DealsSetConsiderVerifiedStorageDeals(arg0 context.Context, arg1 address.Address, arg2 bool) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsSetConsiderVerifiedStorageDeals", arg0, arg1) + ret := m.ctrl.Call(m, "DealsSetConsiderVerifiedStorageDeals", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // DealsSetConsiderVerifiedStorageDeals indicates an expected call of DealsSetConsiderVerifiedStorageDeals. -func (mr *MockIMarketMockRecorder) DealsSetConsiderVerifiedStorageDeals(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsSetConsiderVerifiedStorageDeals(arg0, arg1, arg2 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderVerifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderVerifiedStorageDeals), arg0, arg1, arg2) +} + +// DealsSetMaxProviderCollateralMultiplier mocks base method. +func (m *MockIMarket) DealsSetMaxProviderCollateralMultiplier(arg0 context.Context, arg1 address.Address, arg2 uint64) error { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsSetMaxProviderCollateralMultiplier", arg0, arg1, arg2) + ret0, _ := ret[0].(error) + return ret0 +} + +// DealsSetMaxProviderCollateralMultiplier indicates an expected call of DealsSetMaxProviderCollateralMultiplier. +func (mr *MockIMarketMockRecorder) DealsSetMaxProviderCollateralMultiplier(arg0, arg1, arg2 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetMaxProviderCollateralMultiplier", reflect.TypeOf((*MockIMarket)(nil).DealsSetMaxProviderCollateralMultiplier), arg0, arg1, arg2) +} + +// DealsSetMaxPublishFee mocks base method. +func (m *MockIMarket) DealsSetMaxPublishFee(arg0 context.Context, arg1 address.Address, arg2 internal.FIL) error { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsSetMaxPublishFee", arg0, arg1, arg2) + ret0, _ := ret[0].(error) + return ret0 +} + +// DealsSetMaxPublishFee indicates an expected call of DealsSetMaxPublishFee. +func (mr *MockIMarketMockRecorder) DealsSetMaxPublishFee(arg0, arg1, arg2 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetMaxPublishFee", reflect.TypeOf((*MockIMarket)(nil).DealsSetMaxPublishFee), arg0, arg1, arg2) +} + +// DealsSetMaxStartDelay mocks base method. +func (m *MockIMarket) DealsSetMaxStartDelay(arg0 context.Context, arg1 address.Address, arg2 time.Duration) error { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsSetMaxStartDelay", arg0, arg1, arg2) + ret0, _ := ret[0].(error) + return ret0 +} + +// DealsSetMaxStartDelay indicates an expected call of DealsSetMaxStartDelay. +func (mr *MockIMarketMockRecorder) DealsSetMaxStartDelay(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetConsiderVerifiedStorageDeals", reflect.TypeOf((*MockIMarket)(nil).DealsSetConsiderVerifiedStorageDeals), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetMaxStartDelay", reflect.TypeOf((*MockIMarket)(nil).DealsSetMaxStartDelay), arg0, arg1, arg2) } // DealsSetPieceCidBlocklist mocks base method. -func (m *MockIMarket) DealsSetPieceCidBlocklist(arg0 context.Context, arg1 []cid.Cid) error { +func (m *MockIMarket) DealsSetPieceCidBlocklist(arg0 context.Context, arg1 address.Address, arg2 []cid.Cid) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "DealsSetPieceCidBlocklist", arg0, arg1) + ret := m.ctrl.Call(m, "DealsSetPieceCidBlocklist", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // DealsSetPieceCidBlocklist indicates an expected call of DealsSetPieceCidBlocklist. -func (mr *MockIMarketMockRecorder) DealsSetPieceCidBlocklist(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) DealsSetPieceCidBlocklist(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetPieceCidBlocklist", reflect.TypeOf((*MockIMarket)(nil).DealsSetPieceCidBlocklist), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetPieceCidBlocklist", reflect.TypeOf((*MockIMarket)(nil).DealsSetPieceCidBlocklist), arg0, arg1, arg2) +} + +// DealsSetPublishMsgPeriod mocks base method. +func (m *MockIMarket) DealsSetPublishMsgPeriod(arg0 context.Context, arg1 address.Address, arg2 time.Duration) error { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "DealsSetPublishMsgPeriod", arg0, arg1, arg2) + ret0, _ := ret[0].(error) + return ret0 +} + +// DealsSetPublishMsgPeriod indicates an expected call of DealsSetPublishMsgPeriod. +func (mr *MockIMarketMockRecorder) DealsSetPublishMsgPeriod(arg0, arg1, arg2 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DealsSetPublishMsgPeriod", reflect.TypeOf((*MockIMarket)(nil).DealsSetPublishMsgPeriod), arg0, arg1, arg2) } // GetDeals mocks base method. @@ -602,6 +718,35 @@ func (mr *MockIMarketMockRecorder) MarketCancelDataTransfer(arg0, arg1, arg2, ar return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketCancelDataTransfer", reflect.TypeOf((*MockIMarket)(nil).MarketCancelDataTransfer), arg0, arg1, arg2, arg3) } +// MarketDataSetTransferPath mocks base method. +func (m *MockIMarket) MarketDataSetTransferPath(arg0 context.Context, arg1 address.Address, arg2 string) error { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "MarketDataSetTransferPath", arg0, arg1, arg2) + ret0, _ := ret[0].(error) + return ret0 +} + +// MarketDataSetTransferPath indicates an expected call of MarketDataSetTransferPath. +func (mr *MockIMarketMockRecorder) MarketDataSetTransferPath(arg0, arg1, arg2 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketDataSetTransferPath", reflect.TypeOf((*MockIMarket)(nil).MarketDataSetTransferPath), arg0, arg1, arg2) +} + +// MarketDataTransferPath mocks base method. +func (m *MockIMarket) MarketDataTransferPath(arg0 context.Context, arg1 address.Address) (string, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "MarketDataTransferPath", arg0, arg1) + ret0, _ := ret[0].(string) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// MarketDataTransferPath indicates an expected call of MarketDataTransferPath. +func (mr *MockIMarketMockRecorder) MarketDataTransferPath(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketDataTransferPath", reflect.TypeOf((*MockIMarket)(nil).MarketDataTransferPath), arg0, arg1) +} + // MarketDataTransferUpdates mocks base method. func (m *MockIMarket) MarketDataTransferUpdates(arg0 context.Context) (<-chan market.DataTransferChannel, error) { m.ctrl.T.Helper() @@ -781,18 +926,48 @@ func (mr *MockIMarketMockRecorder) MarketListRetrievalAsk(arg0 interface{}) *gom } // MarketListRetrievalDeals mocks base method. -func (m *MockIMarket) MarketListRetrievalDeals(arg0 context.Context, arg1 address.Address) ([]market.ProviderDealState, error) { +func (m *MockIMarket) MarketListRetrievalDeals(arg0 context.Context) ([]market.ProviderDealState, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "MarketListRetrievalDeals", arg0, arg1) + ret := m.ctrl.Call(m, "MarketListRetrievalDeals", arg0) ret0, _ := ret[0].([]market.ProviderDealState) ret1, _ := ret[1].(error) return ret0, ret1 } // MarketListRetrievalDeals indicates an expected call of MarketListRetrievalDeals. -func (mr *MockIMarketMockRecorder) MarketListRetrievalDeals(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) MarketListRetrievalDeals(arg0 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketListRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).MarketListRetrievalDeals), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketListRetrievalDeals", reflect.TypeOf((*MockIMarket)(nil).MarketListRetrievalDeals), arg0) +} + +// MarketMaxBalanceAddFee mocks base method. +func (m *MockIMarket) MarketMaxBalanceAddFee(arg0 context.Context, arg1 address.Address) (internal.FIL, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "MarketMaxBalanceAddFee", arg0, arg1) + ret0, _ := ret[0].(internal.FIL) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// MarketMaxBalanceAddFee indicates an expected call of MarketMaxBalanceAddFee. +func (mr *MockIMarketMockRecorder) MarketMaxBalanceAddFee(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketMaxBalanceAddFee", reflect.TypeOf((*MockIMarket)(nil).MarketMaxBalanceAddFee), arg0, arg1) +} + +// MarketMaxDealsPerPublishMsg mocks base method. +func (m *MockIMarket) MarketMaxDealsPerPublishMsg(arg0 context.Context, arg1 address.Address) (uint64, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "MarketMaxDealsPerPublishMsg", arg0, arg1) + ret0, _ := ret[0].(uint64) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// MarketMaxDealsPerPublishMsg indicates an expected call of MarketMaxDealsPerPublishMsg. +func (mr *MockIMarketMockRecorder) MarketMaxDealsPerPublishMsg(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketMaxDealsPerPublishMsg", reflect.TypeOf((*MockIMarket)(nil).MarketMaxDealsPerPublishMsg), arg0, arg1) } // MarketPendingDeals mocks base method. @@ -881,6 +1056,34 @@ func (mr *MockIMarketMockRecorder) MarketSetAsk(arg0, arg1, arg2, arg3, arg4, ar return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketSetAsk", reflect.TypeOf((*MockIMarket)(nil).MarketSetAsk), arg0, arg1, arg2, arg3, arg4, arg5, arg6) } +// MarketSetMaxBalanceAddFee mocks base method. +func (m *MockIMarket) MarketSetMaxBalanceAddFee(arg0 context.Context, arg1 address.Address, arg2 internal.FIL) error { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "MarketSetMaxBalanceAddFee", arg0, arg1, arg2) + ret0, _ := ret[0].(error) + return ret0 +} + +// MarketSetMaxBalanceAddFee indicates an expected call of MarketSetMaxBalanceAddFee. +func (mr *MockIMarketMockRecorder) MarketSetMaxBalanceAddFee(arg0, arg1, arg2 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketSetMaxBalanceAddFee", reflect.TypeOf((*MockIMarket)(nil).MarketSetMaxBalanceAddFee), arg0, arg1, arg2) +} + +// MarketSetMaxDealsPerPublishMsg mocks base method. +func (m *MockIMarket) MarketSetMaxDealsPerPublishMsg(arg0 context.Context, arg1 address.Address, arg2 uint64) error { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "MarketSetMaxDealsPerPublishMsg", arg0, arg1, arg2) + ret0, _ := ret[0].(error) + return ret0 +} + +// MarketSetMaxDealsPerPublishMsg indicates an expected call of MarketSetMaxDealsPerPublishMsg. +func (mr *MockIMarketMockRecorder) MarketSetMaxDealsPerPublishMsg(arg0, arg1, arg2 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarketSetMaxDealsPerPublishMsg", reflect.TypeOf((*MockIMarket)(nil).MarketSetMaxDealsPerPublishMsg), arg0, arg1, arg2) +} + // MarketSetRetrievalAsk mocks base method. func (m *MockIMarket) MarketSetRetrievalAsk(arg0 context.Context, arg1 address.Address, arg2 *retrievalmarket.Ask) error { m.ctrl.T.Helper() @@ -1087,33 +1290,33 @@ func (mr *MockIMarketMockRecorder) ResponseMarketEvent(arg0, arg1 interface{}) * return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResponseMarketEvent", reflect.TypeOf((*MockIMarket)(nil).ResponseMarketEvent), arg0, arg1) } -// SectorGetSealDelay mocks base method. -func (m *MockIMarket) SectorGetSealDelay(arg0 context.Context) (time.Duration, error) { +// SectorGetExpectedSealDuration mocks base method. +func (m *MockIMarket) SectorGetExpectedSealDuration(arg0 context.Context, arg1 address.Address) (time.Duration, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "SectorGetSealDelay", arg0) + ret := m.ctrl.Call(m, "SectorGetExpectedSealDuration", arg0, arg1) ret0, _ := ret[0].(time.Duration) ret1, _ := ret[1].(error) return ret0, ret1 } -// SectorGetSealDelay indicates an expected call of SectorGetSealDelay. -func (mr *MockIMarketMockRecorder) SectorGetSealDelay(arg0 interface{}) *gomock.Call { +// SectorGetExpectedSealDuration indicates an expected call of SectorGetExpectedSealDuration. +func (mr *MockIMarketMockRecorder) SectorGetExpectedSealDuration(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SectorGetSealDelay", reflect.TypeOf((*MockIMarket)(nil).SectorGetSealDelay), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SectorGetExpectedSealDuration", reflect.TypeOf((*MockIMarket)(nil).SectorGetExpectedSealDuration), arg0, arg1) } // SectorSetExpectedSealDuration mocks base method. -func (m *MockIMarket) SectorSetExpectedSealDuration(arg0 context.Context, arg1 time.Duration) error { +func (m *MockIMarket) SectorSetExpectedSealDuration(arg0 context.Context, arg1 address.Address, arg2 time.Duration) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "SectorSetExpectedSealDuration", arg0, arg1) + ret := m.ctrl.Call(m, "SectorSetExpectedSealDuration", arg0, arg1, arg2) ret0, _ := ret[0].(error) return ret0 } // SectorSetExpectedSealDuration indicates an expected call of SectorSetExpectedSealDuration. -func (mr *MockIMarketMockRecorder) SectorSetExpectedSealDuration(arg0, arg1 interface{}) *gomock.Call { +func (mr *MockIMarketMockRecorder) SectorSetExpectedSealDuration(arg0, arg1, arg2 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SectorSetExpectedSealDuration", reflect.TypeOf((*MockIMarket)(nil).SectorSetExpectedSealDuration), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SectorSetExpectedSealDuration", reflect.TypeOf((*MockIMarket)(nil).SectorSetExpectedSealDuration), arg0, arg1, arg2) } // UpdateDealOnPacking mocks base method. diff --git a/venus-shared/api/market/proxy_gen.go b/venus-shared/api/market/proxy_gen.go index 2936595a5e..8f381cf5d8 100644 --- a/venus-shared/api/market/proxy_gen.go +++ b/venus-shared/api/market/proxy_gen.go @@ -22,83 +22,97 @@ import ( 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) (*market.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) ([]*market.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"` + 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, address.Address) (bool, error) `perm:"read"` + DealsConsiderOfflineStorageDeals func(context.Context, address.Address) (bool, error) `perm:"read"` + DealsConsiderOnlineRetrievalDeals func(context.Context, address.Address) (bool, error) `perm:"read"` + DealsConsiderOnlineStorageDeals func(context.Context, address.Address) (bool, error) `perm:"read"` + DealsConsiderUnverifiedStorageDeals func(context.Context, address.Address) (bool, error) `perm:"read"` + DealsConsiderVerifiedStorageDeals func(context.Context, address.Address) (bool, error) `perm:"read"` + DealsImportData func(ctx context.Context, dealPropCid cid.Cid, file string) error `perm:"admin"` + DealsMaxProviderCollateralMultiplier func(context.Context, address.Address) (uint64, error) `perm:"read"` + DealsMaxPublishFee func(context.Context, address.Address) (types.FIL, error) `perm:"read"` + DealsMaxStartDelay func(context.Context, address.Address) (time.Duration, error) `perm:"read"` + DealsPieceCidBlocklist func(context.Context, address.Address) ([]cid.Cid, error) `perm:"read"` + DealsPublishMsgPeriod func(context.Context, address.Address) (time.Duration, error) `perm:"read"` + DealsSetConsiderOfflineRetrievalDeals func(context.Context, address.Address, bool) error `perm:"write"` + DealsSetConsiderOfflineStorageDeals func(context.Context, address.Address, bool) error `perm:"write"` + DealsSetConsiderOnlineRetrievalDeals func(context.Context, address.Address, bool) error `perm:"write"` + DealsSetConsiderOnlineStorageDeals func(context.Context, address.Address, bool) error `perm:"write"` + DealsSetConsiderUnverifiedStorageDeals func(context.Context, address.Address, bool) error `perm:"write"` + DealsSetConsiderVerifiedStorageDeals func(context.Context, address.Address, bool) error `perm:"write"` + DealsSetMaxProviderCollateralMultiplier func(context.Context, address.Address, uint64) error `perm:"write"` + DealsSetMaxPublishFee func(context.Context, address.Address, types.FIL) error `perm:"write"` + DealsSetMaxStartDelay func(context.Context, address.Address, time.Duration) error `perm:"write"` + DealsSetPieceCidBlocklist func(context.Context, address.Address, []cid.Cid) error `perm:"write"` + DealsSetPublishMsgPeriod func(context.Context, address.Address, time.Duration) error `perm:"write"` + GetDeals func(ctx context.Context, miner address.Address, pageIndex, pageSize int) ([]*market.DealInfo, error) `perm:"read"` + GetRetrievalDealStatistic func(ctx context.Context, miner address.Address) (*market.RetrievalDealStatistic, error) `perm:"read"` + GetStorageDealStatistic func(ctx context.Context, miner address.Address) (*market.StorageDealStatistic, error) `perm:"read"` + GetUnPackedDeals func(ctx context.Context, miner address.Address, spec *market.GetDealSpec) ([]*market.DealInfoIncludePath, error) `perm:"read"` + ID func(context.Context) (peer.ID, error) `perm:"read"` + 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"` + MarketDataSetTransferPath func(context.Context, address.Address, string) error `perm:"admin"` + MarketDataTransferPath func(context.Context, address.Address) (string, error) `perm:"admin"` + MarketDataTransferUpdates func(ctx context.Context) (<-chan market.DataTransferChannel, error) `perm:"write"` + MarketGetAsk func(ctx context.Context, mAddr address.Address) (*market.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) ([]*market.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) ([]market.ProviderDealState, error) `perm:"read"` + MarketMaxBalanceAddFee func(context.Context, address.Address) (types.FIL, error) `perm:"read"` + MarketMaxDealsPerPublishMsg func(context.Context, address.Address) (uint64, error) `perm:"read"` + MarketPendingDeals func(ctx context.Context) ([]market.PendingDealInfo, error) `perm:"write"` + MarketPublishPendingDeals func(ctx context.Context) error `perm:"admin"` + MarketReleaseFunds func(ctx context.Context, addr address.Address, amt types.BigInt) error `perm:"sign"` + MarketReserveFunds func(ctx context.Context, wallet address.Address, addr address.Address, amt types.BigInt) (cid.Cid, error) `perm:"sign"` + MarketRestartDataTransfer func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error `perm:"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"` + MarketSetMaxBalanceAddFee func(context.Context, address.Address, types.FIL) error `perm:"write"` + MarketSetMaxDealsPerPublishMsg func(context.Context, address.Address, uint64) error `perm:"write"` + MarketSetRetrievalAsk func(ctx context.Context, mAddr address.Address, rask *retrievalmarket.Ask) error `perm:"admin"` + MarketWithdraw func(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, error) `perm:"sign"` + MessagerGetMessage func(ctx context.Context, mid cid.Cid) (*types.Message, error) `perm:"read"` + MessagerPushMessage func(ctx context.Context, msg *types.Message, meta *types.MessageSendSpec) (cid.Cid, error) `perm:"write"` + MessagerWaitMessage func(ctx context.Context, mid cid.Cid) (*types.MsgLookup, error) `perm:"read"` + NetAddrsListen func(context.Context) (peer.AddrInfo, error) `perm:"read"` + 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"` + SectorGetExpectedSealDuration func(context.Context, address.Address) (time.Duration, error) `perm:"read"` + SectorSetExpectedSealDuration func(context.Context, address.Address, time.Duration) error `perm:"write"` + UpdateDealOnPacking func(ctx context.Context, miner address.Address, dealID abi.DealID, sectorid abi.SectorNumber, offset abi.PaddedPieceSize) error `perm:"write"` + UpdateDealStatus func(ctx context.Context, miner address.Address, dealID abi.DealID, pieceStatus market.PieceStatus) error `perm:"write"` + UpdateStorageDealStatus func(ctx context.Context, dealProposalCid cid.Cid, state storagemarket.StorageDealStatus, pieceState market.PieceStatus) error `perm:"write"` + Version func(ctx context.Context) (types.Version, error) `perm:"read"` } } @@ -138,50 +152,74 @@ func (s *IMarketStruct) DagstoreListShards(p0 context.Context) ([]market.Dagstor func (s *IMarketStruct) DagstoreRecoverShard(p0 context.Context, p1 string) error { return s.Internal.DagstoreRecoverShard(p0, p1) } -func (s *IMarketStruct) DealsConsiderOfflineRetrievalDeals(p0 context.Context) (bool, error) { - return s.Internal.DealsConsiderOfflineRetrievalDeals(p0) +func (s *IMarketStruct) DealsConsiderOfflineRetrievalDeals(p0 context.Context, p1 address.Address) (bool, error) { + return s.Internal.DealsConsiderOfflineRetrievalDeals(p0, p1) } -func (s *IMarketStruct) DealsConsiderOfflineStorageDeals(p0 context.Context) (bool, error) { - return s.Internal.DealsConsiderOfflineStorageDeals(p0) +func (s *IMarketStruct) DealsConsiderOfflineStorageDeals(p0 context.Context, p1 address.Address) (bool, error) { + return s.Internal.DealsConsiderOfflineStorageDeals(p0, p1) } -func (s *IMarketStruct) DealsConsiderOnlineRetrievalDeals(p0 context.Context) (bool, error) { - return s.Internal.DealsConsiderOnlineRetrievalDeals(p0) +func (s *IMarketStruct) DealsConsiderOnlineRetrievalDeals(p0 context.Context, p1 address.Address) (bool, error) { + return s.Internal.DealsConsiderOnlineRetrievalDeals(p0, p1) } -func (s *IMarketStruct) DealsConsiderOnlineStorageDeals(p0 context.Context) (bool, error) { - return s.Internal.DealsConsiderOnlineStorageDeals(p0) +func (s *IMarketStruct) DealsConsiderOnlineStorageDeals(p0 context.Context, p1 address.Address) (bool, error) { + return s.Internal.DealsConsiderOnlineStorageDeals(p0, p1) } -func (s *IMarketStruct) DealsConsiderUnverifiedStorageDeals(p0 context.Context) (bool, error) { - return s.Internal.DealsConsiderUnverifiedStorageDeals(p0) +func (s *IMarketStruct) DealsConsiderUnverifiedStorageDeals(p0 context.Context, p1 address.Address) (bool, error) { + return s.Internal.DealsConsiderUnverifiedStorageDeals(p0, p1) } -func (s *IMarketStruct) DealsConsiderVerifiedStorageDeals(p0 context.Context) (bool, error) { - return s.Internal.DealsConsiderVerifiedStorageDeals(p0) +func (s *IMarketStruct) DealsConsiderVerifiedStorageDeals(p0 context.Context, p1 address.Address) (bool, error) { + return s.Internal.DealsConsiderVerifiedStorageDeals(p0, p1) } func (s *IMarketStruct) DealsImportData(p0 context.Context, p1 cid.Cid, p2 string) error { return s.Internal.DealsImportData(p0, p1, p2) } -func (s *IMarketStruct) DealsPieceCidBlocklist(p0 context.Context) ([]cid.Cid, error) { - return s.Internal.DealsPieceCidBlocklist(p0) +func (s *IMarketStruct) DealsMaxProviderCollateralMultiplier(p0 context.Context, p1 address.Address) (uint64, error) { + return s.Internal.DealsMaxProviderCollateralMultiplier(p0, p1) } -func (s *IMarketStruct) DealsSetConsiderOfflineRetrievalDeals(p0 context.Context, p1 bool) error { - return s.Internal.DealsSetConsiderOfflineRetrievalDeals(p0, p1) +func (s *IMarketStruct) DealsMaxPublishFee(p0 context.Context, p1 address.Address) (types.FIL, error) { + return s.Internal.DealsMaxPublishFee(p0, p1) } -func (s *IMarketStruct) DealsSetConsiderOfflineStorageDeals(p0 context.Context, p1 bool) error { - return s.Internal.DealsSetConsiderOfflineStorageDeals(p0, p1) +func (s *IMarketStruct) DealsMaxStartDelay(p0 context.Context, p1 address.Address) (time.Duration, error) { + return s.Internal.DealsMaxStartDelay(p0, p1) } -func (s *IMarketStruct) DealsSetConsiderOnlineRetrievalDeals(p0 context.Context, p1 bool) error { - return s.Internal.DealsSetConsiderOnlineRetrievalDeals(p0, p1) +func (s *IMarketStruct) DealsPieceCidBlocklist(p0 context.Context, p1 address.Address) ([]cid.Cid, error) { + return s.Internal.DealsPieceCidBlocklist(p0, p1) } -func (s *IMarketStruct) DealsSetConsiderOnlineStorageDeals(p0 context.Context, p1 bool) error { - return s.Internal.DealsSetConsiderOnlineStorageDeals(p0, p1) +func (s *IMarketStruct) DealsPublishMsgPeriod(p0 context.Context, p1 address.Address) (time.Duration, error) { + return s.Internal.DealsPublishMsgPeriod(p0, p1) } -func (s *IMarketStruct) DealsSetConsiderUnverifiedStorageDeals(p0 context.Context, p1 bool) error { - return s.Internal.DealsSetConsiderUnverifiedStorageDeals(p0, p1) +func (s *IMarketStruct) DealsSetConsiderOfflineRetrievalDeals(p0 context.Context, p1 address.Address, p2 bool) error { + return s.Internal.DealsSetConsiderOfflineRetrievalDeals(p0, p1, p2) } -func (s *IMarketStruct) DealsSetConsiderVerifiedStorageDeals(p0 context.Context, p1 bool) error { - return s.Internal.DealsSetConsiderVerifiedStorageDeals(p0, p1) +func (s *IMarketStruct) DealsSetConsiderOfflineStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error { + return s.Internal.DealsSetConsiderOfflineStorageDeals(p0, p1, p2) } -func (s *IMarketStruct) DealsSetPieceCidBlocklist(p0 context.Context, p1 []cid.Cid) error { - return s.Internal.DealsSetPieceCidBlocklist(p0, p1) +func (s *IMarketStruct) DealsSetConsiderOnlineRetrievalDeals(p0 context.Context, p1 address.Address, p2 bool) error { + return s.Internal.DealsSetConsiderOnlineRetrievalDeals(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetConsiderOnlineStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error { + return s.Internal.DealsSetConsiderOnlineStorageDeals(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetConsiderUnverifiedStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error { + return s.Internal.DealsSetConsiderUnverifiedStorageDeals(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetConsiderVerifiedStorageDeals(p0 context.Context, p1 address.Address, p2 bool) error { + return s.Internal.DealsSetConsiderVerifiedStorageDeals(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetMaxProviderCollateralMultiplier(p0 context.Context, p1 address.Address, p2 uint64) error { + return s.Internal.DealsSetMaxProviderCollateralMultiplier(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetMaxPublishFee(p0 context.Context, p1 address.Address, p2 types.FIL) error { + return s.Internal.DealsSetMaxPublishFee(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetMaxStartDelay(p0 context.Context, p1 address.Address, p2 time.Duration) error { + return s.Internal.DealsSetMaxStartDelay(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetPieceCidBlocklist(p0 context.Context, p1 address.Address, p2 []cid.Cid) error { + return s.Internal.DealsSetPieceCidBlocklist(p0, p1, p2) +} +func (s *IMarketStruct) DealsSetPublishMsgPeriod(p0 context.Context, p1 address.Address, p2 time.Duration) error { + return s.Internal.DealsSetPublishMsgPeriod(p0, p1, p2) } func (s *IMarketStruct) GetDeals(p0 context.Context, p1 address.Address, p2, p3 int) ([]*market.DealInfo, error) { return s.Internal.GetDeals(p0, p1, p2, p3) @@ -214,6 +252,12 @@ func (s *IMarketStruct) MarketAddBalance(p0 context.Context, p1, p2 address.Addr func (s *IMarketStruct) MarketCancelDataTransfer(p0 context.Context, p1 datatransfer.TransferID, p2 peer.ID, p3 bool) error { return s.Internal.MarketCancelDataTransfer(p0, p1, p2, p3) } +func (s *IMarketStruct) MarketDataSetTransferPath(p0 context.Context, p1 address.Address, p2 string) error { + return s.Internal.MarketDataSetTransferPath(p0, p1, p2) +} +func (s *IMarketStruct) MarketDataTransferPath(p0 context.Context, p1 address.Address) (string, error) { + return s.Internal.MarketDataTransferPath(p0, p1) +} func (s *IMarketStruct) MarketDataTransferUpdates(p0 context.Context) (<-chan market.DataTransferChannel, error) { return s.Internal.MarketDataTransferUpdates(p0) } @@ -250,8 +294,14 @@ func (s *IMarketStruct) MarketListIncompleteDeals(p0 context.Context, p1 address func (s *IMarketStruct) MarketListRetrievalAsk(p0 context.Context) ([]*market.RetrievalAsk, error) { return s.Internal.MarketListRetrievalAsk(p0) } -func (s *IMarketStruct) MarketListRetrievalDeals(p0 context.Context, p1 address.Address) ([]market.ProviderDealState, error) { - return s.Internal.MarketListRetrievalDeals(p0, p1) +func (s *IMarketStruct) MarketListRetrievalDeals(p0 context.Context) ([]market.ProviderDealState, error) { + return s.Internal.MarketListRetrievalDeals(p0) +} +func (s *IMarketStruct) MarketMaxBalanceAddFee(p0 context.Context, p1 address.Address) (types.FIL, error) { + return s.Internal.MarketMaxBalanceAddFee(p0, p1) +} +func (s *IMarketStruct) MarketMaxDealsPerPublishMsg(p0 context.Context, p1 address.Address) (uint64, error) { + return s.Internal.MarketMaxDealsPerPublishMsg(p0, p1) } func (s *IMarketStruct) MarketPendingDeals(p0 context.Context) ([]market.PendingDealInfo, error) { return s.Internal.MarketPendingDeals(p0) @@ -271,6 +321,12 @@ func (s *IMarketStruct) MarketRestartDataTransfer(p0 context.Context, p1 datatra 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 { return s.Internal.MarketSetAsk(p0, p1, p2, p3, p4, p5, p6) } +func (s *IMarketStruct) MarketSetMaxBalanceAddFee(p0 context.Context, p1 address.Address, p2 types.FIL) error { + return s.Internal.MarketSetMaxBalanceAddFee(p0, p1, p2) +} +func (s *IMarketStruct) MarketSetMaxDealsPerPublishMsg(p0 context.Context, p1 address.Address, p2 uint64) error { + return s.Internal.MarketSetMaxDealsPerPublishMsg(p0, p1, p2) +} func (s *IMarketStruct) MarketSetRetrievalAsk(p0 context.Context, p1 address.Address, p2 *retrievalmarket.Ask) error { return s.Internal.MarketSetRetrievalAsk(p0, p1, p2) } @@ -313,11 +369,11 @@ func (s *IMarketStruct) RemovePieceStorage(p0 context.Context, p1 string) error func (s *IMarketStruct) ResponseMarketEvent(p0 context.Context, p1 *gateway.ResponseEvent) error { return s.Internal.ResponseMarketEvent(p0, p1) } -func (s *IMarketStruct) SectorGetSealDelay(p0 context.Context) (time.Duration, error) { - return s.Internal.SectorGetSealDelay(p0) +func (s *IMarketStruct) SectorGetExpectedSealDuration(p0 context.Context, p1 address.Address) (time.Duration, error) { + return s.Internal.SectorGetExpectedSealDuration(p0, p1) } -func (s *IMarketStruct) SectorSetExpectedSealDuration(p0 context.Context, p1 time.Duration) error { - return s.Internal.SectorSetExpectedSealDuration(p0, p1) +func (s *IMarketStruct) SectorSetExpectedSealDuration(p0 context.Context, p1 address.Address, p2 time.Duration) error { + return s.Internal.SectorSetExpectedSealDuration(p0, p1, p2) } func (s *IMarketStruct) UpdateDealOnPacking(p0 context.Context, p1 address.Address, p2 abi.DealID, p3 abi.SectorNumber, p4 abi.PaddedPieceSize) error { return s.Internal.UpdateDealOnPacking(p0, p1, p2, p3, p4)