taskqueue

Documentation

Index

• func NewQueue(client Client, namespace string) TaskQueue
• func NewQueueWithDelta(client Client, namespace string, delta time.Duration) TaskQueue
• func NewTask(namespace string) *task
• func NewTaskWithPriority(namespace string, priority int) *task
• func NewTaskWithPriorityAndExpiresAt(namespace string, priority int, expires_at time.Time) *task

Functions

func NewQueue

func NewQueue(client Client, namespace string) TaskQueue

Create a new queue with the given namespace

func NewQueueWithDelta

func NewQueueWithDelta(client Client, namespace string, delta time.Duration) TaskQueue

Create a new queue with the given namespace

func NewTask

func NewTask(namespace string) *task

NewTask creates a new task with the given namespace, priority, and when the task should expire. The task is scheduled to run immediately.

func NewTaskWithPriority

func NewTaskWithPriority(namespace string, priority int) *task

NewTaskWithPriority creates a new task with the given namespace and priority

func NewTaskWithPriorityAndExpiresAt

func NewTaskWithPriorityAndExpiresAt(namespace string, priority int, expires_at time.Time) *task

NewTaskWithPriorityAndExpiresAt creates a new task with the given namespace, priority, and when the task should expire.