task

Documentation

Index

• Constants
• type Func
• type Task
  • func New(locker locker.Locker, fun Func) *Task
  • func (t *Task) Close() (err error)

Constants

const (
	// RetryAfterErrorDelay is how long we wait before re-try after error.
	RetryAfterErrorDelay = 1 * time.Second
)

Types

type Func

type Func func(context.Context) error

Func is type of task function.

type Task

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

Task is a long-running task (minutes to permanent).

func New

func New(locker locker.Locker, fun Func) *Task

New creates long-running task.

func (*Task) Close

func (t *Task) Close() (err error)

Close implements io.Closer interface. It stops long running-task.