worker

type Configuration struct {
	//Number of pre-initialized task thread
	Concurrency int

	//Waiting time for worker to wait task threads closing
	WaitTaskThreadsToClose time.Duration

	//Waiting time to issue heartbeat
	Heartbeat time.Duration
}

type EventHandler interface {
	//TODO: Remove Start and End handlers. It can be solved with decorator
	OnStartWorker()
	OnEndWorker()

	//TODO: Remove Pre and Post handlers. It can be solved with decorator
	OnPreTask(task *common.Task)
	OnPostTask(task *common.Task)
	OnThreadHeartbeat(threadId int)
}

type Handler interface {
	Init() error
	Close() error

	Config() *Configuration

	TaskQueue() chan<- *common.Task
	SetEventHandler(eventHandler EventHandler)
	SetTaskEventHandler(eventHandler common.TaskProcessEventHandler)
	StartWorker()
	StopWorker()
}

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