snap

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 SubmitTaskNodeAPI

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

v1.23.1

Sep 23, 2024

Changes in this version

+ var ImmutableSubmitGate = abi.ChainEpoch(2)

+ func DropSectorPieceRefsSnap(ctx context.Context, db *harmonydb.DB, sid abi.SectorID) error

type EncodeTask

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

type MoveStorageTask

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

type ProveTask

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

type SubmitTask

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

type SubmitTaskNodeAPI

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

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

v1.23.0

Jul 29, 2024

Changes in this version

+ const MinSnapSchedInterval

+ type EncodeTask struct

+ func NewEncodeTask(sc *ffi.SealCalls, db *harmonydb.DB, max int) *EncodeTask

+ func (e *EncodeTask) Adder(taskFunc harmonytask.AddTaskFunc)

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

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

+ func (e *EncodeTask) GetSpid(db *harmonydb.DB, taskID int64) string

+ func (e *EncodeTask) TypeDetails() harmonytask.TaskTypeDetails

+ type MoveStorageTask struct

+ func NewMoveStorageTask(sc *ffi.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) GetSpid(db *harmonydb.DB, taskID int64) string

+ func (m *MoveStorageTask) TypeDetails() harmonytask.TaskTypeDetails

+ type ProveTask struct

+ func NewProveTask(sc *ffi.SealCalls, db *harmonydb.DB, paramck func() (bool, error), max int) *ProveTask

+ func (p *ProveTask) Adder(taskFunc harmonytask.AddTaskFunc)

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

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

+ func (p *ProveTask) GetSpid(db *harmonydb.DB, taskID int64) string

+ func (p *ProveTask) TypeDetails() harmonytask.TaskTypeDetails

+ type SubmitTask struct

+ func NewSubmitTask(db *harmonydb.DB, api SubmitTaskNodeAPI, bstore curiochain.CurioBlockstore, ...) *SubmitTask

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

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

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

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

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

+ type SubmitTaskNodeAPI interface

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

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

+ StateGetActor func(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)

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

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

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

+ StateSectorGetInfo func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*miner.SectorOnChainInfo, error)

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

+ StateVMCirculatingSupplyInternal func(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)

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

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

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