worker

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (m *Manager) AddWorker(worker Worker) error
  • func (m *Manager) NewTaskGroupWorker(taskgroup *model.TaskGroup) Worker
  • func (m *Manager) NewTaskWorker(task *model.Task) Worker
  • func (m *Manager) RemoveWorker(worker Worker) error
  • func (m *Manager) Start() error
  • func (m *Manager) Stop() error
• type Worker

Types

type Manager

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

Manager

func NewManager

func NewManager() *Manager

NewManager

func (*Manager) AddWorker

func (m *Manager) AddWorker(worker Worker) error

AddWorker

func (*Manager) NewTaskGroupWorker

func (m *Manager) NewTaskGroupWorker(taskgroup *model.TaskGroup) Worker

NewTaskGroupWorker

func (*Manager) NewTaskWorker

func (m *Manager) NewTaskWorker(task *model.Task) Worker

NewTaskWorker

func (*Manager) RemoveWorker

func (m *Manager) RemoveWorker(worker Worker) error

RemoveWorker

func (*Manager) Start

func (m *Manager) Start() error

Start

func (*Manager) Stop

func (m *Manager) Stop() error

Stop

type Worker

type Worker interface {
	Start()
	Stop() error
	Result()
}

Worker