Fix fmt error

Signed-off-by: Bin Shi <binshi.bing@gmail.com>
tikv · May 15, 2023 · e6f3f4e · e6f3f4e
1 parent c66370d
commit e6f3f4e
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 12 deletions.
diff --git a/pkg/tso/allocator_manager.go b/pkg/tso/allocator_manager.go
@@ -46,13 +46,13 @@ import (
 
 const (
 	// GlobalDCLocation is the Global TSO Allocator's DC location label.
-	GlobalDCLocation            = "global"
-	checkStep                   = time.Minute
-	patrolStep                  = time.Second
-	defaultAllocatorLeaderLease = 3
+	GlobalDCLocation             = "global"
+	checkStep                    = time.Minute
+	patrolStep                   = time.Second
+	defaultAllocatorLeaderLease  = 3
 	globalTSOAllocatorEtcdPrefix = "gta"
-	localTSOAllocatorEtcdPrefix = "lta"
-	localTSOSuffixEtcdPrefix    = "lts"
+	localTSOAllocatorEtcdPrefix  = "lta"
+	localTSOSuffixEtcdPrefix     = "lts"
 )
 
 var (

diff --git a/pkg/tso/global_allocator.go b/pkg/tso/global_allocator.go
@@ -27,7 +27,6 @@ import (
 	"github.com/pingcap/kvproto/pkg/pdpb"
 	"github.com/pingcap/log"
 	"github.com/tikv/pd/pkg/errs"
-	"github.com/tikv/pd/pkg/mcs/utils"
 	mcsutils "github.com/tikv/pd/pkg/mcs/utils"
 	"github.com/tikv/pd/pkg/slice"
 	"github.com/tikv/pd/pkg/utils/logutil"
@@ -96,7 +95,7 @@ func NewGlobalTSOAllocator(
 	// 2. for the non-default keyspace groups:
 	//     {group}/gta in /ms/{cluster_id}/tso/{group}/gta/timestamp
 	tsPath := ""
-	if am.kgID != utils.DefaultKeyspaceGroupID {
+	if am.kgID != mcsutils.DefaultKeyspaceGroupID {
 		tsPath = path.Join(fmt.Sprintf("%05d", am.kgID), globalTSOAllocatorEtcdPrefix)
 	}
 

diff --git a/tests/integrations/mcs/tso/keyspace_group_manager_test.go b/tests/integrations/mcs/tso/keyspace_group_manager_test.go
@@ -201,7 +201,6 @@ func (suite *tsoKeyspaceGroupManagerTestSuite) TestKeyspacesServedByNonDefaultKe
 						} else {
 							timestampPath = fmt.Sprintf("/ms/%s/tso/%05d/gta/timestamp",
 								clusterID, param.keyspaceGroupID)
-
 						}
 						re.Equal(timestampPath, am.GetTimestampPath(""))
 

diff --git a/tests/integrations/tso/client_test.go b/tests/integrations/tso/client_test.go
@@ -16,7 +16,6 @@ package tso
 
 import (
 	"context"
-	"fmt"
 	"math"
 	"math/rand"
 	"strings"
@@ -140,8 +139,6 @@ func (suite *tsoClientTestSuite) SetupSuite() {
 
 		suite.waitForAllKeyspaceGroupsInServing(re)
 	}
-
-	fmt.Println("TestSuite Setup Done !!!!!!!!!!!!!!!!!!!!!")
 }
 
 func (suite *tsoClientTestSuite) waitForAllKeyspaceGroupsInServing(re *require.Assertions) {