queue

Documentation

Index

• type Queue
  • func NewQueue(weight int) *Queue
  • func (q *Queue) AddTask(task *Task)
  • func (q *Queue) GetTasks() []*Task
  • func (q *Queue) GetWeight() int
  • func (q *Queue) LastFinish() *managedrefs.ManagedRef[time.Time]
  • func (q *Queue) Pop() *Task
  • func (q *Queue) SetLastFinish(t time.Time)
• type Task

Types

type Queue

type Queue struct {
	Tasks  *managedrefs.ManagedRef[[]*Task]
	Weight int
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(weight int) *Queue

func (*Queue) AddTask

func (q *Queue) AddTask(task *Task)

func (*Queue) GetTasks

func (q *Queue) GetTasks() []*Task

func (*Queue) GetWeight

func (q *Queue) GetWeight() int

func (*Queue) LastFinish

func (q *Queue) LastFinish() *managedrefs.ManagedRef[time.Time]

func (*Queue) Pop

func (q *Queue) Pop() *Task

func (*Queue) SetLastFinish

func (q *Queue) SetLastFinish(t time.Time)

type Task

type Task struct {
	ID        ulid.ULID
	Weight    uint64
	ExecTime  time.Duration
	Timestamp time.Time
}