indexing

Documentation

Index

• Constants
• Variables
• type CheckIndexesTask
  • func NewCheckIndexesTask(db *harmonydb.DB, indexStore *indexstore.IndexStore) *CheckIndexesTask
  • func (c *CheckIndexesTask) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (c *CheckIndexesTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (c *CheckIndexesTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (c *CheckIndexesTask) TypeDetails() harmonytask.TaskTypeDetails
• type IPNITask
  • func NewIPNITask(db *harmonydb.DB, sc *ffi.SealCalls, indexStore *indexstore.IndexStore, ...) *IPNITask
  • func (I *IPNITask) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (I *IPNITask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (I *IPNITask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (I *IPNITask) GetSpid(db *harmonydb.DB, taskID int64) string
  • func (I *IPNITask) TypeDetails() harmonytask.TaskTypeDetails
• type IndexingTask
  • func NewIndexingTask(db *harmonydb.DB, sc *ffi.SealCalls, indexStore *indexstore.IndexStore, ...) *IndexingTask
  • func (i *IndexingTask) Adder(taskFunc harmonytask.AddTaskFunc)
  • func (i *IndexingTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
  • func (i *IndexingTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
  • func (i *IndexingTask) GetSpid(db *harmonydb.DB, taskID int64) string
  • func (i *IndexingTask) TypeDetails() harmonytask.TaskTypeDetails

Constants

const CheckIndexInterval = 9 * time.Minute

Variables

var MaxOngoingIndexingTasks = 40

Types

type CheckIndexesTask

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

func NewCheckIndexesTask

func NewCheckIndexesTask(db *harmonydb.DB, indexStore *indexstore.IndexStore) *CheckIndexesTask

func (*CheckIndexesTask) Adder

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

func (*CheckIndexesTask) CanAccept

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

func (*CheckIndexesTask) Do

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

func (*CheckIndexesTask) TypeDetails

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

type IPNITask

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

func NewIPNITask

func NewIPNITask(db *harmonydb.DB, sc *ffi.SealCalls, indexStore *indexstore.IndexStore, pieceProvider *pieceprovider.PieceProvider, cfg *config.CurioConfig, max taskhelp.Limiter) *IPNITask

func (*IPNITask) Adder

func (I *IPNITask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*IPNITask) CanAccept

func (I *IPNITask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*IPNITask) Do

func (I *IPNITask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*IPNITask) GetSpid

func (I *IPNITask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*IPNITask) TypeDetails

func (I *IPNITask) TypeDetails() harmonytask.TaskTypeDetails

type IndexingTask

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

func NewIndexingTask

func NewIndexingTask(db *harmonydb.DB, sc *ffi.SealCalls, indexStore *indexstore.IndexStore, pieceProvider *pieceprovider.PieceProvider, cfg *config.CurioConfig, max taskhelp.Limiter) *IndexingTask

func (*IndexingTask) Adder

func (i *IndexingTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*IndexingTask) CanAccept

func (i *IndexingTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*IndexingTask) Do

func (i *IndexingTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*IndexingTask) GetSpid

func (i *IndexingTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*IndexingTask) TypeDetails

func (i *IndexingTask) TypeDetails() harmonytask.TaskTypeDetails