Skip to content

Commit

Permalink
update kvproto
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Sep 7, 2023
1 parent 9a30a83 commit dc3d3cf
Show file tree
Hide file tree
Showing 18 changed files with 93 additions and 68 deletions.
2 changes: 1 addition & 1 deletion client/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -41,4 +41,4 @@ require (
gopkg.in/yaml.v3 v3.0.1 // indirect
)

replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097
replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38
4 changes: 2 additions & 2 deletions client/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -117,8 +117,8 @@ github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsT
github.com/prometheus/procfs v0.1.3/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4OA4YeYWdaU=
github.com/prometheus/procfs v0.6.0 h1:mxy4L2jP6qMonqmq+aTtOx1ifVWUgG/TAmntgbh3xv4=
github.com/prometheus/procfs v0.6.0/go.mod h1:cz+aTbrPOrUb4q7XlbU9ygM+/jj0fzG6c1xBZuNvfVA=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097 h1:luEk8MEptO8Fop2EfHqY0bsIBtGZh8Qb0eVEz3tjYG8=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38 h1:8vBwN7w7keTO+sBESkGVHM0bWAvOtc5eEEDaRR7ufbE=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/sergi/go-diff v1.1.0/go.mod h1:STckp+ISIX8hZLjrqAeVduY0gWCT9IjLuqbuNXdaHfM=
github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
github.com/sirupsen/logrus v1.4.2/go.mod h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6MwdIuYE2rE=
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -206,4 +206,4 @@ replace google.golang.org/grpc v1.54.0 => google.golang.org/grpc v1.26.0
// After the PR to kvproto is merged, remember to comment this out and run `go mod tidy`.
// replace github.com/pingcap/kvproto => github.com/$YourPrivateRepo $YourPrivateBranch

replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097
replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -489,8 +489,8 @@ github.com/prometheus/procfs v0.1.3/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4O
github.com/prometheus/procfs v0.6.0 h1:mxy4L2jP6qMonqmq+aTtOx1ifVWUgG/TAmntgbh3xv4=
github.com/prometheus/procfs v0.6.0/go.mod h1:cz+aTbrPOrUb4q7XlbU9ygM+/jj0fzG6c1xBZuNvfVA=
github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097 h1:luEk8MEptO8Fop2EfHqY0bsIBtGZh8Qb0eVEz3tjYG8=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38 h1:8vBwN7w7keTO+sBESkGVHM0bWAvOtc5eEEDaRR7ufbE=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
Expand Down
25 changes: 3 additions & 22 deletions pkg/mcs/scheduling/server/cluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,9 @@ import (

"github.com/pingcap/errors"
"github.com/pingcap/kvproto/pkg/pdpb"
"github.com/pingcap/kvproto/pkg/schedulingpb"
"github.com/pingcap/log"
"github.com/tikv/pd/pkg/core"
"github.com/tikv/pd/pkg/core/storelimit"
"github.com/tikv/pd/pkg/errs"
"github.com/tikv/pd/pkg/mcs/scheduling/server/config"
"github.com/tikv/pd/pkg/schedule"
sc "github.com/tikv/pd/pkg/schedule/config"
Expand Down Expand Up @@ -188,35 +187,17 @@ func (c *Cluster) getStoresWithoutLabelLocked(region *core.RegionInfo, key, valu
}

// HandleStoreHeartbeat updates the store status.
func (c *Cluster) HandleStoreHeartbeat(heartbeat *pdpb.StoreHeartbeatRequest) error {
func (c *Cluster) HandleStoreHeartbeat(heartbeat *schedulingpb.StoreHeartbeatRequest) error {
stats := heartbeat.GetStats()
storeID := stats.GetStoreId()
store := c.GetStore(storeID)
if store == nil {
return errors.Errorf("store %v not found", storeID)
}

limit := store.GetStoreLimit()
if limit == nil {
limit = storelimit.NewStoreRateLimit(0.0)
}

nowTime := time.Now()
newStore := store.Clone(core.SetStoreStats(stats), core.SetLastHeartbeatTS(nowTime), core.SetStoreLimit(limit))
newStore := store.Clone(core.SetStoreStats(stats), core.SetLastHeartbeatTS(nowTime))

if newStore.IsLowSpace(c.persistConfig.GetLowSpaceRatio()) {
log.Warn("store does not have enough disk space",
zap.Uint64("store-id", storeID),
zap.Uint64("capacity", newStore.GetCapacity()),
zap.Uint64("available", newStore.GetAvailable()))
}
if newStore.NeedPersist() && c.storage != nil {
if err := c.storage.SaveStoreMeta(newStore.GetMeta()); err != nil {
log.Error("failed to persist store", zap.Uint64("store-id", storeID), errs.ZapError(err))
} else {
newStore = newStore.Clone(core.SetLastPersistTime(nowTime))
}
}
if store := c.GetStore(storeID); store != nil {
statistics.UpdateStoreHeartbeatMetrics(store)
}
Expand Down
23 changes: 8 additions & 15 deletions pkg/mcs/scheduling/server/grpc_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@ import (
"context"
"net/http"

"github.com/pingcap/kvproto/pkg/pdpb"
"github.com/pingcap/kvproto/pkg/schedulingpb"
"github.com/pingcap/log"
bs "github.com/tikv/pd/pkg/basicserver"
Expand Down Expand Up @@ -69,35 +68,29 @@ func NewService[T ConfigProvider](svr bs.Server) registry.RegistrableService {
}

// StoreHeartbeat implements gRPC PDServer.
func (s *Service) StoreHeartbeat(ctx context.Context, request *pdpb.StoreHeartbeatRequest) (*pdpb.StoreHeartbeatResponse, error) {
func (s *Service) StoreHeartbeat(ctx context.Context, request *schedulingpb.StoreHeartbeatRequest) (*schedulingpb.StoreHeartbeatResponse, error) {
c := s.GetCluster()
if c == nil {
// ignore the error
return &pdpb.StoreHeartbeatResponse{}, nil
return &schedulingpb.StoreHeartbeatResponse{Header: &schedulingpb.ResponseHeader{ClusterId: s.clusterID}}, nil
}

// ignore the error
c.HandleStoreHeartbeat(request)
return &pdpb.StoreHeartbeatResponse{}, nil
return &schedulingpb.StoreHeartbeatResponse{Header: &schedulingpb.ResponseHeader{ClusterId: s.clusterID}}, nil
}

// PutStore implements gRPC PDServer.
func (s *Service) PutStore(ctx context.Context, request *pdpb.PutStoreRequest) (*pdpb.PutStoreResponse, error) {
func (s *Service) PutStore(ctx context.Context, request *schedulingpb.PutStoreRequest) (*schedulingpb.PutStoreResponse, error) {
c := s.GetCluster()
if c == nil {
return &pdpb.PutStoreResponse{Header: &pdpb.ResponseHeader{
ClusterId: s.clusterID,
Error: &pdpb.Error{
Type: pdpb.ErrorType_NOT_BOOTSTRAPPED,
Message: "scheduling server is not initialized yet",
},
}}, nil
// ignore the error
return &schedulingpb.PutStoreResponse{Header: &schedulingpb.ResponseHeader{ClusterId: s.clusterID}}, nil
}

// ignore the error
c.PutStore(core.NewStoreInfo(request.GetStore()))
return &pdpb.PutStoreResponse{Header: &pdpb.ResponseHeader{
ClusterId: s.clusterID,
}}, nil
return &schedulingpb.PutStoreResponse{Header: &schedulingpb.ResponseHeader{ClusterId: s.clusterID}}, nil
}

// RegisterGRPCService registers the service to gRPC server.
Expand Down
2 changes: 1 addition & 1 deletion pkg/mcs/scheduling/server/meta/watcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ func (w *Watcher) initializeStoreWatcher() error {
if err := proto.Unmarshal(kv.Value, store); err != nil {
log.Warn("failed to unmarshal store entry",
zap.String("event-kv-key", string(kv.Key)), zap.Error(err))
return err
return err
}
origin := w.basicCluster.GetStore(store.GetId())
if origin == nil {
Expand Down
29 changes: 16 additions & 13 deletions server/grpc_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -862,16 +862,14 @@ func (s *GrpcServer) PutStore(ctx context.Context, request *pdpb.PutStoreRequest
if s.IsAPIServiceMode() {
client := s.getForwardedClient(ctx)
if client != nil {
if resp, _ := schedulingpb.NewSchedulingClient(client).PutStore(ctx, request); resp.GetHeader().GetError() != nil {
return &pdpb.PutStoreResponse{
Header: s.wrapErrorToHeader(pdpb.ErrorType_UNKNOWN, resp.GetHeader().GetError().String()),
}, nil
req := &schedulingpb.PutStoreRequest{
Header: &schedulingpb.RequestHeader{
ClusterId: request.GetHeader().GetClusterId(),
SenderId: request.GetHeader().GetSenderId(),
},
Store: request.GetStore(),
}
} else {
return &pdpb.PutStoreResponse{
Header: s.wrapErrorToHeader(pdpb.ErrorType_UNKNOWN,
"get delegate client failed"),
}, nil
schedulingpb.NewSchedulingClient(client).PutStore(ctx, req)
}
}

Expand Down Expand Up @@ -995,15 +993,20 @@ func (s *GrpcServer) StoreHeartbeat(ctx context.Context, request *pdpb.StoreHear
}

s.handleDamagedStore(request.GetStats())

storeHeartbeatHandleDuration.WithLabelValues(storeAddress, storeLabel).Observe(time.Since(start).Seconds())
if s.IsAPIServiceMode() {
client := s.getForwardedClient(ctx)
if client != nil {
schedulingpb.NewSchedulingClient(client).StoreHeartbeat(ctx, request)
req := &schedulingpb.StoreHeartbeatRequest{
Header: &schedulingpb.RequestHeader{
ClusterId: request.GetHeader().GetClusterId(),
SenderId: request.GetHeader().GetSenderId(),
},
Stats: request.GetStats(),
}
schedulingpb.NewSchedulingClient(client).StoreHeartbeat(ctx, req)
}
}

storeHeartbeatHandleDuration.WithLabelValues(storeAddress, storeLabel).Observe(time.Since(start).Seconds())
}

if status := request.GetDrAutosyncStatus(); status != nil {
Expand Down
2 changes: 1 addition & 1 deletion tests/integrations/client/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ replace (
// reset grpc and protobuf deps in order to import client and server at the same time
replace google.golang.org/grpc v1.54.0 => google.golang.org/grpc v1.26.0

replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097
replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38

require (
github.com/docker/go-units v0.4.0
Expand Down
4 changes: 2 additions & 2 deletions tests/integrations/client/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -453,8 +453,8 @@ github.com/prometheus/procfs v0.1.3/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4O
github.com/prometheus/procfs v0.6.0 h1:mxy4L2jP6qMonqmq+aTtOx1ifVWUgG/TAmntgbh3xv4=
github.com/prometheus/procfs v0.6.0/go.mod h1:cz+aTbrPOrUb4q7XlbU9ygM+/jj0fzG6c1xBZuNvfVA=
github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097 h1:luEk8MEptO8Fop2EfHqY0bsIBtGZh8Qb0eVEz3tjYG8=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38 h1:8vBwN7w7keTO+sBESkGVHM0bWAvOtc5eEEDaRR7ufbE=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
Expand Down
2 changes: 1 addition & 1 deletion tests/integrations/mcs/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ replace (
// reset grpc and protobuf deps in order to import client and server at the same time
replace google.golang.org/grpc v1.54.0 => google.golang.org/grpc v1.26.0

replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097
replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38

require (
github.com/pingcap/failpoint v0.0.0-20210918120811-547c13e3eb00
Expand Down
4 changes: 2 additions & 2 deletions tests/integrations/mcs/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -457,8 +457,8 @@ github.com/prometheus/procfs v0.1.3/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4O
github.com/prometheus/procfs v0.6.0 h1:mxy4L2jP6qMonqmq+aTtOx1ifVWUgG/TAmntgbh3xv4=
github.com/prometheus/procfs v0.6.0/go.mod h1:cz+aTbrPOrUb4q7XlbU9ygM+/jj0fzG6c1xBZuNvfVA=
github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097 h1:luEk8MEptO8Fop2EfHqY0bsIBtGZh8Qb0eVEz3tjYG8=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38 h1:8vBwN7w7keTO+sBESkGVHM0bWAvOtc5eEEDaRR7ufbE=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
Expand Down
1 change: 1 addition & 0 deletions tests/integrations/mcs/scheduling/api_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -106,3 +106,4 @@ func (suite *apiTestSuite) TestGetCheckerByName() {
suite.False(resp["paused"].(bool))
}
}

47 changes: 47 additions & 0 deletions tests/integrations/mcs/scheduling/server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,11 @@ import (
"time"

"github.com/pingcap/failpoint"
"github.com/pingcap/kvproto/pkg/metapb"
"github.com/pingcap/kvproto/pkg/pdpb"
"github.com/stretchr/testify/suite"
"github.com/tikv/pd/pkg/utils/testutil"
"github.com/tikv/pd/server"
"github.com/tikv/pd/tests"
"go.uber.org/goleak"
)
Expand Down Expand Up @@ -95,3 +98,47 @@ func (suite *serverTestSuite) TestAllocIDAfterLeaderChange() {
re.Greater(id1, id)
re.NoError(failpoint.Disable("github.com/tikv/pd/pkg/mcs/scheduling/server/fastUpdateMember"))
}

func (suite *serverTestSuite) TestForwardSchedulingRelated() {
re := suite.Require()
tc, err := tests.NewTestSchedulingCluster(suite.ctx, 1, suite.backendEndpoints)
re.NoError(err)
defer tc.Destroy()
tc.WaitForPrimaryServing(re)

s := &server.GrpcServer{Server: suite.pdLeader.GetServer()}
s.PutStore(
context.Background(), &pdpb.PutStoreRequest{
Header: &pdpb.RequestHeader{ClusterId: suite.pdLeader.GetClusterID()},
Store: &metapb.Store{
Id: 1,
Address: "tikv1",
State: metapb.StoreState_Up,
Version: "7.0.0",
},
},
)
s.StoreHeartbeat(
context.Background(), &pdpb.StoreHeartbeatRequest{
Header: &pdpb.RequestHeader{ClusterId: suite.pdLeader.GetClusterID()},
Stats: &pdpb.StoreStats{
StoreId: 1,
Capacity: 1798985089024,
Available: 1709868695552,
UsedSize: 85150956358,
KeysWritten: 20000,
BytesWritten: 199,
KeysRead: 10000,
BytesRead: 99,
},
},
)
store := tc.GetPrimaryServer().GetCluster().GetStore(1)
re.Equal(uint64(1798985089024), store.GetStoreStats().GetCapacity())
re.Equal(uint64(1709868695552), store.GetStoreStats().GetAvailable())
re.Equal(uint64(85150956358), store.GetStoreStats().GetUsedSize())
re.Equal(uint64(20000), store.GetStoreStats().GetKeysWritten())
re.Equal(uint64(199), store.GetStoreStats().GetBytesWritten())
re.Equal(uint64(10000), store.GetStoreStats().GetKeysRead())
re.Equal(uint64(99), store.GetStoreStats().GetBytesRead())
}
2 changes: 1 addition & 1 deletion tests/integrations/tso/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ replace (
// reset grpc and protobuf deps in order to import client and server at the same time
replace google.golang.org/grpc v1.54.0 => google.golang.org/grpc v1.26.0

replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097
replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38

require (
github.com/pingcap/failpoint v0.0.0-20220801062533-2eaa32854a6c
Expand Down
4 changes: 2 additions & 2 deletions tests/integrations/tso/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -451,8 +451,8 @@ github.com/prometheus/procfs v0.1.3/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4O
github.com/prometheus/procfs v0.6.0 h1:mxy4L2jP6qMonqmq+aTtOx1ifVWUgG/TAmntgbh3xv4=
github.com/prometheus/procfs v0.6.0/go.mod h1:cz+aTbrPOrUb4q7XlbU9ygM+/jj0fzG6c1xBZuNvfVA=
github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097 h1:luEk8MEptO8Fop2EfHqY0bsIBtGZh8Qb0eVEz3tjYG8=
github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38 h1:8vBwN7w7keTO+sBESkGVHM0bWAvOtc5eEEDaRR7ufbE=
github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38/go.mod h1:r0q/CFcwvyeRhKtoqzmWMBebrtpIziQQ9vR+JKh1knc=
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
Expand Down
2 changes: 1 addition & 1 deletion tools/pd-api-bench/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -122,4 +122,4 @@ replace (
github.com/tikv/pd/client => ../../client
)

replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097
replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38
2 changes: 1 addition & 1 deletion tools/pd-tso-bench/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -37,4 +37,4 @@ require (

replace github.com/tikv/pd/client => ../../client

replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230906083326-5bca56048097
replace github.com/pingcap/kvproto => github.com/rleungx/kvproto v0.0.0-20230907032444-eba37dcb1a38

0 comments on commit dc3d3cf

Please sign in to comment.