disable retry in grpc connect and grpc sendMsg (#26258)

Signed-off-by: N Wei Liu <wei.liu@zilliz.com>

disable retry in grpc connect and grpc sendMsg (#26258)
Signed-off-by: N Wei Liu <wei.liu@zilliz.com>
42cb5d12 · wei liu · GitHub · aa92f8fd · 42cb5d12
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

internal/util/grpcclient/client.go internal/util/grpcclient/client.go +4 -0

未找到文件。
--- a/internal/util/grpcclient/client.go
+++ b/internal/util/grpcclient/client.go
@@ -215,6 +215,8 @@ func (c *ClientBase[T]) connect(ctx context.Context) error {
 				MinConnectTimeout: c.DialTimeout,
 			}),
 			grpc.WithPerRPCCredentials(&Token{Value: crypto.Base64Encode(util.MemberCredID)}),
+			grpc.WithDisableRetry(),
+			grpc.FailOnNonTempDialError(true),
 		)
 	} else {
 		conn, err = grpc.DialContext(
@@ -250,6 +252,8 @@ func (c *ClientBase[T]) connect(ctx context.Context) error {
 				MinConnectTimeout: c.DialTimeout,
 			}),
 			grpc.WithPerRPCCredentials(&Token{Value: crypto.Base64Encode(util.MemberCredID)}),
+			grpc.WithDisableRetry(),
+			grpc.FailOnNonTempDialError(true),
 		)
 	}