Versions in this module Expand all Collapse all v1 v1.22.0 Jun 12, 2024 Changes in this version + func AllocateSectorNumbers(ctx context.Context, a AllocAPI, db *harmonydb.DB, maddr address.Address, ...) ([]abi.SectorNumber, error) + func DropSectorPieceRefs(ctx context.Context, db *harmonydb.DB, sid abi.SectorID) error + func GetDevnet() bool + func SetDevnet(value bool) + type AllocAPI interface + StateMinerAllocated func(context.Context, address.Address, types.TipSetKey) (*bitfield.BitField, error) + type FinalizeTask struct + func NewFinalizeTask(max int, sp *SealPoller, sc *ffi.SealCalls, db *harmonydb.DB) *FinalizeTask + func (f *FinalizeTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (f *FinalizeTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (f *FinalizeTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (f *FinalizeTask) TypeDetails() harmonytask.TaskTypeDetails + type MoveStorageTask struct + func NewMoveStorageTask(sp *SealPoller, sc *ffi2.SealCalls, db *harmonydb.DB, max int) *MoveStorageTask + func (m *MoveStorageTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (m *MoveStorageTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (m *MoveStorageTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (m *MoveStorageTask) TypeDetails() harmonytask.TaskTypeDetails + type PoRepAPI interface + ChainHead func(context.Context) (*types.TipSet, error) + StateGetRandomnessFromBeacon func(context.Context, crypto.DomainSeparationTag, abi.ChainEpoch, []byte, ...) (abi.Randomness, error) + type PoRepTask struct + func NewPoRepTask(db *harmonydb.DB, api PoRepAPI, sp *SealPoller, sc *ffi.SealCalls, ...) *PoRepTask + func (p *PoRepTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (p *PoRepTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (p *PoRepTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (p *PoRepTask) TypeDetails() harmonytask.TaskTypeDetails + type SDRAPI interface + ChainHead func(context.Context) (*types.TipSet, error) + StateGetRandomnessFromTickets func(context.Context, crypto.DomainSeparationTag, abi.ChainEpoch, []byte, ...) (abi.Randomness, error) + type SDRTask struct + func NewSDRTask(api SDRAPI, db *harmonydb.DB, sp *SealPoller, sc *ffi2.SealCalls, maxSDR int) *SDRTask + func (s *SDRTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (s *SDRTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (s *SDRTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (s *SDRTask) TypeDetails() harmonytask.TaskTypeDetails + type SealPoller struct + func NewPoller(db *harmonydb.DB, api SealPollerAPI) *SealPoller + func (s *SealPoller) RunPoller(ctx context.Context) + type SealPollerAPI interface + ChainHead func(context.Context) (*types.TipSet, error) + StateSectorGetInfo func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*miner.SectorOnChainInfo, error) + StateSectorPreCommitInfo func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorPreCommitOnChainInfo, error) + type SubmitCommitAPI interface + ChainHead func(context.Context) (*types.TipSet, error) + StateGetAllocation func(ctx context.Context, clientAddr address.Address, ...) (*verifregtypes9.Allocation, error) + StateGetAllocationIdForPendingDeal func(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (verifregtypes9.AllocationId, error) + StateMinerInfo func(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error) + StateMinerInitialPledgeCollateral func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error) + StateSectorPreCommitInfo func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorPreCommitOnChainInfo, error) + type SubmitCommitTask struct + func NewSubmitCommitTask(sp *SealPoller, db *harmonydb.DB, api SubmitCommitAPI, sender *message.Sender, ...) *SubmitCommitTask + func (s *SubmitCommitTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (s *SubmitCommitTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (s *SubmitCommitTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (s *SubmitCommitTask) TypeDetails() harmonytask.TaskTypeDetails + type SubmitPrecommitTask struct + func NewSubmitPrecommitTask(sp *SealPoller, db *harmonydb.DB, api SubmitPrecommitTaskApi, ...) *SubmitPrecommitTask + func (s *SubmitPrecommitTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (s *SubmitPrecommitTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (s *SubmitPrecommitTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (s *SubmitPrecommitTask) TypeDetails() harmonytask.TaskTypeDetails + type SubmitPrecommitTaskApi interface + ChainHead func(context.Context) (*types.TipSet, error) + StateMinerInfo func(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error) + StateMinerPreCommitDepositForPower func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error) + StateNetworkVersion func(context.Context, types.TipSetKey) (network.Version, error) + type TreeDTask struct + func NewTreeDTask(sp *SealPoller, db *harmonydb.DB, sc *ffi2.SealCalls, maxTrees int) *TreeDTask + func (t *TreeDTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (t *TreeDTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (t *TreeDTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (t *TreeDTask) TypeDetails() harmonytask.TaskTypeDetails + type TreeRCTask struct + func NewTreeRCTask(sp *SealPoller, db *harmonydb.DB, sc *ffi2.SealCalls, maxTrees int) *TreeRCTask + func (t *TreeRCTask) Adder(taskFunc harmonytask.AddTaskFunc) + func (t *TreeRCTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error) + func (t *TreeRCTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error) + func (t *TreeRCTask) TypeDetails() harmonytask.TaskTypeDetails + type UrlPieceReader struct + RawSize int64 + Url string + func (u *UrlPieceReader) Close() error + func (u *UrlPieceReader) Read(p []byte) (n int, err error)