async_task

Documentation

Index

• type AsyncTask
  • func NewAsyncTask(f Task, replicas int) *AsyncTask
  • func (at *AsyncTask) Run(ctx context.Context)
• type Task

Types

type AsyncTask

type AsyncTask struct {
	*async.TaskGroup
	// contains filtered or unexported fields
}

AsyncTask is an asynchronous task runner for functions of type Task.

func NewAsyncTask

func NewAsyncTask(f Task, replicas int) *AsyncTask

NewAsyncTask creates a new instance of AsyncTask.

func (*AsyncTask) Run

func (at *AsyncTask) Run(ctx context.Context)

Run executes a number of asynchronous tasks in loop and blocks until a shutdown signal is triggered, or the parent context is canceled. The number of executed tasks is defined by the replicas parameter.

type Task

type Task func() error

Task represents a task that needs to be always running.