modules

Jul 7, 2023

Changes in this version

+ func NewMpoolMonitor(cfg *config.Boost) func(lc fx.Lifecycle, a v1api.FullNode) *mpoolmonitor.MpoolMonitor

Jun 8, 2023

Changes in this version

+ func SetLinkSystem(proxy *LinkSystemProv, prov provider.Interface)

+ type LinkSystemProv struct

+ func NewLinkSystemProvider() *LinkSystemProv

+ func (p *LinkSystemProv) LinkSys() *ipld.LinkSystem

Apr 20, 2023

Changes in this version

+ func DealDeciderFn(df lotus_dtypes.StorageDealFilter) storageimpl.DealDeciderFunc

+ func HandleRetrieval(host host.Host, lc fx.Lifecycle, m retrievalmarket.RetrievalProvider)

+ func LotusGFMStorageProviderNode(spn gfm_storagemarket.StorageProviderNode) lotus_gfm_storagemarket.StorageProviderNode

+ func NewBoostGFMDAGStoreWrapper(w *mdagstore.Wrapper) stores.DAGStoreWrapper

+ func NewLotusGFMProviderPieceStore(ps dtypes.ProviderPieceStore) lotus_dtypes.ProviderPieceStore

+ func NewProviderPieceStore(lc fx.Lifecycle, ds lotus_dtypes.MetadataDS) (dtypes.ProviderPieceStore, error)

+ func NewProviderTransport(h host.Host, gs dtypes.StagingGraphsync) dtypes.ProviderTransport

+ func NewSectorStateDB(sqldb *sql.DB) *db.SectorStateDB

+ func NewStorageAsk(ctx helpers.MetricsCtx, fapi v1api.FullNode, ds lotus_dtypes.MetadataDS, ...) (*storedask.StoredAsk, error)

+ func RetrievalGraphsync(parallelTransfersForStorage uint64, parallelTransfersForStoragePerPeer uint64, ...) ...

+ func RetrievalNetwork(h host.Host) rmnet.RetrievalMarketNetwork

+ func RetrievalPricingFunc(cfg config.DealmakingConfig) ...

Mar 22, 2023

Changes in this version

+ var UserAgent = simpleOpt(libp2p.UserAgent("boost-" + build.UserVersion()))

+ func NewOnlineBackupMgr(cfg *config.Boost) ...

+ func NewProviderTransferNetwork(h host.Host) lotus_dtypes.ProviderTransferNetwork

+ func NewSectorAccessor(cfg *config.Boost) sectoraccessor.SectorAccessorConstructor

+ func SetAskGetter(proxy *ProxyAskGetter, rp retrievalmarket.RetrievalProvider)

+ func SetShardSelectorFunc(lc fx.Lifecycle, shardSelector *ShardSelector, ...) error

+ type ProxyAskGetter struct

+ func NewAskGetter() *ProxyAskGetter

+ func (ag *ProxyAskGetter) GetAsk() *retrievalmarket.Ask

+ type ShardSelector struct

+ Proxy indexbs.ShardSelectorF

+ Target indexbs.ShardSelectorF

+ func NewShardSelector() *ShardSelector

Mar 8, 2023

Changes in this version

+ func HandleBoostLibp2pDeals(lc fx.Lifecycle, h host.Host, prov *storagemarket.Provider, a v1api.FullNode, ...)

+ func HandleContractDeals(c *config.ContractDealsConfig) ...

+ func RetrievalProvider(maddr dtypes.MinerAddress, adapter retrievalmarket.RetrievalProviderNode, ...) (retrievalmarket.RetrievalProvider, error)

+ func StorageProvider(minerAddress dtypes.MinerAddress, storedAsk *storedask.StoredAsk, h host.Host, ...) (storagemarket.StorageProvider, error)

Feb 16, 2023

Changes in this version

+ func CreateRetrievalTables(lc fx.Lifecycle, db *RetrievalSqlDB)

+ func HandleRetrievalGraphsyncUpdates(duration time.Duration) func(lc fx.Lifecycle, db *rtvllog.RetrievalLogDB, ...)

+ func NewRetrievalLogDB(db *RetrievalSqlDB) *rtvllog.RetrievalLogDB

+ type IdxProv struct

+ Datastore lotus_dtypes.MetadataDS

+ type RetrievalSqlDB struct

+ func NewRetrievalSqlDB(r repo.LockedRepo) (*RetrievalSqlDB, error)

Nov 16, 2022

Changes in this version

+ func HandleProtocolProxy(lc fx.Lifecycle, pp *protocolproxy.ProtocolProxy)

+ func NewIndexBackedBlockstore(lc fx.Lifecycle, dagst dagstore.Interface, ps lotus_dtypes.ProviderPieceStore, ...) (dtypes.IndexBackedBlockstore, error)

+ func NewLegacyStorageProvider(cfg *config.Boost) ...

+ func NewProtocolProxy(cfg *config.Boost) func(h host.Host) (*protocolproxy.ProtocolProxy, error)

Sep 15, 2022

Changes in this version

+ func HandleRetrievalTransports(lc fx.Lifecycle, l *lp2pimpl.TransportsListener)

+ func NewTracing(cfg *config.Boost) func(lc fx.Lifecycle) (*tracing.Tracing, error)

+ func NewTransportsListener(cfg *config.Boost) func(h host.Host) (*lp2pimpl.TransportsListener, error)

Jul 18, 2022

Changes in this version

+ func ResourceManager(connMgrHi uint) func(lc fx.Lifecycle, repo repo.LockedRepo) (network.ResourceManager, error)

Jun 7, 2022

Changes in this version

+ const EnvWatchdogDisabled

+ const JWTSecretName

+ const KTJwtHmacSecret

+ var StorageCounterDSPrefix = "/storage/nextid"

+ func APISecret(keystore types.KeyStore, lr lotus_repo.LockedRepo) (*dtypes.APIAlg, error)

+ func BasicDealFilter(cfg config.DealmakingConfig, userCmd dtypes.StorageDealFilter) ...

+ func ClientBlockstore() dtypes.ClientBlockstore

+ func ClientImportMgr(ds lotus_dtypes.MetadataDS, r repo.LockedRepo) (lotus_dtypes.ClientImportMgr, error)

+ func ConfigBootstrap(peers []string) func() (dtypes.BootstrapPeers, error)

+ func ConnectSealingService(apiInfo string) func(mctx helpers.MetricsCtx, lc fx.Lifecycle) (MinerSealingService, error)

+ func ConnectStorageService(apiInfo string) func(mctx helpers.MetricsCtx, lc fx.Lifecycle) (MinerStorageService, error)

+ func Datastore(disableLog bool) ...

+ func Graphsync(parallelTransfersForStorage uint64, parallelTransfersForRetrieval uint64) ...

+ func HandleBoostDeals(lc fx.Lifecycle, h host.Host, prov *storagemarket.Provider, a v1api.FullNode, ...)

+ func HandleLegacyDeals(mctx helpers.MetricsCtx, lc fx.Lifecycle, host host.Host, ...) error

+ func HandleMigrateClientFunds(lc fx.Lifecycle, ds lotus_dtypes.MetadataDS, wallet full.WalletAPI, ...)

+ func HandleProposalLogCleaner(duration time.Duration) func(lc fx.Lifecycle, plDB *db.ProposalLogsDB)

+ func IndexProvider(cfg config.IndexProviderConfig) ...

+ func KeyStore(lr lotus_repo.LockedRepo) (types.KeyStore, error)

+ func LockedRepo(lr lotus_repo.LockedRepo) func(lc fx.Lifecycle) lotus_repo.LockedRepo

+ func MemoryConstraints() system.MemoryConstraints

+ func MemoryWatchdog(lr lotus_repo.LockedRepo, lc fx.Lifecycle, ...)

+ func NewBoostDB(r lotus_repo.LockedRepo) (*sql.DB, error)

+ func NewChainDealManager(a v1api.FullNode) *storagemarket.ChainDealManager

+ func NewClientDatastore(ds lotus_dtypes.MetadataDS) dtypes.ClientDatastore

+ func NewConsiderOfflineRetrievalDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.ConsiderOfflineRetrievalDealsConfigFunc, error)

+ func NewConsiderOfflineStorageDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.ConsiderOfflineStorageDealsConfigFunc, error)

+ func NewConsiderOnlineRetrievalDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.ConsiderOnlineRetrievalDealsConfigFunc, error)

+ func NewConsiderOnlineStorageDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.ConsiderOnlineStorageDealsConfigFunc, error)

+ func NewConsiderUnverifiedStorageDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.ConsiderUnverifiedStorageDealsConfigFunc, error)

+ func NewConsiderVerifiedStorageDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.ConsiderVerifiedStorageDealsConfigFunc, error)

+ func NewDealsDB(sqldb *sql.DB) *db.DealsDB

+ func NewFundsDB(sqldb *sql.DB) *db.FundsDB

+ func NewGetExpectedSealDurationFunc(r lotus_repo.LockedRepo) (dtypes.GetExpectedSealDurationFunc, error)

+ func NewGetMaxDealStartDelayFunc(r lotus_repo.LockedRepo) (dtypes.GetMaxDealStartDelayFunc, error)

+ func NewGraphqlServer(cfg *config.Boost) ...

+ func NewLogsDB(logsSqlDB *LogSqlDB) *db.LogsDB

+ func NewProposalLogsDB(sqldb *sql.DB) *db.ProposalLogsDB

+ func NewProviderDataTransfer(lc fx.Lifecycle, net dtypes.ProviderTransferNetwork, ...) (dtypes.ProviderDataTransfer, error)

+ func NewSetConsiderOfflineRetrievalDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.SetConsiderOfflineRetrievalDealsConfigFunc, error)

+ func NewSetConsiderOnlineRetrievalDealsConfigFunc(r lotus_repo.LockedRepo) (dtypes.SetConsiderOnlineRetrievalDealsConfigFunc, error)

+ func NewSetConsideringOfflineStorageDealsFunc(r lotus_repo.LockedRepo) (dtypes.SetConsiderOfflineStorageDealsConfigFunc, error)

+ func NewSetConsideringOnlineStorageDealsFunc(r lotus_repo.LockedRepo) (dtypes.SetConsiderOnlineStorageDealsConfigFunc, error)

+ func NewSetConsideringUnverifiedStorageDealsFunc(r lotus_repo.LockedRepo) (dtypes.SetConsiderUnverifiedStorageDealsConfigFunc, error)

+ func NewSetConsideringVerifiedStorageDealsFunc(r lotus_repo.LockedRepo) (dtypes.SetConsiderVerifiedStorageDealsConfigFunc, error)

+ func NewSetExpectedSealDurationFunc(r lotus_repo.LockedRepo) (dtypes.SetExpectedSealDurationFunc, error)

+ func NewSetMaxDealStartDelayFunc(r lotus_repo.LockedRepo) (dtypes.SetMaxDealStartDelayFunc, error)

+ func NewSetStorageDealPieceCidBlocklistConfigFunc(r lotus_repo.LockedRepo) (dtypes.SetStorageDealPieceCidBlocklistConfigFunc, error)

+ func NewStorageDealPieceCidBlocklistConfigFunc(r lotus_repo.LockedRepo) (dtypes.StorageDealPieceCidBlocklistConfigFunc, error)

+ func NewStorageMarketProvider(provAddr address.Address) ...

+ func RecordValidator(ps peerstore.Peerstore) record.Validator

+ func RegisterClientValidator(crv dtypes.ClientRequestValidator, dtm dtypes.ClientDataTransfer)

+ func RetrievalBlockstoreAccessor(r repo.LockedRepo) (retrievalmarket.BlockstoreAccessor, error)

+ func RetrievalClient(lc fx.Lifecycle, h host.Host, r repo.LockedRepo, dt dtypes.ClientDataTransfer, ...) (retrievalmarket.RetrievalClient, error)

+ func RetrievalDealFilter(userFilter dtypes.RetrievalDealFilter) ...

+ func StorageBlockstoreAccessor(importmgr dtypes.ClientImportMgr) storagemarket.BlockstoreAccessor

+ func StorageClient(lc fx.Lifecycle, h host.Host, dataTransfer dtypes.ClientDataTransfer, ...) (storagemarket.StorageClient, error)

+ func StorageNetworkName(ctx helpers.MetricsCtx, a v1api.FullNode) (dtypes.NetworkName, error)

+ type Genesis func() (*types.BlockHeader, error)

+ type JwtPayload struct

+ Allow []auth.Permission

+ type LogSqlDB struct

+ func NewLogsSqlDB(r repo.LockedRepo) (*LogSqlDB, error)

+ type MinerSealingService lapi.StorageMiner

+ type MinerStorageService lapi.StorageMiner