overflow_backup_2018_0455/rpc_network_crawler_go
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

of_rpc => grpc

Browse Source
This commit is contained in:
jackdaw@loafle.com 2017-04-12 21:03:20 +09:00
parent faadbe2552
commit 8bba2fff61
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
network_crawler_test.go
View File

@ -17,7 +17,7 @@ import (
type call func() crawler.Crawler
func initRPCServer(cc call) {
func startRPCServerTest(cc call) {
rr:=cc()
AddDelegate(pb.Crawlers_HEALTH_REDIS.String(),rr)
go start(&ConfigServer{},&DataServer{})
@ -49,7 +49,7 @@ func clientCall(t *testing.T,cl pb.Crawlers) {
func TestRedisGRPC(t *testing.T) {
go initRPCServer( func() crawler.Crawler {
go startRPCServerTest( func() crawler.Crawler {
rr := redis_protocol_crawler_go.NewRedisHeahthCrawler()
m := make(map[string]interface{}, 0)
m["ip"] = "192.168.1.104"