From c46b96d455c68a98e437dd4e835bb2fcea62f662 Mon Sep 17 00:00:00 2001 From: DengBiao <2319963317@qq.com> Date: Mon, 19 Sep 2022 23:43:09 +0800 Subject: [PATCH] udpate --- pkg/rpc/rpc.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/rpc/rpc.go b/pkg/rpc/rpc.go index 61559ca..f5f095b 100644 --- a/pkg/rpc/rpc.go +++ b/pkg/rpc/rpc.go @@ -40,7 +40,7 @@ func GetBusinessIntClient() pb.BusinessIntClient { } func initLogicIntClient() { - conn, err := grpc.DialContext(context.TODO(), k8s.GetK8STarget("default", "logic", "8000"), grpc.WithInsecure(), + conn, err := grpc.DialContext(context.TODO(), k8s.GetK8STarget("gim", "logic", "8000"), grpc.WithInsecure(), grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, roundrobin.Name))) if err != nil { panic(err) @@ -49,7 +49,7 @@ func initLogicIntClient() { } func initConnectIntClient() { - conn, err := grpc.DialContext(context.TODO(), k8s.GetK8STarget("default", "connect", "8000"), grpc.WithInsecure(), + conn, err := grpc.DialContext(context.TODO(), k8s.GetK8STarget("gim", "connect", "8000"), grpc.WithInsecure(), grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, picker.AddrPickerName))) if err != nil { panic(err) @@ -58,7 +58,7 @@ func initConnectIntClient() { } func initBusinessIntClient() { - conn, err := grpc.DialContext(context.TODO(), k8s.GetK8STarget("default", "business", "8000"), grpc.WithInsecure(), + conn, err := grpc.DialContext(context.TODO(), k8s.GetK8STarget("gim", "business", "8000"), grpc.WithInsecure(), grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, roundrobin.Name))) if err != nil { panic(err)