waiting_service

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 17, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(
	preloadedTasks <-chan domain.Task,
	monitoring contracts.MonitoringInterface,
	taskManager contracts.TaskManagerInterface,
	eventHandler contracts.EventHandlerInterface,
	options *Options,
) contracts.WaitingServiceInterface

func NewPrioritizedTask added in v1.1.0

func NewPrioritizedTask(tasks []domain.Task) prioritizedTaskListInterface

Types

type Options

type Options struct {
	TasksReadyToSendCap   int //Deprecated
	CanceledTasksCap      int //Deprecated
	GreedyProcessingLimit int
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL