Documentation ¶
Index ¶
- func CloudTaskHandler(manager *TaskManager, task Task) error
- func TestTaskHandler(manager *TaskManager, task Task) error
- type Options
- type Task
- type TaskManager
- func (m *TaskManager) AddTask(task *Task) error
- func (m *TaskManager) AddTaskAndCreateQueueWhenNotExists(task *Task) error
- func (m *TaskManager) PauseQueue(queue string) error
- func (m *TaskManager) QueueCreate(queue string) error
- func (m *TaskManager) QueueRemove(queue string) error
- func (m *TaskManager) ResumeQueue(queue string) error
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 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
Click to show internal directories.
Click to hide internal directories.