From dc130aa0d3b1cdd4eeb8b26caa3299d4fafb4a30 Mon Sep 17 00:00:00 2001 From: Yongbo Jiang Date: Tue, 11 Oct 2022 14:27:39 +0800 Subject: [PATCH] imple pd client (#597) Signed-off-by: Cabinfever_B Signed-off-by: Cabinfever_B --- internal/mockstore/mocktikv/pd.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/internal/mockstore/mocktikv/pd.go b/internal/mockstore/mocktikv/pd.go index 769f2c89..e5cec547 100644 --- a/internal/mockstore/mocktikv/pd.go +++ b/internal/mockstore/mocktikv/pd.go @@ -41,6 +41,7 @@ import ( "sync" "time" + "github.com/pingcap/kvproto/pkg/keyspacepb" "github.com/pingcap/kvproto/pkg/metapb" "github.com/pingcap/kvproto/pkg/pdpb" "github.com/pkg/errors" @@ -251,3 +252,11 @@ func (c *pdClient) GetLeaderAddr() string { return "mockpd" } func (c *pdClient) UpdateOption(option pd.DynamicOption, value interface{}) error { return nil } + +func (c *pdClient) LoadKeyspace(ctx context.Context, name string) (*keyspacepb.KeyspaceMeta, error) { + return nil, nil +} + +func (c *pdClient) WatchKeyspaces(ctx context.Context) (chan []*keyspacepb.KeyspaceMeta, error) { + return nil, nil +}