task

Documentation

Index

• Variables
• type Manager
  • func NewManager(ctx context.Context) *Manager
  • func (m *Manager) Add(id string, fn func(context.Context) error)
  • func (m *Manager) Exists(id string) bool
  • func (m *Manager) Run(id string, done chan<- error)
  • func (m *Manager) Stop(id string) error
• type Task

Variables

var (
	// ErrNotFound is returned when a process is not found.
	ErrNotFound = errors.New("task not found")

	// ErrAlreadyStarted is returned when a process is already started.
	ErrAlreadyStarted = errors.New("task already started")
)

Types

type Manager

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

Manager manages tasks.

func NewManager

func NewManager(ctx context.Context) *Manager

NewManager returns a new task manager.

func (*Manager) Add

func (m *Manager) Add(id string, fn func(context.Context) error)

Add adds a task to the manager. If the process already exists, it is a no-op.

func (*Manager) Exists

func (m *Manager) Exists(id string) bool

Exists checks if a task exists.

func (*Manager) Run

func (m *Manager) Run(id string, done chan<- error)

Run starts the task if it exists. Otherwise, it waits for the process to finish.

func (*Manager) Stop

func (m *Manager) Stop(id string) error

Stop stops the task and removes it from the manager.

type Task

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

Task is a task that can be started and stopped.