scrub

Documentation

Index

• Constants
• type ScrubCommDTask
  • func NewCommDCheckTask(db *harmonydb.DB, sc *ffi.SealCalls) *ScrubCommDTask
  • func (c *ScrubCommDTask) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (c *ScrubCommDTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (c *ScrubCommDTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (c *ScrubCommDTask) TypeDetails() harmonytask.TaskTypeDetails

Constants

const MinSchedInterval = 100 * time.Second

Types

type ScrubCommDTask

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

func NewCommDCheckTask

func NewCommDCheckTask(db *harmonydb.DB, sc *ffi.SealCalls) *ScrubCommDTask

func (*ScrubCommDTask) Adder

func (c *ScrubCommDTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*ScrubCommDTask) CanAccept

func (c *ScrubCommDTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*ScrubCommDTask) Do

func (c *ScrubCommDTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*ScrubCommDTask) TypeDetails

func (c *ScrubCommDTask) TypeDetails() harmonytask.TaskTypeDetails