Documentation ¶
Index ¶
- type FullNodeAPI
- type StorageMinerAPI
- func (sm *StorageMinerAPI) ActorAddress(context.Context) (address.Address, error)
- func (sm *StorageMinerAPI) ActorAddressConfig(ctx context.Context) (api.AddressConfig, error)
- func (sm *StorageMinerAPI) ActorSectorSize(ctx context.Context, addr address.Address) (abi.SectorSize, error)
- func (sm *StorageMinerAPI) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []sto.SectorRef, ...) (map[abi.SectorNumber]string, error)
- func (sm *StorageMinerAPI) CreateBackup(ctx context.Context, fpath string) error
- func (sm *StorageMinerAPI) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)
- func (sm *StorageMinerAPI) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)
- func (sm *StorageMinerAPI) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)
- func (sm *StorageMinerAPI) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)
- func (sm *StorageMinerAPI) DealsConsiderUnverifiedStorageDeals(ctx context.Context) (bool, error)
- func (sm *StorageMinerAPI) DealsConsiderVerifiedStorageDeals(ctx context.Context) (bool, error)
- func (sm *StorageMinerAPI) DealsGetExpectedSealDurationFunc(ctx context.Context) (time.Duration, error)
- func (sm *StorageMinerAPI) DealsImportData(ctx context.Context, deal cid.Cid, fname string) error
- func (sm *StorageMinerAPI) DealsList(ctx context.Context) ([]api.MarketDeal, error)
- func (sm *StorageMinerAPI) DealsPieceCidBlocklist(ctx context.Context) ([]cid.Cid, error)
- func (sm *StorageMinerAPI) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error
- func (sm *StorageMinerAPI) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error
- func (sm *StorageMinerAPI) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error
- func (sm *StorageMinerAPI) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error
- func (sm *StorageMinerAPI) DealsSetConsiderUnverifiedStorageDeals(ctx context.Context, b bool) error
- func (sm *StorageMinerAPI) DealsSetConsiderVerifiedStorageDeals(ctx context.Context, b bool) error
- func (sm *StorageMinerAPI) DealsSetExpectedSealDurationFunc(ctx context.Context, d time.Duration) error
- func (sm *StorageMinerAPI) DealsSetPieceCidBlocklist(ctx context.Context, cids []cid.Cid) error
- func (sm *StorageMinerAPI) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, ...) error
- func (sm *StorageMinerAPI) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
- func (sm *StorageMinerAPI) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)
- func (sm *StorageMinerAPI) MarketGetDealUpdates(ctx context.Context) (<-chan storagemarket.MinerDeal, error)
- func (sm *StorageMinerAPI) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)
- func (sm *StorageMinerAPI) MarketImportDealData(ctx context.Context, propCid cid.Cid, path string) error
- func (sm *StorageMinerAPI) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
- func (sm *StorageMinerAPI) MarketListDeals(ctx context.Context) ([]api.MarketDeal, error)
- func (sm *StorageMinerAPI) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)
- func (sm *StorageMinerAPI) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)
- func (sm *StorageMinerAPI) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, ...) error
- func (sm *StorageMinerAPI) MarketSetAsk(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, ...) error
- func (sm *StorageMinerAPI) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error
- func (sm *StorageMinerAPI) MiningBase(ctx context.Context) (*types.TipSet, error)
- func (sm *StorageMinerAPI) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)
- func (sm *StorageMinerAPI) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)
- func (sm *StorageMinerAPI) PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)
- func (sm *StorageMinerAPI) PiecesListPieces(ctx context.Context) ([]cid.Cid, error)
- func (sm *StorageMinerAPI) PledgeSector(ctx context.Context) error
- func (sm *StorageMinerAPI) RetrievalDealsList(ctx context.Context) (map[retrievalmarket.ProviderDealIdentifier]retrievalmarket.ProviderDealState, ...)
- func (sm *StorageMinerAPI) SealingAbort(ctx context.Context, call storiface.CallID) error
- func (sm *StorageMinerAPI) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)
- func (sm *StorageMinerAPI) SectorGetExpectedSealDuration(ctx context.Context) (time.Duration, error)
- func (sm *StorageMinerAPI) SectorGetSealDelay(ctx context.Context) (time.Duration, error)
- func (sm *StorageMinerAPI) SectorMarkForUpgrade(ctx context.Context, id abi.SectorNumber) error
- func (sm *StorageMinerAPI) SectorRemove(ctx context.Context, id abi.SectorNumber) error
- func (sm *StorageMinerAPI) SectorSetExpectedSealDuration(ctx context.Context, delay time.Duration) error
- func (sm *StorageMinerAPI) SectorSetSealDelay(ctx context.Context, delay time.Duration) error
- func (sm *StorageMinerAPI) SectorStartSealing(ctx context.Context, number abi.SectorNumber) error
- func (sm *StorageMinerAPI) SectorsList(context.Context) ([]abi.SectorNumber, error)
- func (sm *StorageMinerAPI) SectorsListInStates(ctx context.Context, states []api.SectorState) ([]abi.SectorNumber, error)
- func (sm *StorageMinerAPI) SectorsRefs(context.Context) (map[string][]api.SealedRef, error)
- func (sm *StorageMinerAPI) SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)
- func (sm *StorageMinerAPI) SectorsSummary(ctx context.Context) (map[api.SectorState]int, error)
- func (sm *StorageMinerAPI) SectorsUpdate(ctx context.Context, id abi.SectorNumber, state api.SectorState) error
- func (sm *StorageMinerAPI) ServeRemote(w http.ResponseWriter, r *http.Request)
- func (sm *StorageMinerAPI) StorageAddLocal(ctx context.Context, path string) error
- func (sm *StorageMinerAPI) StorageLocal(ctx context.Context) (map[stores.ID]string, error)
- func (sm *StorageMinerAPI) StorageStat(ctx context.Context, id stores.ID) (fsutil.FsStat, error)
- func (sm *StorageMinerAPI) WorkerConnect(ctx context.Context, url string) error
- func (sm *StorageMinerAPI) WorkerJobs(ctx context.Context) (map[uuid.UUID][]storiface.WorkerJob, error)
- func (sm *StorageMinerAPI) WorkerStats(context.Context) (map[uuid.UUID]storiface.WorkerStats, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FullNodeAPI ¶
type FullNodeAPI struct { common.CommonAPI full.ChainAPI client.API full.MpoolAPI full.GasAPI market.MarketAPI paych.PaychAPI full.StateAPI full.MsigAPI full.WalletAPI full.SyncAPI full.BeaconAPI DS dtypes.MetadataDS }
func (*FullNodeAPI) CreateBackup ¶ added in v0.9.0
func (n *FullNodeAPI) CreateBackup(ctx context.Context, fpath string) error
type StorageMinerAPI ¶
type StorageMinerAPI struct { common.CommonAPI SectorBlocks *sectorblocks.SectorBlocks PieceStore dtypes.ProviderPieceStore StorageProvider storagemarket.StorageProvider RetrievalProvider retrievalmarket.RetrievalProvider Miner *storage.Miner BlockMiner *miner.Miner Full api.FullNode StorageMgr *sectorstorage.Manager `optional:"true"` IStorageMgr sectorstorage.SectorManager *stores.Index storiface.WorkerReturn DataTransfer dtypes.ProviderDataTransfer Host host.Host AddrSel *storage.AddressSelector DS dtypes.MetadataDS ConsiderOnlineStorageDealsConfigFunc dtypes.ConsiderOnlineStorageDealsConfigFunc SetConsiderOnlineStorageDealsConfigFunc dtypes.SetConsiderOnlineStorageDealsConfigFunc ConsiderOnlineRetrievalDealsConfigFunc dtypes.ConsiderOnlineRetrievalDealsConfigFunc SetConsiderOnlineRetrievalDealsConfigFunc dtypes.SetConsiderOnlineRetrievalDealsConfigFunc StorageDealPieceCidBlocklistConfigFunc dtypes.StorageDealPieceCidBlocklistConfigFunc SetStorageDealPieceCidBlocklistConfigFunc dtypes.SetStorageDealPieceCidBlocklistConfigFunc ConsiderOfflineStorageDealsConfigFunc dtypes.ConsiderOfflineStorageDealsConfigFunc SetConsiderOfflineStorageDealsConfigFunc dtypes.SetConsiderOfflineStorageDealsConfigFunc ConsiderOfflineRetrievalDealsConfigFunc dtypes.ConsiderOfflineRetrievalDealsConfigFunc SetConsiderOfflineRetrievalDealsConfigFunc dtypes.SetConsiderOfflineRetrievalDealsConfigFunc ConsiderVerifiedStorageDealsConfigFunc dtypes.ConsiderVerifiedStorageDealsConfigFunc SetConsiderVerifiedStorageDealsConfigFunc dtypes.SetConsiderVerifiedStorageDealsConfigFunc ConsiderUnverifiedStorageDealsConfigFunc dtypes.ConsiderUnverifiedStorageDealsConfigFunc SetConsiderUnverifiedStorageDealsConfigFunc dtypes.SetConsiderUnverifiedStorageDealsConfigFunc SetSealingConfigFunc dtypes.SetSealingConfigFunc GetSealingConfigFunc dtypes.GetSealingConfigFunc GetExpectedSealDurationFunc dtypes.GetExpectedSealDurationFunc SetExpectedSealDurationFunc dtypes.SetExpectedSealDurationFunc }
func (*StorageMinerAPI) ActorAddress ¶
func (sm *StorageMinerAPI) ActorAddress(context.Context) (address.Address, error)
func (*StorageMinerAPI) ActorAddressConfig ¶ added in v1.2.3
func (sm *StorageMinerAPI) ActorAddressConfig(ctx context.Context) (api.AddressConfig, error)
func (*StorageMinerAPI) ActorSectorSize ¶
func (sm *StorageMinerAPI) ActorSectorSize(ctx context.Context, addr address.Address) (abi.SectorSize, error)
func (*StorageMinerAPI) CheckProvable ¶ added in v1.2.2
func (sm *StorageMinerAPI) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []sto.SectorRef, expensive bool) (map[abi.SectorNumber]string, error)
func (*StorageMinerAPI) CreateBackup ¶ added in v0.9.0
func (sm *StorageMinerAPI) CreateBackup(ctx context.Context, fpath string) error
func (*StorageMinerAPI) DealsConsiderOfflineRetrievalDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderOfflineStorageDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderOnlineRetrievalDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderOnlineStorageDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderUnverifiedStorageDeals ¶ added in v1.2.3
func (sm *StorageMinerAPI) DealsConsiderUnverifiedStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderVerifiedStorageDeals ¶ added in v1.2.3
func (sm *StorageMinerAPI) DealsConsiderVerifiedStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsGetExpectedSealDurationFunc ¶ added in v0.5.0
func (*StorageMinerAPI) DealsImportData ¶ added in v0.3.0
func (sm *StorageMinerAPI) DealsImportData(ctx context.Context, deal cid.Cid, fname string) error
func (*StorageMinerAPI) DealsList ¶ added in v0.3.0
func (sm *StorageMinerAPI) DealsList(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerAPI) DealsPieceCidBlocklist ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsPieceCidBlocklist(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerAPI) DealsSetConsiderOfflineRetrievalDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderOfflineStorageDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderOnlineRetrievalDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderOnlineStorageDeals ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderUnverifiedStorageDeals ¶ added in v1.2.3
func (sm *StorageMinerAPI) DealsSetConsiderUnverifiedStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderVerifiedStorageDeals ¶ added in v1.2.3
func (sm *StorageMinerAPI) DealsSetConsiderVerifiedStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetExpectedSealDurationFunc ¶ added in v0.5.0
func (*StorageMinerAPI) DealsSetPieceCidBlocklist ¶ added in v0.4.1
func (sm *StorageMinerAPI) DealsSetPieceCidBlocklist(ctx context.Context, cids []cid.Cid) error
func (*StorageMinerAPI) MarketCancelDataTransfer ¶ added in v1.1.3
func (sm *StorageMinerAPI) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerAPI) MarketDataTransferUpdates ¶ added in v0.5.0
func (sm *StorageMinerAPI) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
func (*StorageMinerAPI) MarketGetAsk ¶ added in v0.4.0
func (sm *StorageMinerAPI) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)
func (*StorageMinerAPI) MarketGetDealUpdates ¶ added in v0.5.0
func (sm *StorageMinerAPI) MarketGetDealUpdates(ctx context.Context) (<-chan storagemarket.MinerDeal, error)
func (*StorageMinerAPI) MarketGetRetrievalAsk ¶ added in v0.5.0
func (sm *StorageMinerAPI) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)
func (*StorageMinerAPI) MarketImportDealData ¶ added in v0.3.0
func (sm *StorageMinerAPI) MarketImportDealData(ctx context.Context, propCid cid.Cid, path string) error
func (*StorageMinerAPI) MarketListDataTransfers ¶ added in v0.5.0
func (sm *StorageMinerAPI) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
func (*StorageMinerAPI) MarketListDeals ¶ added in v0.3.0
func (sm *StorageMinerAPI) MarketListDeals(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerAPI) MarketListIncompleteDeals ¶ added in v0.3.0
func (sm *StorageMinerAPI) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)
func (*StorageMinerAPI) MarketListRetrievalDeals ¶ added in v0.5.0
func (sm *StorageMinerAPI) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)
func (*StorageMinerAPI) MarketRestartDataTransfer ¶ added in v1.1.3
func (sm *StorageMinerAPI) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerAPI) MarketSetAsk ¶ added in v0.4.0
func (sm *StorageMinerAPI) MarketSetAsk(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error
func (*StorageMinerAPI) MarketSetRetrievalAsk ¶ added in v0.5.0
func (sm *StorageMinerAPI) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error
func (*StorageMinerAPI) MiningBase ¶ added in v0.3.0
func (*StorageMinerAPI) PiecesGetCIDInfo ¶ added in v0.5.0
func (sm *StorageMinerAPI) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)
func (*StorageMinerAPI) PiecesGetPieceInfo ¶ added in v0.5.0
func (sm *StorageMinerAPI) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)
func (*StorageMinerAPI) PiecesListCidInfos ¶ added in v0.5.0
func (sm *StorageMinerAPI) PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerAPI) PiecesListPieces ¶ added in v0.5.0
func (sm *StorageMinerAPI) PiecesListPieces(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerAPI) PledgeSector ¶
func (sm *StorageMinerAPI) PledgeSector(ctx context.Context) error
func (*StorageMinerAPI) RetrievalDealsList ¶ added in v0.5.0
func (sm *StorageMinerAPI) RetrievalDealsList(ctx context.Context) (map[retrievalmarket.ProviderDealIdentifier]retrievalmarket.ProviderDealState, error)
func (*StorageMinerAPI) SealingAbort ¶ added in v1.1.3
func (*StorageMinerAPI) SealingSchedDiag ¶ added in v0.5.0
func (sm *StorageMinerAPI) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)
func (*StorageMinerAPI) SectorGetExpectedSealDuration ¶ added in v0.5.0
func (*StorageMinerAPI) SectorGetSealDelay ¶ added in v0.5.0
func (*StorageMinerAPI) SectorMarkForUpgrade ¶ added in v0.5.0
func (sm *StorageMinerAPI) SectorMarkForUpgrade(ctx context.Context, id abi.SectorNumber) error
func (*StorageMinerAPI) SectorRemove ¶ added in v0.4.1
func (sm *StorageMinerAPI) SectorRemove(ctx context.Context, id abi.SectorNumber) error
func (*StorageMinerAPI) SectorSetExpectedSealDuration ¶ added in v0.5.0
func (*StorageMinerAPI) SectorSetSealDelay ¶ added in v0.5.0
func (*StorageMinerAPI) SectorStartSealing ¶ added in v0.5.0
func (sm *StorageMinerAPI) SectorStartSealing(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerAPI) SectorsList ¶
func (sm *StorageMinerAPI) SectorsList(context.Context) ([]abi.SectorNumber, error)
List all staged sectors
func (*StorageMinerAPI) SectorsListInStates ¶ added in v1.2.3
func (sm *StorageMinerAPI) SectorsListInStates(ctx context.Context, states []api.SectorState) ([]abi.SectorNumber, error)
func (*StorageMinerAPI) SectorsRefs ¶
func (*StorageMinerAPI) SectorsStatus ¶
func (sm *StorageMinerAPI) SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)
func (*StorageMinerAPI) SectorsSummary ¶ added in v1.2.3
func (sm *StorageMinerAPI) SectorsSummary(ctx context.Context) (map[api.SectorState]int, error)
func (*StorageMinerAPI) SectorsUpdate ¶
func (sm *StorageMinerAPI) SectorsUpdate(ctx context.Context, id abi.SectorNumber, state api.SectorState) error
func (*StorageMinerAPI) ServeRemote ¶
func (sm *StorageMinerAPI) ServeRemote(w http.ResponseWriter, r *http.Request)
func (*StorageMinerAPI) StorageAddLocal ¶ added in v0.3.0
func (sm *StorageMinerAPI) StorageAddLocal(ctx context.Context, path string) error
func (*StorageMinerAPI) StorageLocal ¶ added in v0.3.0
func (*StorageMinerAPI) StorageStat ¶ added in v0.3.0
func (*StorageMinerAPI) WorkerConnect ¶ added in v0.3.0
func (sm *StorageMinerAPI) WorkerConnect(ctx context.Context, url string) error
func (*StorageMinerAPI) WorkerJobs ¶ added in v0.5.0
func (*StorageMinerAPI) WorkerStats ¶
func (sm *StorageMinerAPI) WorkerStats(context.Context) (map[uuid.UUID]storiface.WorkerStats, error)
Click to show internal directories.
Click to hide internal directories.