senaduka/old-kiviscrapbalancer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use worker server

Browse Source
This commit is contained in:
Senad Uka
2020-03-18 20:42:16 +01:00
parent 289d6238d0
commit 2d1f226ab7
1 changed files with 3 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
main.go
View File

@@ -4,6 +4,7 @@ import (
"github.com/sevlyar/go-daemon" "github.com/sevlyar/go-daemon"
"gitlab.com/saburly/kiviscraplib/structures" "gitlab.com/saburly/kiviscraplib/structures"
"gitlab.com/saburly/kiviscraplib/webserver" "gitlab.com/saburly/kiviscraplib/webserver"
"gitlab.com/saburly/kiviscraplib/workerserver"
"log" "log"
) )
@@ -37,20 +38,9 @@ func main() {
end = make(chan string) end = make(chan string)
go webserver.ServeHTTP(queue, end) go webserver.ServeHTTP(queue, end)
go func() { go workerserver.ServeWorkers(queue, end)
for {
request := <-queue
//time.Sleep(2 * time.Second)
response := structures.Response{
Url: request.Url,
Content: []byte("<html><body><h1>Bla!</h1></body><html>"),
Err: nil,
}
request.Response <- response
}
}()
ended := <-end ended := <-end
log.Printf("%s ended so closing the daemon", ended) log.Printf("%s ended so closing the daemon\n", ended)
} }