worker

type Worker interface {
	Do(request service.Request) error
	Abort() error
}

type WorkerPool interface {
	// Add new worker, can be called any time.
	Add(worker Worker) error
	// Process requests from channel.
	DoAll(requests <-chan service.Request) error
	// Finish all consumed requests, do not process new requests.
	Cancel() error
	// Abort everything now, drop consumed requests.
	Abort() error
}