Documentation
¶
Index ¶
- type Options
- type RedisQueue
- func (r *RedisQueue) Clear(ctx context.Context, queueName string) error
- func (r *RedisQueue) Close() error
- func (r *RedisQueue) Delete(ctx context.Context, queueName string, jobID string) error
- func (r *RedisQueue) Get(ctx context.Context, queueName string, jobID string) (*queue.Job, error)
- func (r *RedisQueue) ProcessNext(ctx context.Context, queueName string) error
- func (r *RedisQueue) Push(ctx context.Context, queueName string, jobName string, ...) (string, error)
- func (r *RedisQueue) PushWithDelay(ctx context.Context, queueName string, jobName string, ...) (string, error)
- func (r *RedisQueue) Register(jobName string, handler queue.Handler)
- func (r *RedisQueue) Retry(ctx context.Context, queueName string, jobID string) error
- func (r *RedisQueue) Schedule(ctx context.Context, queueName string, jobName string, ...) (string, error)
- func (r *RedisQueue) Size(ctx context.Context, queueName string) (int, error)
- func (r *RedisQueue) StartWorker(ctx context.Context, queueName string, concurrency int) error
- func (r *RedisQueue) StopWorker(ctx context.Context, queueName string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
// Redis连接地址
Addr string
// Redis密码
Password string
// Redis数据库
DB int
// 最大重试次数
MaxRetries int
// 连接池大小
PoolSize int
}
Options Redis队列配置选项
type RedisQueue ¶
type RedisQueue struct {
// contains filtered or unexported fields
}
RedisQueue 是基于Redis的队列实现
func (*RedisQueue) Clear ¶
func (r *RedisQueue) Clear(ctx context.Context, queueName string) error
Clear 清空队列
func (*RedisQueue) ProcessNext ¶
func (r *RedisQueue) ProcessNext(ctx context.Context, queueName string) error
ProcessNext 处理队列中的下一个任务
func (*RedisQueue) Push ¶
func (r *RedisQueue) Push(ctx context.Context, queueName string, jobName string, payload map[string]interface{}) (string, error)
Push 将任务推送到队列
func (*RedisQueue) PushWithDelay ¶
func (r *RedisQueue) PushWithDelay(ctx context.Context, queueName string, jobName string, payload map[string]interface{}, delay time.Duration) (string, error)
PushWithDelay 延迟执行任务
func (*RedisQueue) Register ¶
func (r *RedisQueue) Register(jobName string, handler queue.Handler)
Register 注册任务处理器
func (*RedisQueue) Schedule ¶
func (r *RedisQueue) Schedule(ctx context.Context, queueName string, jobName string, payload map[string]interface{}, scheduledAt time.Time) (string, error)
Schedule 计划在特定时间执行任务
func (*RedisQueue) StartWorker ¶
StartWorker 启动工作进程
func (*RedisQueue) StopWorker ¶
func (r *RedisQueue) StopWorker(ctx context.Context, queueName string) error
StopWorker 停止工作进程
Source Files
Click to show internal directories.
Click to hide internal directories.