queue

Documentation

Index

• type QueryQueue
  • func NewQueryQueue(size int) *QueryQueue
  • func (p *QueryQueue) Acquire(key string, delta int)
  • func (p *QueryQueue) Release(key string, delta int)
• type Task
• type TaskQueue
  • func NewTaskQueue(maxSize int) *TaskQueue
  • func (q *TaskQueue) Dequeue() *Task
  • func (q *TaskQueue) Enqueue(task *Task)
  • func (q *TaskQueue) ExecuteLoop(interval time.Duration)
  • func (q *TaskQueue) IsFull() bool

Types

type QueryQueue

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

func NewQueryQueue

func NewQueryQueue(size int) *QueryQueue

func (*QueryQueue) Acquire

func (p *QueryQueue) Acquire(key string, delta int)

func (*QueryQueue) Release

func (p *QueryQueue) Release(key string, delta int)

type Task

type Task struct {
	Key string
	Do  func()
}

type TaskQueue

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

func NewTaskQueue

func NewTaskQueue(maxSize int) *TaskQueue

func (*TaskQueue) Dequeue

func (q *TaskQueue) Dequeue() *Task

func (*TaskQueue) Enqueue

func (q *TaskQueue) Enqueue(task *Task)

func (*TaskQueue) ExecuteLoop

func (q *TaskQueue) ExecuteLoop(interval time.Duration)

func (*TaskQueue) IsFull

func (q *TaskQueue) IsFull() bool