impl

package
v1.7.5 Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2023 License: Apache-2.0, MIT Imports: 43 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BoostAPI 

type BoostAPI struct {
	fx.In

	api.Common
	api.Net

	Full  lapi.FullNode
	SubCh *gateway.EthSubHandler

	Host host.Host

	DAGStore              *dagstore.DAGStore
	DagStoreWrapper       *mktsdagstore.Wrapper
	IndexBackedBlockstore dtypes.IndexBackedBlockstore
	// Boost
	StorageProvider *storagemarket.Provider
	IndexProvider   *indexprovider.Wrapper

	// Legacy Lotus
	LegacyStorageProvider gfm_storagemarket.StorageProvider

	// Lotus Markets
	SectorBlocks *sectorblocks.SectorBlocks
	PieceStore   dtypes.ProviderPieceStore
	DataTransfer dtypes.ProviderDataTransfer

	RetrievalProvider retrievalmarket.RetrievalProvider
	SectorAccessor    retrievalmarket.SectorAccessor
	DealPublisher     *storageadapter.DealPublisher

	// Graphsync Unpaid Retrieval
	GraphsyncUnpaidRetrieval *retmarket.GraphsyncUnpaidRetrieval

	// Sealing Pipeline API
	Sps sealingpipeline.API

	// GraphSQL server
	GraphqlServer *gql.Server

	// Tracing
	Tracing *tracing.Tracing

	DS lotus_dtypes.MetadataDS

	Bkp *backupmgr.BackupMgr

	ConsiderOnlineStorageDealsConfigFunc        lotus_dtypes.ConsiderOnlineStorageDealsConfigFunc        `optional:"true"`
	SetConsiderOnlineStorageDealsConfigFunc     lotus_dtypes.SetConsiderOnlineStorageDealsConfigFunc     `optional:"true"`
	ConsiderOnlineRetrievalDealsConfigFunc      lotus_dtypes.ConsiderOnlineRetrievalDealsConfigFunc      `optional:"true"`
	SetConsiderOnlineRetrievalDealsConfigFunc   lotus_dtypes.SetConsiderOnlineRetrievalDealsConfigFunc   `optional:"true"`
	StorageDealPieceCidBlocklistConfigFunc      lotus_dtypes.StorageDealPieceCidBlocklistConfigFunc      `optional:"true"`
	SetStorageDealPieceCidBlocklistConfigFunc   lotus_dtypes.SetStorageDealPieceCidBlocklistConfigFunc   `optional:"true"`
	ConsiderOfflineStorageDealsConfigFunc       lotus_dtypes.ConsiderOfflineStorageDealsConfigFunc       `optional:"true"`
	SetConsiderOfflineStorageDealsConfigFunc    lotus_dtypes.SetConsiderOfflineStorageDealsConfigFunc    `optional:"true"`
	ConsiderOfflineRetrievalDealsConfigFunc     lotus_dtypes.ConsiderOfflineRetrievalDealsConfigFunc     `optional:"true"`
	SetConsiderOfflineRetrievalDealsConfigFunc  lotus_dtypes.SetConsiderOfflineRetrievalDealsConfigFunc  `optional:"true"`
	ConsiderVerifiedStorageDealsConfigFunc      lotus_dtypes.ConsiderVerifiedStorageDealsConfigFunc      `optional:"true"`
	SetConsiderVerifiedStorageDealsConfigFunc   lotus_dtypes.SetConsiderVerifiedStorageDealsConfigFunc   `optional:"true"`
	ConsiderUnverifiedStorageDealsConfigFunc    lotus_dtypes.ConsiderUnverifiedStorageDealsConfigFunc    `optional:"true"`
	SetConsiderUnverifiedStorageDealsConfigFunc lotus_dtypes.SetConsiderUnverifiedStorageDealsConfigFunc `optional:"true"`
	SetSealingConfigFunc                        lotus_dtypes.SetSealingConfigFunc                        `optional:"true"`
	GetSealingConfigFunc                        lotus_dtypes.GetSealingConfigFunc                        `optional:"true"`
	GetExpectedSealDurationFunc                 lotus_dtypes.GetExpectedSealDurationFunc                 `optional:"true"`
	SetExpectedSealDurationFunc                 lotus_dtypes.SetExpectedSealDurationFunc                 `optional:"true"`
}

func (*BoostAPI) ActorSectorSize 

func (sm *BoostAPI) ActorSectorSize(ctx context.Context, addr address.Address) (abi.SectorSize, error)

func (*BoostAPI) BlockstoreGet added in v1.5.0 

func (sm *BoostAPI) BlockstoreGet(ctx context.Context, c cid.Cid) ([]byte, error)

func (*BoostAPI) BlockstoreGetSize added in v1.5.0 

func (sm *BoostAPI) BlockstoreGetSize(ctx context.Context, c cid.Cid) (int, error)

func (*BoostAPI) BlockstoreHas added in v1.5.0 

func (sm *BoostAPI) BlockstoreHas(ctx context.Context, c cid.Cid) (bool, error)

func (*BoostAPI) BoostDagstoreDestroyShard added in v1.3.0 

func (sm *BoostAPI) BoostDagstoreDestroyShard(ctx context.Context, key string) error

func (*BoostAPI) BoostDagstoreGC 

func (sm *BoostAPI) BoostDagstoreGC(ctx context.Context) ([]api.DagstoreShardResult, error)

func (*BoostAPI) BoostDagstoreInitializeAll 

func (sm *BoostAPI) BoostDagstoreInitializeAll(ctx context.Context, params api.DagstoreInitializeAllParams) (<-chan api.DagstoreInitializeAllEvent, error)

func (*BoostAPI) BoostDagstoreInitializeShard 

func (sm *BoostAPI) BoostDagstoreInitializeShard(ctx context.Context, key string) error

func (*BoostAPI) BoostDagstoreListShards 

func (sm *BoostAPI) BoostDagstoreListShards(ctx context.Context) ([]api.DagstoreShardInfo, error)

func (*BoostAPI) BoostDagstorePiecesContainingMultihash added in v1.1.0 

func (sm *BoostAPI) BoostDagstorePiecesContainingMultihash(ctx context.Context, mh multihash.Multihash) ([]cid.Cid, error)

func (*BoostAPI) BoostDagstoreRecoverShard 

func (sm *BoostAPI) BoostDagstoreRecoverShard(ctx context.Context, key string) error

func (*BoostAPI) BoostDagstoreRegisterShard 

func (sm *BoostAPI) BoostDagstoreRegisterShard(ctx context.Context, key string) error

func (*BoostAPI) BoostDeal 

func (sm *BoostAPI) BoostDeal(ctx context.Context, dealUuid uuid.UUID) (*types.ProviderDealState, error)

func (*BoostAPI) BoostDealBySignedProposalCid added in v1.1.0 

func (sm *BoostAPI) BoostDealBySignedProposalCid(ctx context.Context, proposalCid cid.Cid) (*types.ProviderDealState, error)

func (*BoostAPI) BoostDummyDeal 

func (sm *BoostAPI) BoostDummyDeal(ctx context.Context, params types.DealParams) (*api.ProviderDealRejectionInfo, error)

func (*BoostAPI) BoostIndexerAnnounceAllDeals 

func (sm *BoostAPI) BoostIndexerAnnounceAllDeals(ctx context.Context) error

func (*BoostAPI) BoostIndexerAnnounceLatest added in v1.7.3 

func (sm *BoostAPI) BoostIndexerAnnounceLatest(ctx context.Context) (cid.Cid, error)

func (*BoostAPI) BoostIndexerAnnounceLatestHttp added in v1.7.3 

func (sm *BoostAPI) BoostIndexerAnnounceLatestHttp(ctx context.Context, announceUrls []string) (cid.Cid, error)

func (*BoostAPI) BoostMakeDeal added in v1.6.1 

func (sm *BoostAPI) BoostMakeDeal(ctx context.Context, params types.DealParams) (*api.ProviderDealRejectionInfo, error)

func (*BoostAPI) BoostOfflineDealWithData 

func (sm *BoostAPI) BoostOfflineDealWithData(ctx context.Context, dealUuid uuid.UUID, filePath string, delAfterImport bool) (*api.ProviderDealRejectionInfo, error)

func (*BoostAPI) DealsConsiderOfflineRetrievalDeals 

func (sm *BoostAPI) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)

func (*BoostAPI) DealsConsiderOfflineStorageDeals 

func (sm *BoostAPI) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)

func (*BoostAPI) DealsConsiderOnlineRetrievalDeals 

func (sm *BoostAPI) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)

func (*BoostAPI) DealsConsiderOnlineStorageDeals 

func (sm *BoostAPI) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)

func (*BoostAPI) DealsConsiderUnverifiedStorageDeals 

func (sm *BoostAPI) DealsConsiderUnverifiedStorageDeals(ctx context.Context) (bool, error)

func (*BoostAPI) DealsConsiderVerifiedStorageDeals 

func (sm *BoostAPI) DealsConsiderVerifiedStorageDeals(ctx context.Context) (bool, error)

func (*BoostAPI) DealsGetExpectedSealDurationFunc 

func (sm *BoostAPI) DealsGetExpectedSealDurationFunc(ctx context.Context) (time.Duration, error)

func (*BoostAPI) DealsPieceCidBlocklist 

func (sm *BoostAPI) DealsPieceCidBlocklist(ctx context.Context) ([]cid.Cid, error)

func (*BoostAPI) DealsSetConsiderOfflineRetrievalDeals 

func (sm *BoostAPI) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error

func (*BoostAPI) DealsSetConsiderOfflineStorageDeals 

func (sm *BoostAPI) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error

func (*BoostAPI) DealsSetConsiderOnlineRetrievalDeals 

func (sm *BoostAPI) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error

func (*BoostAPI) DealsSetConsiderOnlineStorageDeals 

func (sm *BoostAPI) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error

func (*BoostAPI) DealsSetConsiderUnverifiedStorageDeals 

func (sm *BoostAPI) DealsSetConsiderUnverifiedStorageDeals(ctx context.Context, b bool) error

func (*BoostAPI) DealsSetConsiderVerifiedStorageDeals 

func (sm *BoostAPI) DealsSetConsiderVerifiedStorageDeals(ctx context.Context, b bool) error

func (*BoostAPI) DealsSetExpectedSealDurationFunc 

func (sm *BoostAPI) DealsSetExpectedSealDurationFunc(ctx context.Context, d time.Duration) error

func (*BoostAPI) DealsSetPieceCidBlocklist 

func (sm *BoostAPI) DealsSetPieceCidBlocklist(ctx context.Context, cids []cid.Cid) error

func (*BoostAPI) MarketCancelDataTransfer 

func (sm *BoostAPI) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error

func (*BoostAPI) MarketDataTransferUpdates 

func (sm *BoostAPI) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)

func (*BoostAPI) MarketGetAsk 

func (sm *BoostAPI) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)

func (*BoostAPI) MarketGetRetrievalAsk 

func (sm *BoostAPI) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)

func (*BoostAPI) MarketImportDealData 

func (sm *BoostAPI) MarketImportDealData(ctx context.Context, propCid cid.Cid, path string) error

func (*BoostAPI) MarketListDataTransfers 

func (sm *BoostAPI) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)

func (*BoostAPI) MarketListIncompleteDeals 

func (sm *BoostAPI) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)

func (*BoostAPI) MarketListRetrievalDeals 

func (sm *BoostAPI) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)

func (*BoostAPI) MarketPendingDeals added in v1.5.0 

func (sm *BoostAPI) MarketPendingDeals(ctx context.Context) (lapi.PendingDealInfo, error)

func (*BoostAPI) MarketRestartDataTransfer 

func (sm *BoostAPI) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error

func (*BoostAPI) MarketSetAsk 

func (sm *BoostAPI) MarketSetAsk(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error

func (*BoostAPI) MarketSetRetrievalAsk 

func (sm *BoostAPI) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error

func (*BoostAPI) OnlineBackup added in v1.6.1 

func (sm *BoostAPI) OnlineBackup(ctx context.Context, dstDir string) error

func (*BoostAPI) PiecesGetCIDInfo 

func (sm *BoostAPI) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)

func (*BoostAPI) PiecesGetMaxOffset added in v1.1.0 

func (sm *BoostAPI) PiecesGetMaxOffset(ctx context.Context, pieceCid cid.Cid) (uint64, error)

func (*BoostAPI) PiecesGetPieceInfo 

func (sm *BoostAPI) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)

func (*BoostAPI) PiecesListCidInfos 

func (sm *BoostAPI) PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)

func (*BoostAPI) PiecesListPieces 

func (sm *BoostAPI) PiecesListPieces(ctx context.Context) ([]cid.Cid, error)

func (*BoostAPI) RuntimeSubsystems 

func (sm *BoostAPI) RuntimeSubsystems(context.Context) (res lapi.MinerSubsystems, err error)

func (*BoostAPI) SectorsRefs added in v1.5.0 

func (sm *BoostAPI) SectorsRefs(ctx context.Context) (map[string][]lapi.SealedRef, error)

func (*BoostAPI) ServeRemote 

func (sm *BoostAPI) ServeRemote(perm bool) func(w http.ResponseWriter, r *http.Request)

Source Files

View all Source files

Directories

Path Synopsis

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.