Documentation
¶
Index ¶
- type FileWorkerDriver
- func (f *FileWorkerDriver) Close() error
- func (f *FileWorkerDriver) Enqueue(job worker_interfaces.Job, params interface{}) error
- func (f *FileWorkerDriver) Init(app *core.App, config interface{}) error
- func (f *FileWorkerDriver) JobHandlerExists(handler worker_interfaces.Job) bool
- func (f *FileWorkerDriver) Name() string
- func (f *FileWorkerDriver) RegisterJobHandlers(handlers ...worker_interfaces.Job)
- func (f *FileWorkerDriver) Run(handlers ...worker_interfaces.Job) error
- type RedisWorkerDriver
- func (r *RedisWorkerDriver) Close() error
- func (r *RedisWorkerDriver) Enqueue(job worker_interfaces.Job, params interface{}) error
- func (r *RedisWorkerDriver) Init(app *core.App, config interface{}) error
- func (r *RedisWorkerDriver) JobHandlerExists(handler worker_interfaces.Job) bool
- func (r *RedisWorkerDriver) Name() string
- func (r *RedisWorkerDriver) RegisterJobHandlers(handlers ...worker_interfaces.Job)
- func (r *RedisWorkerDriver) Run(handlers ...worker_interfaces.Job) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileWorkerDriver ¶
type FileWorkerDriver struct {
// contains filtered or unexported fields
}
FileWorkerDriver represents a worker driver that manages tasks using a file.
func (*FileWorkerDriver) Close ¶
func (f *FileWorkerDriver) Close() error
Close performs any necessary cleanup for the FileWorkerDriver.
func (*FileWorkerDriver) Enqueue ¶
func (f *FileWorkerDriver) Enqueue(job worker_interfaces.Job, params interface{}) error
Enqueue adds a new job to the file queue.
func (*FileWorkerDriver) Init ¶
func (f *FileWorkerDriver) Init(app *core.App, config interface{}) error
Init initializes the worker driver with the application and configuration.
func (*FileWorkerDriver) JobHandlerExists ¶
func (f *FileWorkerDriver) JobHandlerExists(handler worker_interfaces.Job) bool
JobHandlerExists checks if a specific job handler is already registered.
func (*FileWorkerDriver) Name ¶
func (f *FileWorkerDriver) Name() string
Name returns the name of the worker driver.
func (*FileWorkerDriver) RegisterJobHandlers ¶
func (f *FileWorkerDriver) RegisterJobHandlers(handlers ...worker_interfaces.Job)
RegisterJobHandlers adds multiple job handlers to the worker driver.
func (*FileWorkerDriver) Run ¶
func (f *FileWorkerDriver) Run(handlers ...worker_interfaces.Job) error
Run starts processing the tasks with registered job handlers.
type RedisWorkerDriver ¶
type RedisWorkerDriver struct {
// contains filtered or unexported fields
}
func (*RedisWorkerDriver) Close ¶
func (r *RedisWorkerDriver) Close() error
func (*RedisWorkerDriver) Enqueue ¶
func (r *RedisWorkerDriver) Enqueue(job worker_interfaces.Job, params interface{}) error
func (*RedisWorkerDriver) Init ¶
func (r *RedisWorkerDriver) Init(app *core.App, config interface{}) error
func (*RedisWorkerDriver) JobHandlerExists ¶
func (r *RedisWorkerDriver) JobHandlerExists(handler worker_interfaces.Job) bool
JobHandlerExists checks if a specific job handler is already registered.
func (*RedisWorkerDriver) Name ¶
func (r *RedisWorkerDriver) Name() string
func (*RedisWorkerDriver) RegisterJobHandlers ¶
func (r *RedisWorkerDriver) RegisterJobHandlers(handlers ...worker_interfaces.Job)
RegisterJobHandlers adds multiple job handlers to the worker driver.
func (*RedisWorkerDriver) Run ¶
func (r *RedisWorkerDriver) Run(handlers ...worker_interfaces.Job) error
Source Files
Click to show internal directories.
Click to hide internal directories.