func (s *storage) PushJobToQueue(queuePrefix, queueName string, j *job.Job) error {
	ctx := context.Background()
	_, _ = s.rds.SAdd(ctx, queuePrefix, queueName)
	_, err := s.rds.LPush(ctx, queueName, j.GetNameWithVersion())
	return err
}
PushJobToQueue push the job to the given redis queue
package redis
import (
	"context"
	"github.com/changsongl/delay-queue/job"
	"github.com/changsongl/delay-queue/pkg/redis"
	"time"
)