NewFIFOTaskScheduler creates a new FIFO task scheduler it's an no-op implementation as it simply copy tasks from one task channel to another task channel.

NewMockPriorityTask creates a new mock instance.

NewMockProcessor creates a new mock instance.

NewMockScheduler creates a new mock instance.

NewMockSequentialTaskQueue creates a new mock instance.

NewMockTask creates a new mock instance.

NewParallelTaskProcessor creates a new PriorityTaskProcessor.

NewSequentialTaskProcessor create a new sequential tasks processor.

NewWeightedRoundRobinTaskScheduler creates a new WRR task scheduler.

NoPriority is the value returned if no priority is ever assigned to the task.

SchedulerTypeFIFO is the scheduler type for FIFO scheduler implementation.

SchedulerTypeWRR is the scheduler type for weighted round robin scheduler implementation.

TaskStateAcked is the state for a task if it has been successfully completed.

TaskStateNacked is the state for a task if it can not be processed.

TaskStatePending is the state for a task when it's waiting to be processed or currently being processed.

ErrTaskProcessorClosed is the error returned when submiting task to a stopped processor.

ErrTaskSchedulerClosed is the error returned when submitting task to a stopped scheduler.

MockPriorityTask is a mock of PriorityTask interface.

MockPriorityTaskMockRecorder is the mock recorder for MockPriorityTask.

MockProcessor is a mock of Processor interface.

MockProcessorMockRecorder is the mock recorder for MockProcessor.

MockScheduler is a mock of Scheduler interface.

MockSchedulerMockRecorder is the mock recorder for MockScheduler.

MockSequentialTaskQueue is a mock of SequentialTaskQueue interface.

MockSequentialTaskQueueMockRecorder is the mock recorder for MockSequentialTaskQueue.

MockTask is a mock of Task interface.

MockTaskMockRecorder is the mock recorder for MockTask.