queue

Documentation

Index

• type TaskQueue
  • func NewTaskQueue(taskQueueName string) TaskQueue

Types

type TaskQueue

type TaskQueue interface {
	// Enqueue enqueues a list of hostnames into the task eviction queue.
	Enqueue(taskIDs []string) error
	// Dequeue dequeues a hostname from the task eviction queue.
	Dequeue(maxWaitTime time.Duration) (string, error)
	// Length returns the length of task eviction queue at that point in time.
	Length() int
	// Clear contents of task eviction queue.
	Clear()
}

TaskQueue is the interface for task queue.

func NewTaskQueue

func NewTaskQueue(taskQueueName string) TaskQueue

NewTaskQueue returns an instance of the task queue.