taskqueue

type Queue ¶

type Queue interface {
	StoreTask(task *models.Task)
	GetTask(imageUrl string) (*models.Task, error)
	ReadQueue() []*models.Task
	GetDistinctImageList() []string
	BulkRemove(tasks []*models.Task)
	Pop() (*models.Task, bool)
	PeakForNextTask() (*models.Task, bool)
}

Queue is a special datastructure.Queue implementation that will not fully remove models.Task once popped. Instead, It will still be stored in internal datastructure.Buffer to make sure that no task is lost during the task distribution process.

func ProvideTaskQueue(meter metric.Meter) Queue