impl

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Aug 15, 2021 License: Apache-2.0, MIT Imports: 45 Imported by: 1

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

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

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

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

func (*StorageMinerAPI) SealingAbort

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

func (*StorageMinerAPI) SealingSchedDiag

func (sm *StorageMinerAPI) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)

func (*StorageMinerAPI) SectorGetExpectedSealDuration

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

func (*StorageMinerAPI) SectorGetSealDelay

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

func (*StorageMinerAPI) SectorRemove

func (sm *StorageMinerAPI) SectorRemove(ctx context.Context, id abi.SectorNumber) error

func (*StorageMinerAPI) SectorSetExpectedSealDuration

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

func (*StorageMinerAPI) SectorSetSealDelay

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

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 (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

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

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

func (*StorageMinerAPI) StorageStat

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

func (*StorageMinerAPI) WorkerConnect

func (sm *StorageMinerAPI) WorkerConnect(ctx context.Context, url string) error

func (*StorageMinerAPI) WorkerJobs

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