worker

Documentation

Index

• type TaskWorker

Types

type TaskWorker

type TaskWorker interface {
	WorkerCount() int

	SetCallback(func(int, interface{})) error
	SetSource(*queue.RingBuffer) error
	Invoke(interface{}) error

	Start()
	Close()
}

TaskWorker defined common behaviour for different worker