impl

package
v1.4.2 Latest Latest
Warning

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

Go to latest
Published: Feb 17, 2021 License: Apache-2.0, MIT Imports: 45 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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
	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 (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) 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 (*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) 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) error

func (*StorageMinerAPI) RetrievalDealsList added in v0.5.0

func (*StorageMinerAPI) SealingAbort added in v1.1.3

func (sm *StorageMinerAPI) SealingAbort(ctx context.Context, call storiface.CallID) error

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 (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) 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(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) 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 (sm *StorageMinerAPI) StorageLocal(ctx context.Context) (map[stores.ID]string, error)

func (*StorageMinerAPI) StorageStat added in v0.3.0

func (sm *StorageMinerAPI) StorageStat(ctx context.Context, id stores.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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL