task

Documentation

Overview

* Copyright (c) 2023 Juice Technologies, Inc. All Rights Reserved.

Index

• type Group
• type Task
• type TaskFn
• type TaskManager
  • func NewTaskManager(ctx context.Context) *TaskManager
  • func (group *TaskManager) Cancel()
  • func (group *TaskManager) Ctx() context.Context
  • func (group *TaskManager) Go(label string, task Task)
  • func (group *TaskManager) GoFn(label string, task TaskFn)
  • func (group *TaskManager) Wait() error
• type Waiter

Types

type Group

type Group interface {
	Ctx() context.Context
	Cancel()
	Go(string, Task)
	GoFn(string, TaskFn)
}

type Task

type Task interface {
	Run(group Group) error
}

type TaskFn

type TaskFn = func(Group) error

type TaskManager

type TaskManager struct {
	// contains filtered or unexported fields
}

func NewTaskManager

func NewTaskManager(ctx context.Context) *TaskManager

func (*TaskManager) Cancel

func (group *TaskManager) Cancel()

func (*TaskManager) Ctx

func (group *TaskManager) Ctx() context.Context

func (*TaskManager) Go

func (group *TaskManager) Go(label string, task Task)

func (*TaskManager) GoFn

func (group *TaskManager) GoFn(label string, task TaskFn)

func (*TaskManager) Wait

func (group *TaskManager) Wait() error

type Waiter

type Waiter interface {
	Wait() error
}