storage

package
v1.17.0 Latest Latest
Warning

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

Go to latest
Published: Aug 3, 2022 License: Apache-2.0, MIT Imports: 33 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Miner

type Miner struct {
	// contains filtered or unexported fields
}

Miner is the central miner entrypoint object inside Lotus. It is instantiated in the node builder, along with the WindowPoStScheduler.

This object is the owner of the sealing pipeline. Most of the actual logic lives in the pipeline module (sealing.Sealing), and the Miner object exposes it to the rest of the system by proxying calls.

Miner#Run starts the sealing FSM.

func NewMiner

func NewMiner(api fullNodeFilteredAPI,
	maddr address.Address,
	ds datastore.Batching,
	sealer sealer.SectorManager,
	sc pipeline.SectorIDCounter,
	verif storiface.Verifier,
	prover storiface.Prover,
	gsd dtypes.GetSealingConfigFunc,
	feeCfg config.MinerFeeConfig,
	journal journal.Journal,
	as *ctladdr.AddressSelector) (*Miner, error)

NewMiner creates a new Miner object.

func (*Miner) Address added in v0.3.0

func (m *Miner) Address() address.Address

func (*Miner) CommitFlush added in v1.10.0

func (m *Miner) CommitFlush(ctx context.Context) ([]sealiface.CommitBatchRes, error)

func (*Miner) CommitPending added in v1.10.0

func (m *Miner) CommitPending(ctx context.Context) ([]abi.SectorID, error)

func (*Miner) ForceSectorState added in v0.2.5

func (m *Miner) ForceSectorState(ctx context.Context, id abi.SectorNumber, state pipeline.SectorState) error

func (*Miner) ListSectors

func (m *Miner) ListSectors() ([]pipeline.SectorInfo, error)

func (*Miner) MarkForUpgrade added in v0.5.0

func (m *Miner) MarkForUpgrade(ctx context.Context, id abi.SectorNumber, snap bool) error

func (*Miner) PledgeSector

func (m *Miner) PledgeSector(ctx context.Context) (storiface.SectorRef, error)

func (*Miner) RemoveSector added in v0.4.1

func (m *Miner) RemoveSector(ctx context.Context, id abi.SectorNumber) error

func (*Miner) Run

func (m *Miner) Run(ctx context.Context) error

Run starts the sealing FSM in the background, running preliminary checks first.

func (*Miner) SectorAbortUpgrade added in v1.14.0

func (m *Miner) SectorAbortUpgrade(sectorNum abi.SectorNumber) error

func (*Miner) SectorAddPieceToAny added in v1.11.1

func (m *Miner) SectorAddPieceToAny(ctx context.Context, size abi.UnpaddedPieceSize, r storiface.Data, d api.PieceDealInfo) (api.SectorOffset, error)

func (*Miner) SectorMatchPendingPiecesToOpenSectors added in v1.14.0

func (m *Miner) SectorMatchPendingPiecesToOpenSectors(ctx context.Context) error

func (*Miner) SectorPreCommitFlush added in v1.10.0

func (m *Miner) SectorPreCommitFlush(ctx context.Context) ([]sealiface.PreCommitBatchRes, error)

func (*Miner) SectorPreCommitPending added in v1.10.0

func (m *Miner) SectorPreCommitPending(ctx context.Context) ([]abi.SectorID, error)

func (*Miner) SectorsStatus added in v1.11.1

func (m *Miner) SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)

func (*Miner) StartPackingSector added in v0.5.0

func (m *Miner) StartPackingSector(sectorNum abi.SectorNumber) error

func (*Miner) Stop

func (m *Miner) Stop(ctx context.Context) error

func (*Miner) TerminateFlush added in v1.4.1

func (m *Miner) TerminateFlush(ctx context.Context) (*cid.Cid, error)

func (*Miner) TerminatePending added in v1.4.1

func (m *Miner) TerminatePending(ctx context.Context) ([]abi.SectorID, error)

func (*Miner) TerminateSector added in v1.4.1

func (m *Miner) TerminateSector(ctx context.Context, id abi.SectorNumber) error

type SealingStateEvt added in v0.7.1

type SealingStateEvt struct {
	SectorNumber abi.SectorNumber
	SectorType   abi.RegisteredSealProof
	From         pipeline.SectorState
	After        pipeline.SectorState
	Error        string
}

SealingStateEvt is a journal event that records a sector state transition.

type StorageWpp added in v0.3.0

type StorageWpp struct {
	// contains filtered or unexported fields
}

func NewWinningPoStProver added in v0.3.0

func NewWinningPoStProver(api v1api.FullNode, prover storiface.ProverPoSt, verifier storiface.Verifier, miner dtypes.MinerID) (*StorageWpp, error)

func (*StorageWpp) ComputeProof added in v0.3.0

func (wpp *StorageWpp) ComputeProof(ctx context.Context, ssi []builtin.ExtendedSectorInfo, rand abi.PoStRandomness, currEpoch abi.ChainEpoch, nv network.Version) ([]builtin.PoStProof, error)

func (*StorageWpp) GenerateCandidates added in v0.3.0

func (wpp *StorageWpp) GenerateCandidates(ctx context.Context, randomness abi.PoStRandomness, eligibleSectorCount uint64) ([]uint64, error)

Directories

Path Synopsis
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
gen
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

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