queue

type Job struct {
	ID      string        `json:"id"`
	Payload []byte        `json:"payload"`
	Delay   time.Duration `json:"delay"`
}

type QueueOptions struct {
	Names             map[string]int
	Type              string
	RedisClient       *rdb.Redis
	RedisAddress      []string
	PrometheusAddress string
}

type Queuer interface {
	Write(convoy.TaskName, convoy.QueueName, *Job) error
	Options() QueueOptions
}