impl

package
v1.20.0-hyperspace-nv2... Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2023 License: Apache-2.0, MIT Imports: 69 Imported by: 7

Documentation

Index

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.RaftAPI
	full.EthAPI

	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)

func (*FullNodeAPI) RaftLeader added in v1.19.0 

func (n *FullNodeAPI) RaftLeader(ctx context.Context) (peer.ID, error)

func (*FullNodeAPI) RaftState added in v1.19.0 

func (n *FullNodeAPI) RaftState(ctx context.Context) (*api.RaftStateData, error)

type StorageMinerAPI 

type StorageMinerAPI struct {
	fx.In

	api.Common
	api.Net

	EnabledSubsystems api.MinerSubsystems

	Full        api.FullNode
	LocalStore  *paths.Local
	RemoteStore *paths.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"`
	DAGStoreWrapper   *mktsdagstore.Wrapper             `optional:"true"`

	// Miner / storage
	Miner       *sealing.Sealing     `optional:"true"`
	BlockMiner  *miner.Miner         `optional:"true"`
	StorageMgr  *sealer.Manager      `optional:"true"`
	IStorageMgr sealer.SectorManager `optional:"true"`
	paths.SectorIndex
	storiface.WorkerReturn `optional:"true"`
	AddrSel                *ctladdr.AddressSelector

	WdPoSt *wdpost.WindowPoStScheduler `optional:"true"`

	Epp gen.WinningPoStProver `optional:"true"`
	DS  dtypes.MetadataDS

	// StorageService is populated when we're not the main storage node (e.g. we're a markets node)
	StorageService modules.MinerStorageService `optional:"true"`

	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) ActorWithdrawBalance added in v1.17.1 

func (sm *StorageMinerAPI) ActorWithdrawBalance(ctx context.Context, amount abi.TokenAmount) (cid.Cid, error)

func (*StorageMinerAPI) BeneficiaryWithdrawBalance added in v1.17.2 

func (sm *StorageMinerAPI) BeneficiaryWithdrawBalance(ctx context.Context, amount abi.TokenAmount) (cid.Cid, error)

func (*StorageMinerAPI) CheckProvable added in v1.2.2 

func (sm *StorageMinerAPI) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storiface.SectorRef) (map[abi.SectorNumber]string, error)

func (*StorageMinerAPI) ComputeDataCid added in v1.15.3 

func (sm *StorageMinerAPI) ComputeDataCid(ctx context.Context, pieceSize abi.UnpaddedPieceSize, pieceData storiface.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) ([]minertypes.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) DagstoreRegisterShard added in v1.17.0 

func (sm *StorageMinerAPI) DagstoreRegisterShard(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 (sm *StorageMinerAPI) DealsGetExpectedSealDurationFunc(ctx context.Context) (time.Duration, error)

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 (sm *StorageMinerAPI) DealsSetExpectedSealDurationFunc(ctx context.Context, d time.Duration) error

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 (sm *StorageMinerAPI) MiningBase(ctx context.Context) (*types.TipSet, error)

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) (abi.SectorID, error)

func (*StorageMinerAPI) RecoverFault added in v1.17.2 

func (sm *StorageMinerAPI) RecoverFault(ctx context.Context, sectors []abi.SectorNumber) ([]cid.Cid, error)

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 (sm *StorageMinerAPI) SealingAbort(ctx context.Context, call storiface.CallID) error

func (*StorageMinerAPI) SealingRemoveRequest added in v1.17.1 

func (sm *StorageMinerAPI) SealingRemoveRequest(ctx context.Context, schedId uuid.UUID) error

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 storiface.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 (sm *StorageMinerAPI) SectorCommitPending(ctx context.Context) ([]abi.SectorID, error)

func (*StorageMinerAPI) SectorGetExpectedSealDuration added in v0.5.0 

func (sm *StorageMinerAPI) SectorGetExpectedSealDuration(ctx context.Context) (time.Duration, error)

func (*StorageMinerAPI) SectorGetSealDelay added in v0.5.0 

func (sm *StorageMinerAPI) SectorGetSealDelay(ctx context.Context) (time.Duration, error)

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) SectorNumAssignerMeta added in v1.17.2 

func (sm *StorageMinerAPI) SectorNumAssignerMeta(ctx context.Context) (api.NumAssignerMeta, error)

func (*StorageMinerAPI) SectorNumFree added in v1.17.2 

func (sm *StorageMinerAPI) SectorNumFree(ctx context.Context, name string) error

func (*StorageMinerAPI) SectorNumReservations added in v1.17.2 

func (sm *StorageMinerAPI) SectorNumReservations(ctx context.Context) (map[string]bitfield.BitField, error)

func (*StorageMinerAPI) SectorNumReserve added in v1.17.2 

func (sm *StorageMinerAPI) SectorNumReserve(ctx context.Context, name string, field bitfield.BitField, force bool) error

func (*StorageMinerAPI) SectorNumReserveCount added in v1.17.2 

func (sm *StorageMinerAPI) SectorNumReserveCount(ctx context.Context, name string, count uint64) (bitfield.BitField, 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 (sm *StorageMinerAPI) SectorPreCommitPending(ctx context.Context) ([]abi.SectorID, error)

func (*StorageMinerAPI) SectorReceive added in v1.17.2 

func (sm *StorageMinerAPI) SectorReceive(ctx context.Context, meta api.RemoteSectorMeta) 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 (sm *StorageMinerAPI) SectorSetExpectedSealDuration(ctx context.Context, delay time.Duration) error

func (*StorageMinerAPI) SectorSetSealDelay added in v0.5.0 

func (sm *StorageMinerAPI) SectorSetSealDelay(ctx context.Context, delay time.Duration) error

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 (sm *StorageMinerAPI) SectorTerminatePending(ctx context.Context) ([]abi.SectorID, 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 (sm *StorageMinerAPI) SectorsRefs(ctx context.Context) (map[string][]api.SealedRef, error)

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 storiface.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) StorageAuthVerify added in v1.17.0 

func (sm *StorageMinerAPI) StorageAuthVerify(ctx context.Context, token string) ([]auth.Permission, error)

func (*StorageMinerAPI) StorageDetachLocal added in v1.17.1 

func (sm *StorageMinerAPI) StorageDetachLocal(ctx context.Context, path string) error

func (*StorageMinerAPI) StorageLocal added in v0.3.0 

func (sm *StorageMinerAPI) StorageLocal(ctx context.Context) (map[storiface.ID]string, error)

func (*StorageMinerAPI) StorageRedeclareLocal added in v1.17.1 

func (sm *StorageMinerAPI) StorageRedeclareLocal(ctx context.Context, id *storiface.ID, dropMissing bool) error

func (*StorageMinerAPI) StorageStat added in v0.3.0 

func (sm *StorageMinerAPI) StorageStat(ctx context.Context, id storiface.ID) (fsutil.FsStat, error)

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 (sm *StorageMinerAPI) WorkerJobs(ctx context.Context) (map[uuid.UUID][]storiface.WorkerJob, error)

func (*StorageMinerAPI) WorkerStats 

func (sm *StorageMinerAPI) WorkerStats(ctx context.Context) (map[uuid.UUID]storiface.WorkerStats, error)

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.