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) ComputeDataCid(ctx context.Context, pieceSize abi.UnpaddedPieceSize, pieceData sto.Data) (abi.PieceInfo, error)
- func (sm *StorageMinerAPI) ComputeProof(ctx context.Context, ssi []builtin.ExtendedSectorInfo, rand abi.PoStRandomness, ...) ([]builtin.PoStProof, error)
- func (sm *StorageMinerAPI) ComputeWindowPoSt(ctx context.Context, dlIdx uint64, tsk types.TipSetKey) ([]lminer.SubmitWindowedPoStParams, error)
- func (sm *StorageMinerAPI) CreateBackup(ctx context.Context, fpath string) error
- func (sm *StorageMinerAPI) DagstoreGC(ctx context.Context) ([]api.DagstoreShardResult, error)
- func (sm *StorageMinerAPI) DagstoreInitializeAll(ctx context.Context, params api.DagstoreInitializeAllParams) (<-chan api.DagstoreInitializeAllEvent, error)
- func (sm *StorageMinerAPI) DagstoreInitializeShard(ctx context.Context, key string) error
- func (sm *StorageMinerAPI) DagstoreListShards(ctx context.Context) ([]api.DagstoreShardInfo, error)
- func (sm *StorageMinerAPI) DagstoreLookupPieces(ctx context.Context, cid cid.Cid) ([]api.DagstoreShardInfo, error)
- func (sm *StorageMinerAPI) DagstoreRecoverShard(ctx context.Context, key 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) Discover(ctx context.Context) (apitypes.OpenRPCDocument, error)
- func (sm *StorageMinerAPI) IndexerAnnounceAllDeals(ctx context.Context) error
- func (sm *StorageMinerAPI) IndexerAnnounceDeal(ctx context.Context, proposalCid cid.Cid) error
- func (sm *StorageMinerAPI) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, ...) error
- func (sm *StorageMinerAPI) MarketDataTransferDiagnostics(ctx context.Context, mpid peer.ID) (*api.TransferDiagnostics, 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) MarketRetryPublishDeal(ctx context.Context, propcid cid.Cid) 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) RuntimeSubsystems(context.Context) (res api.MinerSubsystems, err error)
- 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) SectorAbortUpgrade(ctx context.Context, number abi.SectorNumber) error
- func (sm *StorageMinerAPI) SectorAddPieceToAny(ctx context.Context, size abi.UnpaddedPieceSize, r sto.Data, ...) (api.SectorOffset, error)
- func (sm *StorageMinerAPI) SectorCommitFlush(ctx context.Context) ([]sealiface.CommitBatchRes, error)
- func (sm *StorageMinerAPI) SectorCommitPending(ctx context.Context) ([]abi.SectorID, 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, snap bool) error
- func (sm *StorageMinerAPI) SectorMatchPendingPiecesToOpenSectors(ctx context.Context) error
- func (sm *StorageMinerAPI) SectorPreCommitFlush(ctx context.Context) ([]sealiface.PreCommitBatchRes, error)
- func (sm *StorageMinerAPI) SectorPreCommitPending(ctx context.Context) ([]abi.SectorID, 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(ctx 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) SectorsUnsealPiece(ctx context.Context, sector sto.SectorRef, offset storiface.UnpaddedByteIndex, ...) error
- func (sm *StorageMinerAPI) SectorsUpdate(ctx context.Context, id abi.SectorNumber, state api.SectorState) error
- func (sm *StorageMinerAPI) ServeRemote(perm bool) func(w http.ResponseWriter, r *http.Request)
- func (sm *StorageMinerAPI) StorageAddLocal(ctx context.Context, path string) error
- func (sm *StorageMinerAPI) StorageLocal(ctx context.Context) (map[storiface.ID]string, error)
- func (sm *StorageMinerAPI) StorageStat(ctx context.Context, id storiface.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(ctx 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 net.NetAPI 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 NetworkName dtypes.NetworkName }
func (*FullNodeAPI) CreateBackup ¶ added in v0.9.0
func (n *FullNodeAPI) CreateBackup(ctx context.Context, fpath string) error
func (*FullNodeAPI) NodeStatus ¶ added in v1.11.0
func (n *FullNodeAPI) NodeStatus(ctx context.Context, inclChainStatus bool) (status api.NodeStatus, err error)
type StorageMinerAPI ¶
type StorageMinerAPI struct { fx.In api.Common api.Net EnabledSubsystems api.MinerSubsystems Full api.FullNode LocalStore *stores.Local RemoteStore *stores.Remote // Markets PieceStore dtypes.ProviderPieceStore `optional:"true"` StorageProvider storagemarket.StorageProvider `optional:"true"` RetrievalProvider retrievalmarket.RetrievalProvider `optional:"true"` SectorAccessor retrievalmarket.SectorAccessor `optional:"true"` DataTransfer dtypes.ProviderDataTransfer `optional:"true"` StagingGraphsync dtypes.StagingGraphsync `optional:"true"` Transport dtypes.ProviderTransport `optional:"true"` DealPublisher *storageadapter.DealPublisher `optional:"true"` SectorBlocks *sectorblocks.SectorBlocks `optional:"true"` Host host.Host `optional:"true"` DAGStore *dagstore.DAGStore `optional:"true"` // Miner / storage Miner *storage.Miner `optional:"true"` BlockMiner *miner.Miner `optional:"true"` StorageMgr *sectorstorage.Manager `optional:"true"` IStorageMgr sectorstorage.SectorManager `optional:"true"` stores.SectorIndex storiface.WorkerReturn `optional:"true"` AddrSel *storage.AddressSelector WdPoSt *storage.WindowPoStScheduler `optional:"true"` Epp gen.WinningPoStProver `optional:"true"` DS dtypes.MetadataDS ConsiderOnlineStorageDealsConfigFunc dtypes.ConsiderOnlineStorageDealsConfigFunc `optional:"true"` SetConsiderOnlineStorageDealsConfigFunc dtypes.SetConsiderOnlineStorageDealsConfigFunc `optional:"true"` ConsiderOnlineRetrievalDealsConfigFunc dtypes.ConsiderOnlineRetrievalDealsConfigFunc `optional:"true"` SetConsiderOnlineRetrievalDealsConfigFunc dtypes.SetConsiderOnlineRetrievalDealsConfigFunc `optional:"true"` StorageDealPieceCidBlocklistConfigFunc dtypes.StorageDealPieceCidBlocklistConfigFunc `optional:"true"` SetStorageDealPieceCidBlocklistConfigFunc dtypes.SetStorageDealPieceCidBlocklistConfigFunc `optional:"true"` ConsiderOfflineStorageDealsConfigFunc dtypes.ConsiderOfflineStorageDealsConfigFunc `optional:"true"` SetConsiderOfflineStorageDealsConfigFunc dtypes.SetConsiderOfflineStorageDealsConfigFunc `optional:"true"` ConsiderOfflineRetrievalDealsConfigFunc dtypes.ConsiderOfflineRetrievalDealsConfigFunc `optional:"true"` SetConsiderOfflineRetrievalDealsConfigFunc dtypes.SetConsiderOfflineRetrievalDealsConfigFunc `optional:"true"` ConsiderVerifiedStorageDealsConfigFunc dtypes.ConsiderVerifiedStorageDealsConfigFunc `optional:"true"` SetConsiderVerifiedStorageDealsConfigFunc dtypes.SetConsiderVerifiedStorageDealsConfigFunc `optional:"true"` ConsiderUnverifiedStorageDealsConfigFunc dtypes.ConsiderUnverifiedStorageDealsConfigFunc `optional:"true"` SetConsiderUnverifiedStorageDealsConfigFunc dtypes.SetConsiderUnverifiedStorageDealsConfigFunc `optional:"true"` SetSealingConfigFunc dtypes.SetSealingConfigFunc `optional:"true"` GetSealingConfigFunc dtypes.GetSealingConfigFunc `optional:"true"` GetExpectedSealDurationFunc dtypes.GetExpectedSealDurationFunc `optional:"true"` SetExpectedSealDurationFunc dtypes.SetExpectedSealDurationFunc `optional:"true"` }
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) ComputeDataCid ¶ added in v1.15.3
func (sm *StorageMinerAPI) ComputeDataCid(ctx context.Context, pieceSize abi.UnpaddedPieceSize, pieceData sto.Data) (abi.PieceInfo, error)
func (*StorageMinerAPI) ComputeProof ¶ added in v1.9.0
func (sm *StorageMinerAPI) ComputeProof(ctx context.Context, ssi []builtin.ExtendedSectorInfo, rand abi.PoStRandomness, poStEpoch abi.ChainEpoch, nv network.Version) ([]builtin.PoStProof, error)
func (*StorageMinerAPI) ComputeWindowPoSt ¶ added in v1.15.2
func (sm *StorageMinerAPI) ComputeWindowPoSt(ctx context.Context, dlIdx uint64, tsk types.TipSetKey) ([]lminer.SubmitWindowedPoStParams, error)
func (*StorageMinerAPI) CreateBackup ¶ added in v0.9.0
func (sm *StorageMinerAPI) CreateBackup(ctx context.Context, fpath string) error
func (*StorageMinerAPI) DagstoreGC ¶ added in v1.11.2
func (sm *StorageMinerAPI) DagstoreGC(ctx context.Context) ([]api.DagstoreShardResult, error)
func (*StorageMinerAPI) DagstoreInitializeAll ¶ added in v1.11.2
func (sm *StorageMinerAPI) DagstoreInitializeAll(ctx context.Context, params api.DagstoreInitializeAllParams) (<-chan api.DagstoreInitializeAllEvent, error)
func (*StorageMinerAPI) DagstoreInitializeShard ¶ added in v1.11.2
func (sm *StorageMinerAPI) DagstoreInitializeShard(ctx context.Context, key string) error
func (*StorageMinerAPI) DagstoreListShards ¶ added in v1.11.2
func (sm *StorageMinerAPI) DagstoreListShards(ctx context.Context) ([]api.DagstoreShardInfo, error)
func (*StorageMinerAPI) DagstoreLookupPieces ¶ added in v1.15.1
func (sm *StorageMinerAPI) DagstoreLookupPieces(ctx context.Context, cid cid.Cid) ([]api.DagstoreShardInfo, error)
func (*StorageMinerAPI) DagstoreRecoverShard ¶ added in v1.11.2
func (sm *StorageMinerAPI) DagstoreRecoverShard(ctx context.Context, key 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) Discover ¶ added in v1.9.0
func (sm *StorageMinerAPI) Discover(ctx context.Context) (apitypes.OpenRPCDocument, error)
func (*StorageMinerAPI) IndexerAnnounceAllDeals ¶ added in v1.15.1
func (sm *StorageMinerAPI) IndexerAnnounceAllDeals(ctx context.Context) error
func (*StorageMinerAPI) IndexerAnnounceDeal ¶ added in v1.15.1
func (sm *StorageMinerAPI) IndexerAnnounceDeal(ctx context.Context, proposalCid 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) MarketDataTransferDiagnostics ¶ added in v1.14.0
func (sm *StorageMinerAPI) MarketDataTransferDiagnostics(ctx context.Context, mpid peer.ID) (*api.TransferDiagnostics, 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) MarketPendingDeals ¶ added in v1.4.2
func (sm *StorageMinerAPI) MarketPendingDeals(ctx context.Context) (api.PendingDealInfo, error)
func (*StorageMinerAPI) MarketPublishPendingDeals ¶ added in v1.4.2
func (sm *StorageMinerAPI) MarketPublishPendingDeals(ctx context.Context) 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) MarketRetryPublishDeal ¶ added in v1.13.1
func (sm *StorageMinerAPI) MarketRetryPublishDeal(ctx context.Context, propcid cid.Cid) 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 (*StorageMinerAPI) RetrievalDealsList ¶ added in v0.5.0
func (sm *StorageMinerAPI) RetrievalDealsList(ctx context.Context) (map[retrievalmarket.ProviderDealIdentifier]retrievalmarket.ProviderDealState, error)
func (*StorageMinerAPI) RuntimeSubsystems ¶ added in v1.11.1
func (sm *StorageMinerAPI) RuntimeSubsystems(context.Context) (res api.MinerSubsystems, err 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) SectorAbortUpgrade ¶ added in v1.14.0
func (sm *StorageMinerAPI) SectorAbortUpgrade(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerAPI) SectorAddPieceToAny ¶ added in v1.11.1
func (sm *StorageMinerAPI) SectorAddPieceToAny(ctx context.Context, size abi.UnpaddedPieceSize, r sto.Data, d api.PieceDealInfo) (api.SectorOffset, error)
func (*StorageMinerAPI) SectorCommitFlush ¶ added in v1.10.0
func (sm *StorageMinerAPI) SectorCommitFlush(ctx context.Context) ([]sealiface.CommitBatchRes, error)
func (*StorageMinerAPI) SectorCommitPending ¶ added in v1.10.0
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, snap bool) error
func (*StorageMinerAPI) SectorMatchPendingPiecesToOpenSectors ¶ added in v1.14.0
func (sm *StorageMinerAPI) SectorMatchPendingPiecesToOpenSectors(ctx context.Context) error
func (*StorageMinerAPI) SectorPreCommitFlush ¶ added in v1.10.0
func (sm *StorageMinerAPI) SectorPreCommitFlush(ctx context.Context) ([]sealiface.PreCommitBatchRes, error)
func (*StorageMinerAPI) SectorPreCommitPending ¶ added in v1.10.0
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) SectorTerminate ¶ added in v1.4.1
func (sm *StorageMinerAPI) SectorTerminate(ctx context.Context, id abi.SectorNumber) error
func (*StorageMinerAPI) SectorTerminateFlush ¶ added in v1.4.1
func (sm *StorageMinerAPI) SectorTerminateFlush(ctx context.Context) (*cid.Cid, error)
func (*StorageMinerAPI) SectorTerminatePending ¶ added in v1.4.1
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) SectorsUnsealPiece ¶ added in v1.11.1
func (sm *StorageMinerAPI) SectorsUnsealPiece(ctx context.Context, sector sto.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize, randomness abi.SealRandomness, commd *cid.Cid) 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(perm bool) func(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(ctx context.Context) (map[uuid.UUID]storiface.WorkerStats, error)
Click to show internal directories.
Click to hide internal directories.