FranklinWH-Toolbox/service/task/task.go

package task

import (
	"fwh-toolbox-server/config"
	task_core "fwh-toolbox-server/task/core"
	taskQueue "fwh-toolbox-server/task/queue"

	"github.com/hibiken/asynq"
)

type TaskRedisOpt struct {
	Addr     string
	DB       int
	Username string
	Password string
}

func InitTask(redisOpt TaskRedisOpt, appConfig *config.AppConfig) {
	redisClientOpt := asynq.RedisClientOpt{
		Addr:     redisOpt.Addr,
		DB:       redisOpt.DB,
		Username: redisOpt.Username,
		Password: redisOpt.Password,
	}

	tc := task_core.NewTaskCore(redisClientOpt)

	taskQueue.InitTaskQueue(tc, appConfig)
}