Directories
¶
| Path | Synopsis |
|---|---|
|
Package entity contains domain entities for the task queue system.
|
Package entity contains domain entities for the task queue system. |
|
Package metrics provides Prometheus instrumentation for Goque task queue operations.
|
Package metrics provides Prometheus instrumentation for Goque task queue operations. |
|
pkg
|
|
|
generated/mocks/mock_periodicprocessor
Package mock_periodicprocessor is a generated GoMock package.
|
Package mock_periodicprocessor is a generated GoMock package. |
|
generated/mocks/mock_storages
Package mock_storages is a generated GoMock package.
|
Package mock_storages 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. |
|
periodicprocessor
Package periodicprocessor provides cron-based periodic job scheduling.
|
Package periodicprocessor provides cron-based periodic job scheduling. |
|
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 queuemanager provides high-level task queue management operations.
|
Package queuemanager provides high-level task queue management operations. |
|
Package storages provides interfaces and implementations for task storage backends.
|
Package storages provides interfaces and implementations for task storage backends. |
|
dbentity
Package dbentity provides common database entities and filters for task storage implementations.
|
Package dbentity provides common database entities and filters for task storage implementations. |
|
dbutils
Package dbutils provides common database utilities for task storage implementations.
|
Package dbutils provides common database utilities for task storage implementations. |
|
mysql/task
Package mysqltask provides MySQL storage operations for task management in the queue system.
|
Package mysqltask provides MySQL storage operations for task management in the queue system. |
|
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. |
|
sqlite
Package sqlite provides SQLite storage operations for task management in the queue system.
|
Package sqlite provides SQLite storage operations for task management in the queue system. |
|
utils
|
|
|
goquectx
Package goquectx provides utilities for managing task metadata within context values.
|
Package goquectx provides utilities for managing task metadata within context values. |
|
xcollections
Package xcollections provides thread-safe collection types.
|
Package xcollections provides thread-safe collection types. |
|
xpool
Package xpool provides a buffer pool for efficient memory reuse.
|
Package xpool provides a buffer pool for efficient memory reuse. |
|
xtime
Package xtime provides time-related utility functions.
|
Package xtime provides time-related utility functions. |
|
xtracer
Package xtracer provides OpenTelemetry tracing utilities for Goque.
|
Package xtracer provides OpenTelemetry tracing utilities for Goque. |
Click to show internal directories.
Click to hide internal directories.