Documentation
¶
Overview ¶
Package internal provides the core task queue management functionality.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Goque ¶
type Goque struct {
// contains filtered or unexported fields
}
Goque is the main task queue manager that coordinates multiple task processors.
func NewGoque ¶
func NewGoque(taskStorage processor.TaskStorage) *Goque
NewGoque creates a new Goque instance with the specified task storage.
func (*Goque) RegisterProcessor ¶
func (g *Goque) RegisterProcessor( taskType string, taskProcessor processor.TaskProcessor, opts ...processor.GoqueProcessorOpts, )
RegisterProcessor registers a new task processor for a specific task type.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package entity contains domain entities for the task queue system.
|
Package entity contains domain entities for the task queue system. |
|
pkg
|
|
|
dbmodels
command
|
|
|
generated/mocks/mock_processor
Package mock_processor is a generated GoMock package.
|
Package mock_processor is a generated GoMock package. |
|
Package processor provides task queue processing functionality with configurable workers and retry logic.
|
Package processor provides task queue processing functionality with configurable workers and retry logic. |
|
Package queuemngr provides queue management functionality for adding tasks to storage.
|
Package queuemngr provides queue management functionality for adding tasks to storage. |
|
storages
|
|
|
dbutils
Package dbutils provides database utilities for connection management and transactions.
|
Package dbutils provides database utilities for connection management and transactions. |
|
task
Package task provides storage operations for task management in the queue system.
|
Package task provides storage operations for task management in the queue system. |
Click to show internal directories.
Click to hide internal directories.