Skip to content

Commit

Permalink
*: update pd and kvproto vendor (#7513)
Browse files Browse the repository at this point in the history
  • Loading branch information
disksing authored Aug 28, 2018
1 parent 5b689e8 commit 364cd97
Show file tree
Hide file tree
Showing 58 changed files with 3,788 additions and 13,758 deletions.
35 changes: 11 additions & 24 deletions Gopkg.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

8 changes: 8 additions & 0 deletions store/mockstore/mocktikv/pd.go
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,10 @@ func (c *pdClient) GetRegion(ctx context.Context, key []byte) (*metapb.Region, *
return region, peer, nil
}

func (c *pdClient) GetPrevRegion(context.Context, []byte) (*metapb.Region, *metapb.Peer, error) {
panic("unimplemented")
}

func (c *pdClient) GetRegionByID(ctx context.Context, regionID uint64) (*metapb.Region, *metapb.Peer, error) {
region, peer := c.cluster.GetRegionByID(regionID)
return region, peer, nil
Expand All @@ -92,5 +96,9 @@ func (c *pdClient) GetStore(ctx context.Context, storeID uint64) (*metapb.Store,
return store, nil
}

func (c *pdClient) UpdateGCSafePoint(ctx context.Context, safePoint uint64) (uint64, error) {
panic("unimplemented")
}

func (c *pdClient) Close() {
}
8 changes: 8 additions & 0 deletions store/tikv/store_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -138,6 +138,10 @@ func (c *mockPDClient) GetRegion(ctx context.Context, key []byte) (*metapb.Regio
return c.client.GetRegion(ctx, key)
}

func (c *mockPDClient) GetPrevRegion(context.Context, []byte) (*metapb.Region, *metapb.Peer, error) {
panic("unimplemented")
}

func (c *mockPDClient) GetRegionByID(ctx context.Context, regionID uint64) (*metapb.Region, *metapb.Peer, error) {
c.RLock()
defer c.RUnlock()
Expand All @@ -158,6 +162,10 @@ func (c *mockPDClient) GetStore(ctx context.Context, storeID uint64) (*metapb.St
return c.client.GetStore(ctx, storeID)
}

func (c *mockPDClient) UpdateGCSafePoint(ctx context.Context, safePoint uint64) (uint64, error) {
panic("unimplemented")
}

func (c *mockPDClient) Close() {}

type checkRequestClient struct {
Expand Down
52 changes: 0 additions & 52 deletions vendor/github.com/etcd-io/gofail/code/binding.go

This file was deleted.

95 changes: 0 additions & 95 deletions vendor/github.com/etcd-io/gofail/code/failpoint.go

This file was deleted.

Loading

0 comments on commit 364cd97

Please sign in to comment.