foomo/contentserver
1
0
Fork 0
mirror of https://github.com/foomo/contentserver.git synced 2025-10-16 12:25:44 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

added flags to testclient, added optional getrepo call

Browse Source
This commit is contained in:
Philipp Mieden 2019-05-24 17:40:26 +02:00
parent 871c844f7b
commit a5ff003d8f
2 changed files with 42 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
repo/repo.go
View File

@ -100,7 +100,7 @@ func (repo *Repo) getNodes(nodeRequests map[string]*requests.Node, env *requests
for nodeName, nodeRequest := range nodeRequests { for nodeName, nodeRequest := range nodeRequests {
if nodeName == "" || nodeRequest.ID == "" { if nodeName == "" || nodeRequest.ID == "" {
Log.Error("invalid node request", zap.Error(errors.New("nodeName or nodeRequest.ID empty"))) Log.Info("invalid node request", zap.Error(errors.New("nodeName or nodeRequest.ID empty")))
continue continue
} }
Log.Debug("adding node", zap.String("name", nodeName), zap.String("requestID", nodeRequest.ID)) Log.Debug("adding node", zap.String("name", nodeName), zap.String("requestID", nodeRequest.ID))

54
testing/client/client.go
View File

@ -1,6 +1,7 @@
package main package main
import ( import (
"flag"
"log" "log"
"time" "time"
@ -8,24 +9,51 @@ import (
"github.com/foomo/contentserver/client" "github.com/foomo/contentserver/client"
) )
// https://globus-b.stage.mzg.bestbytes.net/contentserverapi
var (
flagAddr = flag.String("addr", "http://127.0.0.1:9191/contentserver", "set addr")
flagGetRepo = flag.Bool("getRepo", false, "get repo")
flagUpdate = flag.Bool("update", true, "trigger content update")
flagNum = flag.Int("num", 100, "num repititions")
flagDelay = flag.Int("delay", 2, "delay in seconds")
)
func main() { func main() {
serverAdr := "http://127.0.0.1:9191/contentserver"
c, errClient := client.NewHTTPClient(serverAdr) flag.Parse()
c, errClient := client.NewHTTPClient(*flagAddr)
if errClient != nil { if errClient != nil {
log.Fatal(errClient) log.Fatal(errClient)
} }
for i := 1; i <= 150; i++ { for i := 1; i <= *flagNum; i++ {
go func(num int) {
log.Println("start update") if *flagUpdate {
resp, errUpdate := c.Update() go func(num int) {
if errUpdate != nil { log.Println("start update")
spew.Dump(resp) resp, errUpdate := c.Update()
log.Fatal(errUpdate) if errUpdate != nil {
} spew.Dump(resp)
log.Println(num, "update done", resp) log.Fatal(errUpdate)
}(i) }
time.Sleep(2 * time.Second) log.Println(num, "update done", resp)
}(i)
}
if *flagGetRepo {
go func(num int) {
log.Println("get repo", num)
_, err := c.GetRepo()
if err != nil {
// spew.Dump(resp)
log.Fatal("failed to get repo")
}
log.Println(num, "get repo done")
}(i)
}
time.Sleep(time.Duration(*flagDelay) * time.Second)
} }
log.Println("done") log.Println("done")