Back to godoc.org

Package queue

v0.0.0 (a69e935)
Latest Go to latest
Published: Oct 1, 2019 | License: Apache-2.0 | Module: github.com/uber/peloton

Index

Package Files

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.

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier