queue

type FailedJob struct {
	Job   *Job
	Error string
	Time  time.Time
}

type Handler interface {
	Handle(ctx context.Context, job *Job) error
}

type Job struct {
	ID        string                 `json:"id"`
	Queue     string                 `json:"queue"`
	Handler   string                 `json:"handler"`
	Payload   map[string]interface{} `json:"payload"`
	Attempts  int                    `json:"attempts"`
	MaxTries  int                    `json:"max_tries"`
	Timeout   time.Duration          `json:"timeout"`
	CreatedAt time.Time              `json:"created_at"`
	StartedAt *time.Time             `json:"started_at,omitempty"`
}

type JobError struct {
	Message string
}

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

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

type Queue interface {
	// Push adds a job to the queue
	Push(ctx context.Context, job *Job) error
	// Pop retrieves a job from the queue
	Pop(ctx context.Context, queue string) (*Job, error)
	// Ack acknowledges job completion
	Ack(ctx context.Context, job *Job) error
	// Fail marks a job as failed
	Fail(ctx context.Context, job *Job, err error) error
	// Retry requeues a failed job
	Retry(ctx context.Context, jobID string) error
	// Failed returns failed jobs
	Failed(ctx context.Context, limit int) ([]*Job, error)
	// Close closes the queue connection
	Close() error
}

type RedisClient interface {
	RPush(ctx context.Context, key string, values ...interface{}) error
	BLPop(ctx context.Context, timeout time.Duration, keys ...string) ([]string, error)
	LPush(ctx context.Context, key string, values ...interface{}) error
	LRange(ctx context.Context, key string, start, stop int64) ([]string, error)
	Del(ctx context.Context, keys ...string) error
	Close() error
}

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