unseal

Documentation

Index

• Constants
• type TaskUnsealDecode
  • func NewTaskUnsealDecode(sc *ffi.SealCalls, db *harmonydb.DB, max int, api UnsealSDRApi) *TaskUnsealDecode
  • func (t *TaskUnsealDecode) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (t *TaskUnsealDecode) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (t *TaskUnsealDecode) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (t *TaskUnsealDecode) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)
  • func (t *TaskUnsealDecode) GetSpid(db *harmonydb.DB, taskID int64) string
  • func (t *TaskUnsealDecode) TypeDetails() harmonytask.TaskTypeDetails
• type TaskUnsealSdr
  • func NewTaskUnsealSDR(sc *ffi.SealCalls, db *harmonydb.DB, max taskhelp.Limiter, api UnsealSDRApi) *TaskUnsealSdr
  • func (t *TaskUnsealSdr) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (t *TaskUnsealSdr) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (t *TaskUnsealSdr) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (t *TaskUnsealSdr) GetSectorID(db *harmonydb.DB, taskID int64) (*abi.SectorID, error)
  • func (t *TaskUnsealSdr) GetSpid(db *harmonydb.DB, taskID int64) string
  • func (t *TaskUnsealSdr) TypeDetails() harmonytask.TaskTypeDetails
• type UnsealSDRApi

Constants

const MinSchedInterval = 120 * time.Second

Types

type TaskUnsealDecode

type TaskUnsealDecode struct {
	// contains filtered or unexported fields
}

func NewTaskUnsealDecode

func NewTaskUnsealDecode(sc *ffi.SealCalls, db *harmonydb.DB, max int, api UnsealSDRApi) *TaskUnsealDecode

func (*TaskUnsealDecode) Adder

func (t *TaskUnsealDecode) Adder(taskFunc harmonytask.AddTaskFunc)

func (*TaskUnsealDecode) CanAccept

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

func (*TaskUnsealDecode) Do

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

func (*TaskUnsealDecode) GetSectorID

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

func (*TaskUnsealDecode) GetSpid

func (t *TaskUnsealDecode) GetSpid(db *harmonydb.DB, taskID int64) string

func (*TaskUnsealDecode) TypeDetails

func (t *TaskUnsealDecode) TypeDetails() harmonytask.TaskTypeDetails

type TaskUnsealSdr

type TaskUnsealSdr struct {
	// contains filtered or unexported fields
}

func NewTaskUnsealSDR

func NewTaskUnsealSDR(sc *ffi.SealCalls, db *harmonydb.DB, max taskhelp.Limiter, api UnsealSDRApi) *TaskUnsealSdr

func (*TaskUnsealSdr) Adder

func (t *TaskUnsealSdr) Adder(taskFunc harmonytask.AddTaskFunc)

func (*TaskUnsealSdr) CanAccept

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

func (*TaskUnsealSdr) Do

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

func (*TaskUnsealSdr) GetSectorID

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

func (*TaskUnsealSdr) GetSpid

func (t *TaskUnsealSdr) GetSpid(db *harmonydb.DB, taskID int64) string

func (*TaskUnsealSdr) TypeDetails

func (t *TaskUnsealSdr) TypeDetails() harmonytask.TaskTypeDetails

type UnsealSDRApi

type UnsealSDRApi interface {
	StateSectorGetInfo(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorOnChainInfo, error)
}