package
0.0.0-20200501183948-beb54cfcb8cf
Repository: https://github.com/mnikita/task-queue.git
Documentation: pkg.go.dev
# Functions
GetRegisteredTaskHandler retrieves TaskHandlers by name.Task request payload is unmarshalled to initialize TaskHandler.
GetRegisteredTasks returns slice with all task names registered.
No description provided by the author
No description provided by the author
No description provided by the author
RegisterTask registers tasks by name and stores TaskConstructor for TaskHandler instances creation.
# Structs
BaseTaskHandler is base primitive for final tasks implementations.It is a default implementation of TaskHandler interface.
Task struct contains task requests data.
TaskProcessEvent struct contains task process event data.
TaskThreadError is default error thrown during task processing.
# Interfaces
TaskHandler handles task requests.
TaskPayloadHandler handles consumer task payload.TaskPayloadHandler implementation dispatches consumer requests to worker queue.
TaskProcessEventHandler handles events arising from final task processing.
TaskQueueEventHandler handles task queue events.
# Type aliases
TaskConstructor creates TaskHandler instances.
TaskHandlerFunc is helper class for creating short task implementation containing one processing function.