storage

Documentation

Index

• type Miner
  • func NewMiner(api fullNodeFilteredAPI, maddr address.Address, ds datastore.Batching, ...) (*Miner, error)
  • func (m *Miner) Address() address.Address
  • func (m *Miner) CommitFlush(ctx context.Context) ([]sealiface.CommitBatchRes, error)
  • func (m *Miner) CommitPending(ctx context.Context) ([]abi.SectorID, error)
  • func (m *Miner) ForceSectorState(ctx context.Context, id abi.SectorNumber, state pipeline.SectorState) error
  • func (m *Miner) ListSectors() ([]pipeline.SectorInfo, error)
  • func (m *Miner) MarkForUpgrade(ctx context.Context, id abi.SectorNumber, snap bool) error
  • func (m *Miner) PledgeSector(ctx context.Context) (storiface.SectorRef, error)
  • func (m *Miner) RemoveSector(ctx context.Context, id abi.SectorNumber) error
  • func (m *Miner) Run(ctx context.Context) error
  • func (m *Miner) SectorAbortUpgrade(sectorNum abi.SectorNumber) error
  • func (m *Miner) SectorAddPieceToAny(ctx context.Context, size abi.UnpaddedPieceSize, r storiface.Data, ...) (api.SectorOffset, error)
  • func (m *Miner) SectorMatchPendingPiecesToOpenSectors(ctx context.Context) error
  • func (m *Miner) SectorPreCommitFlush(ctx context.Context) ([]sealiface.PreCommitBatchRes, error)
  • func (m *Miner) SectorPreCommitPending(ctx context.Context) ([]abi.SectorID, error)
  • func (m *Miner) SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)
  • func (m *Miner) StartPackingSector(sectorNum abi.SectorNumber) error
  • func (m *Miner) Stop(ctx context.Context) error
  • func (m *Miner) TerminateFlush(ctx context.Context) (*cid.Cid, error)
  • func (m *Miner) TerminatePending(ctx context.Context) ([]abi.SectorID, error)
  • func (m *Miner) TerminateSector(ctx context.Context, id abi.SectorNumber) error
• type SealingStateEvt
• type StorageWpp
  • func NewWinningPoStProver(api v1api.FullNode, prover storiface.ProverPoSt, verifier storiface.Verifier, ...) (*StorageWpp, error)
  • func (wpp *StorageWpp) ComputeProof(ctx context.Context, ssi []builtin.ExtendedSectorInfo, rand abi.PoStRandomness, ...) ([]builtin.PoStProof, error)
  • func (wpp *StorageWpp) GenerateCandidates(ctx context.Context, randomness abi.PoStRandomness, eligibleSectorCount uint64) ([]uint64, error)

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

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

func (*Miner) CommitFlush

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

func (*Miner) CommitPending

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

func (*Miner) ForceSectorState

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

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

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

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

func (*Miner) SectorAddPieceToAny

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

func (*Miner) SectorMatchPendingPiecesToOpenSectors

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

func (*Miner) SectorPreCommitFlush

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

func (*Miner) SectorPreCommitPending

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

func (*Miner) SectorsStatus

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

func (*Miner) StartPackingSector

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

func (*Miner) Stop

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

func (*Miner) TerminateFlush

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

func (*Miner) TerminatePending

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

func (*Miner) TerminateSector

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

type SealingStateEvt

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

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

func NewWinningPoStProver

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

func (*StorageWpp) ComputeProof

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

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