taskmanager

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CloudTaskHandler

func CloudTaskHandler(manager *TaskManager, task Task) error

func TestTaskHandler

func TestTaskHandler(manager *TaskManager, task Task) error

Types

type Options

type Options struct {
	Project  string
	Location string
	BaseURL  string
	AuthKey  string
}

type Task

type Task struct {
	Method  string
	Path    string
	Payload []byte
	Queue   string
}

type TaskManager

type TaskManager struct {
	Project     string
	Location    string
	BaseURL     string
	AuthKey     string
	TaskHandler func(manager *TaskManager, task Task) error
}

func NewCloudTaskManager

func NewCloudTaskManager(opts *Options) *TaskManager

func NewTestTaskManager

func NewTestTaskManager() *TaskManager

func (*TaskManager) AddTask

func (m *TaskManager) AddTask(task *Task) error

func (*TaskManager) AddTaskAndCreateQueueWhenNotExists

func (m *TaskManager) AddTaskAndCreateQueueWhenNotExists(task *Task) error

func (*TaskManager) PauseQueue added in v1.3.0

func (m *TaskManager) PauseQueue(queue string) error

func (*TaskManager) QueueCreate

func (m *TaskManager) QueueCreate(queue string) error

func (*TaskManager) QueueRemove

func (m *TaskManager) QueueRemove(queue string) error

func (*TaskManager) ResumeQueue added in v1.3.0

func (m *TaskManager) ResumeQueue(queue string) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL