worker

Documentation

Index

• type Starter
• type Task
• type TaskHandler
• type TaskStop
• type Worker
  • func NewWorker(name string, wg *sync.WaitGroup) *Worker
  • func (w *Worker) Sender() chan<- Task
  • func (w *Worker) Start(handler TaskHandler)
  • func (w *Worker) Stop()

Types

type Starter

type Starter interface {
	Start()
}

type Task

type Task interface{}

type TaskHandler

type TaskHandler interface {
	Handle(t Task)
}

type TaskStop

type TaskStop struct{}

type Worker

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

func NewWorker

func NewWorker(name string, wg *sync.WaitGroup) *Worker

func (*Worker) Sender

func (w *Worker) Sender() chan<- Task

func (*Worker) Start

func (w *Worker) Start(handler TaskHandler)

func (*Worker) Stop

func (w *Worker) Stop()