package handler import ( "log" "main/jobs" "github.com/hibiken/asynq" ) func startWorkerHelmInstaller() { srv := asynq.NewServer( asynq.RedisClientOpt{Addr: "130.185.77.247:30828", Password: "xwy8ahx46F"}, asynq.Config{Concurrency: 5}, ) mux := asynq.NewServeMux() mux.HandleFunc(jobs.TypeInstallChart, jobs.HandleInstallCahrt) if err := srv.Run(mux); err != nil { log.Fatalf("Could not run worker: %v", err) } }