seal

package

Go to main page

Versions in this module

v1

v1.24.2

Nov 11, 2024

v1.24.1

Oct 22, 2024

v1.24.0

Oct 21, 2024

Changes in this version

type SubmitCommitAPI

+ StateMinerInitialPledgeForSector func(ctx context.Context, sectorDuration abi.ChainEpoch, sectorSize abi.SectorSize, ...) (types.BigInt, error)

v1.23.1

Sep 23, 2024

Changes in this version

+ func GetTicket(ctx context.Context, api TicketNodeAPI, maddr address.Address) (abi.SealRandomness, abi.ChainEpoch, error)

type FinalizeTask

+ func (f *FinalizeTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

type MoveStorageTask

+ func (m *MoveStorageTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

type PoRepTask

+ func (p *PoRepTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

type SDRTask

+ func (s *SDRTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

type SubmitCommitTask

+ func (s *SubmitCommitTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

type SubmitPrecommitTask

+ func (s *SubmitPrecommitTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

type SyntheticProofTask

+ func (s *SyntheticProofTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

+ type TicketNodeAPI interface

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

+ StateGetRandomnessFromTickets func(context.Context, crypto.DomainSeparationTag, abi.ChainEpoch, []byte, ...) (abi.Randomness, error)

type TreeDTask

+ func (t *TreeDTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

type TreeRCTask

+ func (t *TreeRCTask) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)

v1.23.0

Jul 29, 2024

Changes in this version

+ var IsDevnet = build.BlockDelaySecs < 30

+ func AllocationCheck(ctx context.Context, api AllocNodeApi, piece *miner.PieceActivationManifest, ...) error

+ type AllocNodeApi interface

+ StateGetAllocation func(ctx context.Context, clientAddr address.Address, ...) (*verifregtypes9.Allocation, error)

+ type SyntheticProofTask struct

+ func NewSyntheticProofTask(sp *SealPoller, db *harmonydb.DB, sc *ffi.SealCalls, maxSynths int) *SyntheticProofTask

+ func (s *SyntheticProofTask) Adder(taskFunc harmonytask.AddTaskFunc)

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

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

+ func (s *SyntheticProofTask) GetSpid(db *harmonydb.DB, taskID int64) string

+ func (s *SyntheticProofTask) TypeDetails() harmonytask.TaskTypeDetails

v1.22.1

Jul 15, 2024

Changes in this version

type FinalizeTask

+ func (f *FinalizeTask) GetSpid(taskID int64) string

type MoveStorageTask

+ func (m *MoveStorageTask) GetSpid(taskID int64) string

type PoRepTask

+ func (p *PoRepTask) GetSpid(taskID int64) string

type SDRTask

+ func (s *SDRTask) GetSpid(taskID int64) string

type SubmitCommitAPI

+ StateMinerAvailableBalance func(context.Context, address.Address, types.TipSetKey) (big.Int, error)

type SubmitCommitTask

+ func (s *SubmitCommitTask) GetSpid(taskID int64) string

type SubmitPrecommitTask

+ CollateralFromMinerBalance bool

+ DisableCollateralFallback bool

+ func (s *SubmitPrecommitTask) GetSpid(taskID int64) string

type SubmitPrecommitTaskApi

+ StateMinerAvailableBalance func(context.Context, address.Address, types.TipSetKey) (big.Int, error)

type TreeDTask

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

type TreeRCTask

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

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL