queue

Apr 24, 2023

Changes in this version

type TaskQueue

+ Tasks *PriorityQueue

+ func (c *TaskQueue) EnqueueTask(task *entity.Task, delta int)

+ func (c *TaskQueue) PopAllTasks() (tasks entity.Tasks, err error)

+ func (c *TaskQueue) PopTasks(n int) (tasks entity.Tasks, popped int, err error)

Jan 12, 2023

Changes in this version

+ const FetchFromDBWatermarkRatio

+ type Item struct

+ func NewItem(p int, val interface{}) *Item

+ func (i *Item) Value() interface{}

+ type PriorityQueue []*Item

+ func (pq *PriorityQueue) Pop() interface{}

+ func (pq *PriorityQueue) Push(x interface{})

+ func (pq PriorityQueue) Len() int

+ func (pq PriorityQueue) Less(i, j int) bool

+ func (pq PriorityQueue) Swap(i, j int)

+ type TaskQueue struct

+ CronTasks interface{}

+ DelayTasks interface{}

+ Tenant *entity.Tenant

+ UserTasks *PriorityQueue

+ func NewTaskQueue(db types.DB, lg types.Logger, t *entity.Tenant, ls types.Listener) *TaskQueue

+ func (c *TaskQueue) EnqueueUserTask(task *entity.UserTask, delta int)

+ func (c *TaskQueue) FetchTasks()

+ func (c *TaskQueue) PopAllUserTasks() (tasks entity.UserTasks, err error)

+ func (c *TaskQueue) PopUserTasks(n int) (tasks entity.UserTasks, popped int, err error)