From 72bd03c6a9c4eddc9a9f66d400d04bc199573ca1 Mon Sep 17 00:00:00 2001 From: citrusreticulata <1372722289@qq.com> Date: Fri, 30 Dec 2022 16:27:35 +0800 Subject: [PATCH] fix a typo. "DefualtConnectRetryMax" --> "DefaultConnectRetryMax" fix a typo. "DefualtConnectRetryMax" --> "DefaultConnectRetryMax" --- client/session.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/client/session.go b/client/session.go index 84c6ac5..17a3c9e 100644 --- a/client/session.go +++ b/client/session.go @@ -40,7 +40,7 @@ import ( const ( DefaultTimeZone = "Asia/Shanghai" DefaultFetchSize = 1024 - DefualtConnectRetryMax = 3 + DefaultConnectRetryMax = 3 ) var errLength = errors.New("deviceIds, times, measurementsList and valuesList's size should be equal") @@ -79,7 +79,7 @@ func (s *Session) Open(enableRPCCompression bool, connectionTimeoutInMs int) err } if s.config.ConnectRetryMax <= 0 { - s.config.ConnectRetryMax = DefualtConnectRetryMax + s.config.ConnectRetryMax = DefaultConnectRetryMax } var protocolFactory thrift.TProtocolFactory @@ -145,7 +145,7 @@ func (s *Session) OpenCluster(enableRPCCompression bool) error { } if s.config.ConnectRetryMax <= 0 { - s.config.ConnectRetryMax = DefualtConnectRetryMax + s.config.ConnectRetryMax = DefaultConnectRetryMax } var protocolFactory thrift.TProtocolFactory @@ -1059,7 +1059,7 @@ func (s *Session) initClusterConn(node endPoint) error { } if s.config.ConnectRetryMax < 1 { - s.config.ConnectRetryMax = DefualtConnectRetryMax + s.config.ConnectRetryMax = DefaultConnectRetryMax } var protocolFactory thrift.TProtocolFactory