goq

type ConnectionOptions struct {
	Addr         string
	Password     string
	DB           int64
	MaxRetries   int
	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	PoolSize     int
	PoolTimeout  time.Duration
	IdleTimeout  time.Duration
}

type ErrorHandler func(error)

type Job struct {
	ID     string
	JSON   string
	Status *Status
}

type Options struct {
	Connection   *ConnectionOptions
	Concurrency  uint8
	QueueName    string
	Processor    Processor
	ErrorHandler ErrorHandler
}

type Processor func(*Job)

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

type QueueStatus struct {
	QueueLength int64
}

type Status struct {
	Code     uint8
	Progress uint8
}