taskmanager

type Collector interface {
	Start()
	Stop()
	Collect(t Task)
}

type Dispatcher interface {
	Start()
	Stop()
	Dispatch(r Request)
}

type Request struct {
	Task  Task
	Timer *time.Timer
}

type Task interface {
	Call() (out interface{}, err error)
	StartTime() time.Time
}

type WorkQueue chan Request

type Worker interface {
	Start()
	Stop()
}

type WorkerQueue chan chan Request