Documentation
¶
Overview ¶
Package internal provides the core task queue management functionality.
Index ¶
- type Goque
- func (g *Goque) RegisterProcessor(processorType string, taskProcessor processor.TaskProcessor, ...)
- func (g *Goque) Run(ctx context.Context)
- func (g *Goque) Stop()
- func (g *Goque) TuneCleanerProcessor(opts ...commonopts.InternalProcessorOpt)
- func (g *Goque) TuneHealerProcessor(opts ...commonopts.InternalProcessorOpt)
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 (*Goque) RegisterProcessor ¶
func (g *Goque) RegisterProcessor( processorType string, taskProcessor processor.TaskProcessor, opts ...processor.GoqueProcessorOpts, )
RegisterProcessor registers a new task processor for a specific task type.
func (*Goque) Stop ¶
func (g *Goque) Stop()
Stop gracefully shuts down all registered processors and waits for them to finish.
func (*Goque) TuneCleanerProcessor ¶ added in v0.0.2
func (g *Goque) TuneCleanerProcessor(opts ...commonopts.InternalProcessorOpt)
TuneCleanerProcessor reconfigures the cleaner processor with new options.
func (*Goque) TuneHealerProcessor ¶ added in v0.0.2
func (g *Goque) TuneHealerProcessor(opts ...commonopts.InternalProcessorOpt)
TuneHealerProcessor reconfigures the healer processor with new options.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package commonopts provides common option types for configuring processors.
|
Package commonopts provides common option types for configuring processors. |
|
Package entity contains domain entities for the task queue system.
|
Package entity contains domain entities for the task queue system. |
|
Package internalprocessors provides internal task processors for queue management and maintenance.
|
Package internalprocessors provides internal task processors for queue management and maintenance. |
|
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.