in benchmark/benchserver/main.go [41:78]
func main() {
flag.Parse()
var adHosts []string
if len(*advertiseHosts) > 0 {
adHosts = strings.Split(*advertiseHosts, ",")
}
server := benchmark.NewServer(
benchmark.WithServiceName(*serviceName),
benchmark.WithAdvertiseHosts(adHosts),
)
fmt.Println(server.HostPort())
rdr := bufio.NewReader(os.Stdin)
for {
line, err := rdr.ReadString('\n')
if err != nil {
if err == io.EOF {
return
}
log.Fatalf("stdin read failed: %v", err)
}
line = strings.TrimSuffix(line, "\n")
switch line {
case "count-raw":
fmt.Println(server.RawCalls())
case "count-thrift":
fmt.Println(server.ThriftCalls())
case "quit":
return
default:
log.Fatalf("unrecognized command: %v", line)
}
}
}