From 7d640c41f44cac95852a2a68828c22c6c28e1f6d Mon Sep 17 00:00:00 2001 From: Electronic-Waste <2690692950@qq.com> Date: Sat, 11 Jan 2025 07:45:03 +0000 Subject: [PATCH] refactor(grpc): remove deprecated grpc.Dial implementation. Signed-off-by: Electronic-Waste <2690692950@qq.com> --- cmd/metricscollector/v1beta1/file-metricscollector/main.go | 4 ++-- pkg/common/v1beta1/katib_manager_util.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/metricscollector/v1beta1/file-metricscollector/main.go b/cmd/metricscollector/v1beta1/file-metricscollector/main.go index c91a18060bc..e3323df40ce 100644 --- a/cmd/metricscollector/v1beta1/file-metricscollector/main.go +++ b/cmd/metricscollector/v1beta1/file-metricscollector/main.go @@ -311,7 +311,7 @@ func watchMetricsFile(mFile string, stopRules stopRulesFlag, filters []string, f } // Create connection and client for Early Stopping service. - conn, err := grpc.Dial(*earlyStopServiceAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) + conn, err := grpc.NewClient(*earlyStopServiceAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { klog.Fatalf("Could not connect to Early Stopping service, error: %v", err) } @@ -433,7 +433,7 @@ func main() { func reportMetrics(filters []string, fileFormat commonv1beta1.FileFormat) { - conn, err := grpc.Dial(*dbManagerServiceAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) + conn, err := grpc.NewClient(*dbManagerServiceAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { klog.Fatalf("Could not connect to DB manager service, error: %v", err) } diff --git a/pkg/common/v1beta1/katib_manager_util.go b/pkg/common/v1beta1/katib_manager_util.go index 3345f45b124..7bee281cf25 100644 --- a/pkg/common/v1beta1/katib_manager_util.go +++ b/pkg/common/v1beta1/katib_manager_util.go @@ -46,7 +46,7 @@ func GetDBManagerAddr() string { func getKatibDBManagerClientAndConn() (*katibDBManagerClientAndConn, error) { addr := GetDBManagerAddr() - conn, err := grpc.Dial(addr, grpc.WithTransportCredentials(insecure.NewCredentials())) + conn, err := grpc.NewClient(addr, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { return nil, err }