hnswpurger

Documentation

Index

• type HNSWPurger
  • func New(conf config.HNSWPurger, hnswConf config.HNSW) *HNSWPurger
  • func (hp *HNSWPurger) Run(ctx context.Context) (err error)

Types

type HNSWPurger

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

HNSWPurger implements the mechanism for periodically checking for old PendingJobs and attempting their rescheduling.

func New

func New(conf config.HNSWPurger, hnswConf config.HNSW) *HNSWPurger

New creates a new HNSWPurger.

func (*HNSWPurger) Run

func (hp *HNSWPurger) Run(ctx context.Context) (err error)

Run starts the pending jobs' recovery process.

This function should ideally run forever, unless an error is encountered or the context is done.