MakeBacklog creates a backlog.

MakePool creates a pool.

MakeStreamToBatch creates a new stream to batch converter.

The list of all valid priority values.

The list of all valid priority values.

ErrShuttingDownError is the error returned when a job is not processed because the service is shutting down.

StreamToBatch makes batches from incoming stream of jobs, and submits the batches to the exec pool.

BacklogPool supports all the ExecutionPool functions plus few more that tests the pending tasks.

BatchProcessor is the interface of the functions needed to prepare a batch from the stream, process and return the results.

ExecutionPool interface exposes the core functionality of the execution pool.

InputJob is the interface the incoming jobs need to implement.

A ExecFunc is a unit of work to be executed by a Pool goroutine.

A Priority specifies a hint to the Pool to execute a Task at some priority.