Directories
¶
| Path | Synopsis |
|---|---|
|
Package entity contains domain entities for the task queue system.
|
Package entity contains domain entities for the task queue system. |
|
pkg
|
|
|
generated/mocks/mock_processors/queueprocessor
Package mock_queueprocessor is a generated GoMock package.
|
Package mock_queueprocessor is a generated GoMock package. |
|
processors
|
|
|
internalprocessors
Package internalprocessors provides internal task processors for queue management including cleaning and healing operations.
|
Package internalprocessors provides internal task processors for queue management including cleaning and healing operations. |
|
queueprocessor
Package queueprocessor provides task queue processing functionality with configurable workers and retry logic.
|
Package queueprocessor 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
|
|
|
sql/pg/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. |
|
sql/pg/utils
Package sqlpgutils provides database utility functions and helpers.
|
Package sqlpgutils provides database utility functions and helpers. |
|
sql/utils
Package sqldbutils provides database utilities for transaction management and common database operations.
|
Package sqldbutils provides database utilities for transaction management and common database operations. |
|
utils
|
|
|
xtime
Package xtime provides time-related utility functions.
|
Package xtime provides time-related utility functions. |
Click to show internal directories.
Click to hide internal directories.