miner

package
v0.10.3-pre1 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2020 License: Apache-2.0, MIT Imports: 22 Imported by: 90

Documentation

Index

Constants

View Source 
const MinSectorExpiration = miner0.MinSectorExpiration

Variables

View Source 
var FaultDeclarationCutoff = miner0.FaultDeclarationCutoff
View Source 
var WPoStChallengeLookback = miner0.WPoStChallengeLookback
View Source 
var WPoStChallengeWindow = miner0.WPoStChallengeWindow
View Source 
var WPoStPeriodDeadlines = miner0.WPoStPeriodDeadlines
View Source 
var WPoStProvingPeriod = miner0.WPoStProvingPeriod

Unchanged between v0 and v2 actors

Functions

func AllPartSectors 

func AllPartSectors(mas State, sget func(Partition) (bitfield.BitField, error)) (bitfield.BitField, error)

Types

type Deadline 

type Deadline interface {
	LoadPartition(idx uint64) (Partition, error)
	ForEachPartition(cb func(idx uint64, part Partition) error) error
	PostSubmissions() (bitfield.BitField, error)

	PartitionsChanged(Deadline) (bool, error)
}

type DeadlineDiff added in v0.9.0 

type DeadlineDiff map[uint64]*PartitionDiff

func DiffDeadline added in v0.9.0 

func DiffDeadline(pre, cur Deadline) (DeadlineDiff, error)

type DeadlinesDiff added in v0.9.0 

type DeadlinesDiff map[uint64]DeadlineDiff

func DiffDeadlines added in v0.9.0 

func DiffDeadlines(pre, cur State) (DeadlinesDiff, error)

type DeclareFaultsParams 

type DeclareFaultsParams = miner0.DeclareFaultsParams

Params

type DeclareFaultsRecoveredParams 

type DeclareFaultsRecoveredParams = miner0.DeclareFaultsRecoveredParams

type FaultDeclaration 

type FaultDeclaration = miner0.FaultDeclaration

type LockedFunds 

type LockedFunds struct {
	VestingFunds             abi.TokenAmount
	InitialPledgeRequirement abi.TokenAmount
	PreCommitDeposits        abi.TokenAmount
}

func (LockedFunds) TotalLockedFunds added in v0.10.1 

func (lf LockedFunds) TotalLockedFunds() abi.TokenAmount

type MinerInfo 

type MinerInfo struct {
	Owner                      address.Address   // Must be an ID-address.
	Worker                     address.Address   // Must be an ID-address.
	NewWorker                  address.Address   // Must be an ID-address.
	ControlAddresses           []address.Address // Must be an ID-addresses.
	WorkerChangeEpoch          abi.ChainEpoch
	PeerId                     *peer.ID
	Multiaddrs                 []abi.Multiaddrs
	SealProofType              abi.RegisteredSealProof
	SectorSize                 abi.SectorSize
	WindowPoStPartitionSectors uint64
	ConsensusFaultElapsed      abi.ChainEpoch
}

func (MinerInfo) IsController added in v0.10.1 

func (mi MinerInfo) IsController(addr address.Address) bool

type Partition 

type Partition interface {
	AllSectors() (bitfield.BitField, error)
	FaultySectors() (bitfield.BitField, error)
	RecoveringSectors() (bitfield.BitField, error)
	LiveSectors() (bitfield.BitField, error)
	ActiveSectors() (bitfield.BitField, error)
}

type PartitionDiff added in v0.9.0 

type PartitionDiff struct {
	Removed    bitfield.BitField
	Recovered  bitfield.BitField
	Faulted    bitfield.BitField
	Recovering bitfield.BitField
}

func DiffPartition added in v0.9.0 

func DiffPartition(pre, cur Partition) (*PartitionDiff, error)

type PoStPartition 

type PoStPartition = miner0.PoStPartition

type PreCommitChanges 

type PreCommitChanges struct {
	Added   []SectorPreCommitOnChainInfo
	Removed []SectorPreCommitOnChainInfo
}

func DiffPreCommits 

func DiffPreCommits(pre, cur State) (*PreCommitChanges, error)

type ProveCommitSectorParams 

type ProveCommitSectorParams = miner0.ProveCommitSectorParams

type RecoveryDeclaration 

type RecoveryDeclaration = miner0.RecoveryDeclaration

type SectorChanges 

type SectorChanges struct {
	Added    []SectorOnChainInfo
	Extended []SectorExtensions
	Removed  []SectorOnChainInfo
}

func DiffSectors 

func DiffSectors(pre, cur State) (*SectorChanges, error)

type SectorExpiration 

type SectorExpiration struct {
	OnTime abi.ChainEpoch

	// non-zero if sector is faulty, epoch at which it will be permanently
	// removed if it doesn't recover
	Early abi.ChainEpoch
}

type SectorExtensions 

type SectorExtensions struct {
	From SectorOnChainInfo
	To   SectorOnChainInfo
}

type SectorLocation 

type SectorLocation struct {
	Deadline  uint64
	Partition uint64
}

type SectorOnChainInfo 

type SectorOnChainInfo struct {
	SectorNumber          abi.SectorNumber
	SealProof             abi.RegisteredSealProof
	SealedCID             cid.Cid
	DealIDs               []abi.DealID
	Activation            abi.ChainEpoch
	Expiration            abi.ChainEpoch
	DealWeight            abi.DealWeight
	VerifiedDealWeight    abi.DealWeight
	InitialPledge         abi.TokenAmount
	ExpectedDayReward     abi.TokenAmount
	ExpectedStoragePledge abi.TokenAmount
}

type SectorPreCommitInfo 

type SectorPreCommitInfo = miner0.SectorPreCommitInfo

type SectorPreCommitOnChainInfo 

type SectorPreCommitOnChainInfo struct {
	Info               SectorPreCommitInfo
	PreCommitDeposit   abi.TokenAmount
	PreCommitEpoch     abi.ChainEpoch
	DealWeight         abi.DealWeight
	VerifiedDealWeight abi.DealWeight
}

type State 

type State interface {
	cbor.Marshaler

	// Total available balance to spend.
	AvailableBalance(abi.TokenAmount) (abi.TokenAmount, error)
	// Funds that will vest by the given epoch.
	VestedFunds(abi.ChainEpoch) (abi.TokenAmount, error)
	// Funds locked for various reasons.
	LockedFunds() (LockedFunds, error)
	FeeDebt() (abi.TokenAmount, error)

	GetSector(abi.SectorNumber) (*SectorOnChainInfo, error)
	FindSector(abi.SectorNumber) (*SectorLocation, error)
	GetSectorExpiration(abi.SectorNumber) (*SectorExpiration, error)
	GetPrecommittedSector(abi.SectorNumber) (*SectorPreCommitOnChainInfo, error)
	LoadSectors(sectorNos *bitfield.BitField) ([]*SectorOnChainInfo, error)
	NumLiveSectors() (uint64, error)
	IsAllocated(abi.SectorNumber) (bool, error)

	LoadDeadline(idx uint64) (Deadline, error)
	ForEachDeadline(cb func(idx uint64, dl Deadline) error) error
	NumDeadlines() (uint64, error)
	DeadlinesChanged(State) (bool, error)

	Info() (MinerInfo, error)

	DeadlineInfo(epoch abi.ChainEpoch) (*dline.Info, error)
	// contains filtered or unexported methods
}

func Load 

func Load(store adt.Store, act *types.Actor) (st State, err error)

type SubmitWindowedPoStParams 

type SubmitWindowedPoStParams = miner0.SubmitWindowedPoStParams

Source Files

View all Source files

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.