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) 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) 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) MarketPendingDeals(ctx context.Context) (api.PendingDealInfo, error)
- func (sm *StorageMinerAPI) MarketPublishPendingDeals(ctx context.Context) 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) (abi.SectorID, 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) 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) SectorTerminate(ctx context.Context, id abi.SectorNumber) error
- func (sm *StorageMinerAPI) SectorTerminateFlush(ctx context.Context) (*cid.Cid, error)
- func (sm *StorageMinerAPI) SectorTerminatePending(ctx context.Context) ([]abi.SectorID, 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 flowch.FlowchAPI full.StateAPI full.MsigAPI full.WalletAPI full.SyncAPI full.BeaconAPI DS dtypes.MetadataDS }
func (*FullNodeAPI) CreateBackup ¶
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 DealPublisher *storageadapter.DealPublisher 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 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 ¶
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 ¶
func (sm *StorageMinerAPI) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []sto.SectorRef, expensive bool) (map[abi.SectorNumber]string, error)
func (*StorageMinerAPI) CreateBackup ¶
func (sm *StorageMinerAPI) CreateBackup(ctx context.Context, fpath string) error
func (*StorageMinerAPI) DealsConsiderOfflineRetrievalDeals ¶
func (sm *StorageMinerAPI) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderOfflineStorageDeals ¶
func (sm *StorageMinerAPI) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderOnlineRetrievalDeals ¶
func (sm *StorageMinerAPI) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsConsiderOnlineStorageDeals ¶
func (sm *StorageMinerAPI) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerAPI) DealsGetExpectedSealDurationFunc ¶
func (*StorageMinerAPI) DealsImportData ¶
func (sm *StorageMinerAPI) DealsImportData(ctx context.Context, deal cid.Cid, fname string) error
func (*StorageMinerAPI) DealsList ¶
func (sm *StorageMinerAPI) DealsList(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerAPI) DealsPieceCidBlocklist ¶
func (sm *StorageMinerAPI) DealsPieceCidBlocklist(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerAPI) DealsSetConsiderOfflineRetrievalDeals ¶
func (sm *StorageMinerAPI) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderOfflineStorageDeals ¶
func (sm *StorageMinerAPI) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderOnlineRetrievalDeals ¶
func (sm *StorageMinerAPI) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetConsiderOnlineStorageDeals ¶
func (sm *StorageMinerAPI) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerAPI) DealsSetExpectedSealDurationFunc ¶
func (*StorageMinerAPI) DealsSetPieceCidBlocklist ¶
func (sm *StorageMinerAPI) DealsSetPieceCidBlocklist(ctx context.Context, cids []cid.Cid) error
func (*StorageMinerAPI) MarketCancelDataTransfer ¶
func (sm *StorageMinerAPI) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerAPI) MarketDataTransferUpdates ¶
func (sm *StorageMinerAPI) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
func (*StorageMinerAPI) MarketGetAsk ¶
func (sm *StorageMinerAPI) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)
func (*StorageMinerAPI) MarketGetDealUpdates ¶
func (sm *StorageMinerAPI) MarketGetDealUpdates(ctx context.Context) (<-chan storagemarket.MinerDeal, error)
func (*StorageMinerAPI) MarketGetRetrievalAsk ¶
func (sm *StorageMinerAPI) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)
func (*StorageMinerAPI) MarketImportDealData ¶
func (sm *StorageMinerAPI) MarketImportDealData(ctx context.Context, propCid cid.Cid, path string) error
func (*StorageMinerAPI) MarketListDataTransfers ¶
func (sm *StorageMinerAPI) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
func (*StorageMinerAPI) MarketListDeals ¶
func (sm *StorageMinerAPI) MarketListDeals(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerAPI) MarketListIncompleteDeals ¶
func (sm *StorageMinerAPI) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)
func (*StorageMinerAPI) MarketListRetrievalDeals ¶
func (sm *StorageMinerAPI) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)
func (*StorageMinerAPI) MarketPendingDeals ¶
func (sm *StorageMinerAPI) MarketPendingDeals(ctx context.Context) (api.PendingDealInfo, error)
func (*StorageMinerAPI) MarketPublishPendingDeals ¶
func (sm *StorageMinerAPI) MarketPublishPendingDeals(ctx context.Context) error
func (*StorageMinerAPI) MarketRestartDataTransfer ¶
func (sm *StorageMinerAPI) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerAPI) MarketSetAsk ¶
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 ¶
func (sm *StorageMinerAPI) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error
func (*StorageMinerAPI) MiningBase ¶
func (*StorageMinerAPI) PiecesGetCIDInfo ¶
func (sm *StorageMinerAPI) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)
func (*StorageMinerAPI) PiecesGetPieceInfo ¶
func (sm *StorageMinerAPI) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)
func (*StorageMinerAPI) PiecesListCidInfos ¶
func (sm *StorageMinerAPI) PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerAPI) PiecesListPieces ¶
func (sm *StorageMinerAPI) PiecesListPieces(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerAPI) PledgeSector ¶
func (*StorageMinerAPI) RetrievalDealsList ¶
func (sm *StorageMinerAPI) RetrievalDealsList(ctx context.Context) (map[retrievalmarket.ProviderDealIdentifier]retrievalmarket.ProviderDealState, error)
func (*StorageMinerAPI) SealingAbort ¶
func (*StorageMinerAPI) SealingSchedDiag ¶
func (sm *StorageMinerAPI) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)
func (*StorageMinerAPI) SectorGetExpectedSealDuration ¶
func (*StorageMinerAPI) SectorGetSealDelay ¶
func (*StorageMinerAPI) SectorRemove ¶
func (sm *StorageMinerAPI) SectorRemove(ctx context.Context, id abi.SectorNumber) error
func (*StorageMinerAPI) SectorSetExpectedSealDuration ¶
func (*StorageMinerAPI) SectorSetSealDelay ¶
func (*StorageMinerAPI) SectorStartSealing ¶
func (sm *StorageMinerAPI) SectorStartSealing(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerAPI) SectorTerminate ¶
func (sm *StorageMinerAPI) SectorTerminate(ctx context.Context, id abi.SectorNumber) error
func (*StorageMinerAPI) SectorTerminateFlush ¶
func (sm *StorageMinerAPI) SectorTerminateFlush(ctx context.Context) (*cid.Cid, error)
func (*StorageMinerAPI) SectorTerminatePending ¶
func (*StorageMinerAPI) SectorsList ¶
func (sm *StorageMinerAPI) SectorsList(context.Context) ([]abi.SectorNumber, error)
List all staged sectors
func (*StorageMinerAPI) SectorsListInStates ¶
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 ¶
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 ¶
func (sm *StorageMinerAPI) StorageAddLocal(ctx context.Context, path string) error
func (*StorageMinerAPI) StorageLocal ¶
func (*StorageMinerAPI) StorageStat ¶
func (*StorageMinerAPI) WorkerConnect ¶
func (sm *StorageMinerAPI) WorkerConnect(ctx context.Context, url string) error
func (*StorageMinerAPI) WorkerJobs ¶
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.