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.

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.

FIFOTaskSchedulerOptions configs FIFO task 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.

WeightedRoundRobinTaskSchedulerOptions configs WRR task scheduler.