dave/youtube-downloader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change nsq ip

Browse Source
This commit is contained in:
PhatPhuckDave
2025-04-13 16:19:32 +02:00
parent 7adc1e2f8c
commit c859499676
2 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
downloader/downloaders/utils.go
View File

@@ -8,4 +8,4 @@ const OUTPUT_DIR = "C:/Users/Administrator/ytdlpVideos"
var ongoingDownloads = make(map[string]struct{}) var ongoingDownloads = make(map[string]struct{})
var ongoingDownloadsMutex = &sync.Mutex{} var ongoingDownloadsMutex = &sync.Mutex{}
const DOWNLOAD_WORKERS = 2 const DOWNLOAD_WORKERS = 4

11
downloader/main.go
View File

@@ -37,8 +37,8 @@ func init() {
} }
//var downloader downloaders.Downloader = &downloaders.YTDLPRawDownloader{} //var downloader downloaders.Downloader = &downloaders.YTDLPRawDownloader{}
var downloader downloaders.Downloader = &downloaders.KidaiDownloader{} // var downloader downloaders.Downloader = &downloaders.KidaiDownloader{}
//var downloader downloaders.Downloader = &downloaders.YTDLPLibDownloader{} var downloader downloaders.Downloader = &downloaders.YTDLPLibDownloader{}
type DLHandler struct{} type DLHandler struct{}
@@ -98,11 +98,14 @@ func main() {
consumer.AddHandler(&DLHandler{}) consumer.AddHandler(&DLHandler{})
} }
err = consumer.ConnectToNSQD("nsq.site.quack-lab.dev:41505") url := "192.168.1.123:41505"
log.Printf("Connecting to nsq at %s", url)
err = consumer.ConnectToNSQD(url)
if err != nil { if err != nil {
Error.Printf("Error connecting to nsqlookupd: %v", err) Error.Printf("Error connecting to nsq: %v", err)
return return
} }
log.Printf("Connected to nsq at %s", url)
sigChan := make(chan os.Signal, 1) sigChan := make(chan os.Signal, 1)
signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM) signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)