ing

main.go

@@ -14,7 +14,10 @@ func main() {
 	registry := cRPC.NewRegistry()
 	registry.RegisterService(new(rpc.DiscoveryService), "")
 
-	c := client.New("/tmp/discovery.sock", registry)
+	ch := client.NewClientHandler(registry)
+	sb := client.NewSocketBuilder("/tmp/discovery.sock")
+	c := client.New(ch, sb)
+
 	if err := c.Connect(); nil != err {
 		fmt.Printf("%v", err)
 	}