queue

type Handler func(ctx context.Context, job *Job) error

type Job struct {
	ID          string                 `json:"id"`                     // 任务唯一标识
	Queue       string                 `json:"queue"`                  // 所属队列
	Name        string                 `json:"name"`                   // 任务名称
	Payload     map[string]interface{} `json:"payload"`                // 任务负载数据
	Attempts    int                    `json:"attempts"`               // 尝试次数
	MaxRetries  int                    `json:"max_retries"`            // 最大重试次数
	Status      JobStatus              `json:"status"`                 // 任务状态
	CreatedAt   time.Time              `json:"created_at"`             // 创建时间
	UpdatedAt   time.Time              `json:"updated_at"`             // 更新时间
	ScheduledAt *time.Time             `json:"scheduled_at,omitempty"` // 计划执行时间
	StartedAt   *time.Time             `json:"started_at,omitempty"`   // 开始执行时间
	FinishedAt  *time.Time             `json:"finished_at,omitempty"`  // 完成时间
	Error       string                 `json:"error,omitempty"`        // 错误信息
}

type JobStatus string

type Queue interface {
	// Push 将任务推送到队列
	Push(ctx context.Context, queueName string, jobName string, payload map[string]interface{}) (string, error)

	// PushWithDelay 将任务推送到队列，延迟指定时间后执行
	PushWithDelay(ctx context.Context, queueName string, jobName string, payload map[string]interface{}, delay time.Duration) (string, error)

	// Schedule 计划一个任务在指定时间执行
	Schedule(ctx context.Context, queueName string, jobName string, payload map[string]interface{}, scheduledAt time.Time) (string, error)

	// Get 获取任务信息
	Get(ctx context.Context, queueName string, jobID string) (*Job, error)

	// Delete 删除任务
	Delete(ctx context.Context, queueName string, jobID string) error

	// Clear 清空队列
	Clear(ctx context.Context, queueName string) error

	// Size 获取队列大小
	Size(ctx context.Context, queueName string) (int, error)

	// Register 注册任务处理器
	Register(jobName string, handler Handler)

	// ProcessNext 处理队列中的下一个任务
	ProcessNext(ctx context.Context, queueName string) error

	// StartWorker 启动工作进程处理任务
	StartWorker(ctx context.Context, queueName string, concurrency int) error

	// StopWorker 停止工作进程
	StopWorker(ctx context.Context, queueName string) error

	// Retry 重试失败的任务
	Retry(ctx context.Context, queueName string, jobID string) error
}

type QueueEventListener struct {
	// contains filtered or unexported fields
}

type QueueEventProvider struct {
	// contains filtered or unexported fields
}

type QueueManager struct {
	// contains filtered or unexported fields
}

type QueueMiddleware func(next Handler) Handler