wdpost

Jan 11, 2024

Changes in this version

+ func NextDeadline(currentDeadline *dline.Info) *dline.Info

+ type ActorInfo struct

type NodeAPI

+ ChainGetTipSet func(context.Context, types.TipSetKey) (*types.TipSet, error)

+ type WdPoStCommands interface

+ StateMinerProvingDeadline func(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)

Nov 16, 2022

Changes in this version

type WindowPoStScheduler

+ func (s *WindowPoStScheduler) BatchPartitions(partitions []api.Partition, nv network.Version) ([][]api.Partition, error)

Oct 5, 2022

Changes in this version

type NodeAPI

+ StateSectorPartition func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*lminer.SectorLocation, error)

type WindowPoStScheduler

+ func (s *WindowPoStScheduler) ManualFaultRecovery(ctx context.Context, maddr address.Address, sectors []abi.SectorNumber) ([]cid.Cid, error)

Aug 3, 2022

Changes in this version

+ const ChallengeConfidence

+ const SchedulerStateAborted

+ const SchedulerStateFaulted

+ const SchedulerStateStarted

+ const SchedulerStateSucceeded

+ const SubmitConfidence

+ var RecoveringSectorLimit uint64 = 0

+ func NewDeadlineInfo(periodStart abi.ChainEpoch, deadlineIdx uint64, currEpoch abi.ChainEpoch) *dline.Info

+ type CompleteGeneratePoSTCb func(posts []miner.SubmitWindowedPoStParams, err error)

+ type CompleteSubmitPoSTCb func(err error)

+ type NodeAPI interface

+ ChainHead func(context.Context) (*types.TipSet, error)

+ ChainNotify func(context.Context) (<-chan []*api.HeadChange, error)

+ GasEstimateFeeCap func(context.Context, *types.Message, int64, types.TipSetKey) (types.BigInt, error)

+ GasEstimateGasPremium func(_ context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, ...) (types.BigInt, error)

+ GasEstimateMessageGas func(context.Context, *types.Message, *api.MessageSendSpec, types.TipSetKey) (*types.Message, error)

+ MpoolPushMessage func(context.Context, *types.Message, *api.MessageSendSpec) (*types.SignedMessage, error)

+ StateAccountKey func(context.Context, address.Address, types.TipSetKey) (address.Address, error)

+ StateGetRandomnessFromBeacon func(ctx context.Context, personalization crypto.DomainSeparationTag, ...) (abi.Randomness, error)

+ StateGetRandomnessFromTickets func(ctx context.Context, personalization crypto.DomainSeparationTag, ...) (abi.Randomness, error)

+ StateLookupID func(context.Context, address.Address, types.TipSetKey) (address.Address, error)

+ StateMinerInfo func(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)

+ StateMinerPartitions func(context.Context, address.Address, uint64, types.TipSetKey) ([]api.Partition, error)

+ StateMinerProvingDeadline func(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)

+ StateMinerSectors func(context.Context, address.Address, *bitfield.BitField, types.TipSetKey) ([]*miner.SectorOnChainInfo, error)

+ StateNetworkVersion func(context.Context, types.TipSetKey) (network.Version, error)

+ StateWaitMsg func(ctx context.Context, cid cid.Cid, confidence uint64, limit abi.ChainEpoch, ...) (*api.MsgLookup, error)

+ WalletBalance func(context.Context, address.Address) (types.BigInt, error)

+ WalletHas func(context.Context, address.Address) (bool, error)

+ type SchedulerState string

+ type SubmitState string

+ const SubmitStateComplete

+ const SubmitStateStart

+ const SubmitStateSubmitting

+ type WdPoStFaultsProcessedEvt struct

+ Declarations []miner.FaultDeclaration

+ MessageCID cid.Cid

+ type WdPoStProofsProcessedEvt struct

+ MessageCID cid.Cid

+ Partitions []miner.PoStPartition

+ type WdPoStRecoveriesProcessedEvt struct

+ Declarations []miner.RecoveryDeclaration

+ MessageCID cid.Cid

+ type WdPoStSchedulerEvt struct

+ State SchedulerState

+ type WindowPoStScheduler struct

+ func NewWindowedPoStScheduler(api NodeAPI, cfg config.MinerFeeConfig, pcfg config.ProvingConfig, ...) (*WindowPoStScheduler, error)

+ func (s *WindowPoStScheduler) ComputePoSt(ctx context.Context, dlIdx uint64, ts *types.TipSet) ([]miner.SubmitWindowedPoStParams, error)

+ func (s *WindowPoStScheduler) Run(ctx context.Context)