impl

package
v1.27.2 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2024 License: Apache-2.0, MIT Imports: 54 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithdrawBalance added in v1.27.0 

func WithdrawBalance(ctx context.Context, full api.FullNode, maddr address.Address, amount abi.TokenAmount, fromOwner bool) (cid.Cid, error)

Types

type FullNodeAPI 

type FullNodeAPI struct {
	common.CommonAPI
	net.NetAPI
	full.ChainAPI
	full.MpoolAPI
	full.GasAPI
	market.MarketAPI
	paych.PaychAPI
	full.StateAPI
	full.MsigAPI
	full.WalletAPI
	full.SyncAPI
	full.EthAPI
	full.ActorEventsAPI

	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  *paths.Local
	RemoteStore *paths.Remote

	// Markets
	SectorBlocks *sectorblocks.SectorBlocks `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"`

	SetSealingConfigFunc        dtypes.SetSealingConfigFunc        `optional:"true"`
	GetSealingConfigFunc        dtypes.GetSealingConfigFunc        `optional:"true"`
	GetExpectedSealDurationFunc dtypes.GetExpectedSealDurationFunc `optional:"true"`
	SetExpectedSealDurationFunc dtypes.SetExpectedSealDurationFunc `optional:"true"`

	HarmonyDB *harmonydb.DB `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) ([]lminer.SubmitWindowedPoStParams, error)

func (*StorageMinerAPI) CreateBackup added in v0.9.0 

func (sm *StorageMinerAPI) CreateBackup(ctx context.Context, fpath string) error

func (*StorageMinerAPI) DealsGetExpectedSealDurationFunc added in v0.5.0 

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

func (*StorageMinerAPI) DealsSetExpectedSealDurationFunc added in v0.5.0 

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

func (*StorageMinerAPI) Discover added in v1.9.0 

func (sm *StorageMinerAPI) Discover(ctx context.Context) (apitypes.OpenRPCDocument, error)

func (*StorageMinerAPI) MarketListDeals added in v0.3.0 

func (sm *StorageMinerAPI) MarketListDeals(ctx context.Context) ([]*api.MarketDeal, error)

func (*StorageMinerAPI) MiningBase added in v0.3.0 

func (sm *StorageMinerAPI) MiningBase(ctx context.Context) (*types.TipSet, 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) 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 piece.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) SectorUnseal added in v1.23.1 

func (sm *StorageMinerAPI) SectorUnseal(ctx context.Context, sectorNum abi.SectorNumber) 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)

Use SectorsSummary from stats (prometheus) for faster result

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.