winning

Jul 15, 2024

Changes in this version

type WinPostTask

+ func (t *WinPostTask) GetSpid(taskID int64) string

Jun 12, 2024

Changes in this version

+ const InclusionCheckInterval

+ const MinInclusionEpochs

+ type InclusionCheckNodeApi interface

+ ChainGetTipSetByHeight func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)

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

+ type InclusionCheckTask struct

+ func NewInclusionCheckTask(db *harmonydb.DB, api InclusionCheckNodeApi) *InclusionCheckTask

+ func (i *InclusionCheckTask) Adder(taskFunc harmonytask.AddTaskFunc)

+ func (i *InclusionCheckTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

+ func (i *InclusionCheckTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

+ func (i *InclusionCheckTask) TypeDetails() harmonytask.TaskTypeDetails

+ type MiningBase struct

+ AddRounds abi.ChainEpoch

+ ComputeTime time.Time

+ TipSet *types.TipSet

+ type WinPostAPI interface

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

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

+ ChainTipSetWeight func(context.Context, types.TipSetKey) (types.BigInt, error)

+ MinerCreateBlock func(context.Context, *api.BlockTemplate) (*types.BlockMsg, error)

+ MinerGetBaseInfo func(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*api.MiningBaseInfo, error)

+ MpoolSelect func(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error)

+ StateGetBeaconEntry func(context.Context, abi.ChainEpoch) (*types.BeaconEntry, error)

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

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

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

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

+ SyncSubmitBlock func(context.Context, *types.BlockMsg) error

+ WalletSign func(context.Context, address.Address, []byte) (*crypto.Signature, error)

+ type WinPostTask struct

+ func NewWinPostTask(max int, db *harmonydb.DB, remote *paths.Remote, verifier storiface.Verifier, ...) *WinPostTask

+ func (t *WinPostTask) Adder(taskFunc harmonytask.AddTaskFunc)

+ func (t *WinPostTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

+ func (t *WinPostTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

+ func (t *WinPostTask) TypeDetails() harmonytask.TaskTypeDetails