Jelajahi Sumber

*: move "mvcc" to "internal/mvcc"

Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
Gyuho Lee 8 tahun lalu
induk
melakukan
80d15948bc
100 mengubah file dengan 99 tambahan dan 101 penghapusan
  1. 1 1
      auth/range_perm_cache.go
  2. 1 1
      auth/store.go
  3. 1 1
      auth/store_test.go
  4. 1 1
      clientv3/concurrency/election.go
  5. 1 1
      clientv3/concurrency/key.go
  6. 1 1
      clientv3/integration/kv_test.go
  7. 2 2
      clientv3/integration/maintenance_test.go
  8. 1 1
      clientv3/integration/mirror_test.go
  9. 1 1
      clientv3/integration/namespace_test.go
  10. 1 1
      clientv3/integration/watch_test.go
  11. 1 1
      clientv3/leasing/cache.go
  12. 1 1
      clientv3/leasing/kv.go
  13. 1 1
      clientv3/watch.go
  14. 1 1
      clientv3/watch_test.go
  15. 1 1
      contrib/recipes/barrier.go
  16. 1 1
      contrib/recipes/client.go
  17. 1 1
      contrib/recipes/double_barrier.go
  18. 1 1
      contrib/recipes/priority_queue.go
  19. 1 1
      contrib/recipes/queue.go
  20. 1 1
      contrib/recipes/rwmutex.go
  21. 1 1
      contrib/recipes/watch.go
  22. 1 1
      e2e/etcd_corrupt_test.go
  23. 1 1
      etcdctl/ctlv3/command/defrag_command.go
  24. 1 1
      etcdctl/ctlv3/command/make_mirror_command.go
  25. 3 3
      etcdctl/ctlv3/command/migrate_command.go
  26. 1 1
      etcdctl/ctlv3/command/printer_fields.go
  27. 1 1
      etcdctl/ctlv3/command/printer_protobuf.go
  28. 1 1
      etcdctl/ctlv3/command/util.go
  29. 1 1
      etcdserver/api/v2v3/store.go
  30. 1 1
      etcdserver/api/v3election/v3electionpb/v3election.pb.go
  31. 2 2
      etcdserver/api/v3rpc/maintenance.go
  32. 1 1
      etcdserver/api/v3rpc/util.go
  33. 1 1
      etcdserver/api/v3rpc/util_test.go
  34. 2 2
      etcdserver/api/v3rpc/watch.go
  35. 2 2
      etcdserver/apply.go
  36. 1 1
      etcdserver/apply_auth.go
  37. 2 2
      etcdserver/backend.go
  38. 1 1
      etcdserver/corrupt.go
  39. 1 1
      etcdserver/etcdserverpb/rpc.pb.go
  40. 1 1
      etcdserver/membership/cluster.go
  41. 1 1
      etcdserver/membership/store.go
  42. 2 2
      etcdserver/server.go
  43. 2 2
      etcdserver/server_test.go
  44. 1 1
      etcdserver/snapshot_merge.go
  45. 1 1
      etcdserver/v3_server.go
  46. 2 2
      integration/v3_alarm_test.go
  47. 1 1
      integration/v3_lease_test.go
  48. 1 1
      integration/v3_lock_test.go
  49. 1 1
      integration/v3_watch_test.go
  50. 1 1
      internal/alarm/alarms.go
  51. 1 1
      internal/compactor/periodic.go
  52. 1 1
      internal/compactor/revision.go
  53. 1 1
      internal/lease/leasehttp/http_test.go
  54. 1 1
      internal/lease/lessor.go
  55. 1 1
      internal/lease/lessor_test.go
  56. 0 0
      internal/mvcc/backend/backend.go
  57. 0 0
      internal/mvcc/backend/backend_bench_test.go
  58. 0 0
      internal/mvcc/backend/backend_test.go
  59. 0 0
      internal/mvcc/backend/batch_tx.go
  60. 0 0
      internal/mvcc/backend/batch_tx_test.go
  61. 0 0
      internal/mvcc/backend/config_default.go
  62. 0 0
      internal/mvcc/backend/config_linux.go
  63. 0 0
      internal/mvcc/backend/config_windows.go
  64. 0 0
      internal/mvcc/backend/doc.go
  65. 0 0
      internal/mvcc/backend/metrics.go
  66. 0 0
      internal/mvcc/backend/read_tx.go
  67. 0 0
      internal/mvcc/backend/tx_buffer.go
  68. 0 0
      internal/mvcc/doc.go
  69. 0 0
      internal/mvcc/index.go
  70. 0 0
      internal/mvcc/index_test.go
  71. 0 0
      internal/mvcc/key_index.go
  72. 0 0
      internal/mvcc/key_index_test.go
  73. 2 2
      internal/mvcc/kv.go
  74. 2 2
      internal/mvcc/kv_test.go
  75. 0 0
      internal/mvcc/kv_view.go
  76. 2 2
      internal/mvcc/kvstore.go
  77. 1 1
      internal/mvcc/kvstore_bench_test.go
  78. 0 0
      internal/mvcc/kvstore_compaction.go
  79. 1 1
      internal/mvcc/kvstore_compaction_test.go
  80. 2 2
      internal/mvcc/kvstore_test.go
  81. 2 2
      internal/mvcc/kvstore_txn.go
  82. 0 0
      internal/mvcc/metrics.go
  83. 0 0
      internal/mvcc/metrics_txn.go
  84. 0 0
      internal/mvcc/mvccpb/kv.pb.go
  85. 0 0
      internal/mvcc/mvccpb/kv.proto
  86. 0 0
      internal/mvcc/revision.go
  87. 0 0
      internal/mvcc/revision_test.go
  88. 2 2
      internal/mvcc/util.go
  89. 2 2
      internal/mvcc/watchable_store.go
  90. 1 1
      internal/mvcc/watchable_store_bench_test.go
  91. 2 2
      internal/mvcc/watchable_store_test.go
  92. 1 3
      internal/mvcc/watchable_store_txn.go
  93. 1 1
      internal/mvcc/watcher.go
  94. 1 1
      internal/mvcc/watcher_bench_test.go
  95. 1 1
      internal/mvcc/watcher_group.go
  96. 2 2
      internal/mvcc/watcher_test.go
  97. 2 2
      proxy/grpcproxy/watcher.go
  98. 2 2
      snapshot/v3_snapshot.go
  99. 2 2
      tools/benchmark/cmd/mvcc.go
  100. 3 3
      tools/etcd-dump-db/backend.go

+ 1 - 1
auth/range_perm_cache.go

@@ -16,7 +16,7 @@ package auth
 
 import (
 	"github.com/coreos/etcd/auth/authpb"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/pkg/adt"
 )
 

+ 1 - 1
auth/store.go

@@ -26,7 +26,7 @@ import (
 
 	"github.com/coreos/etcd/auth/authpb"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 
 	"github.com/coreos/pkg/capnslog"
 	"golang.org/x/crypto/bcrypt"

+ 1 - 1
auth/store_test.go

@@ -26,7 +26,7 @@ import (
 
 	"github.com/coreos/etcd/auth/authpb"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 
 	"golang.org/x/crypto/bcrypt"
 	"google.golang.org/grpc/metadata"

+ 1 - 1
clientv3/concurrency/election.go

@@ -21,7 +21,7 @@ import (
 
 	v3 "github.com/coreos/etcd/clientv3"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 var (

+ 1 - 1
clientv3/concurrency/key.go

@@ -20,7 +20,7 @@ import (
 
 	v3 "github.com/coreos/etcd/clientv3"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 func waitDelete(ctx context.Context, client *v3.Client, key string, rev int64) error {

+ 1 - 1
clientv3/integration/kv_test.go

@@ -26,7 +26,7 @@ import (
 	"github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	"github.com/coreos/etcd/integration"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 
 	"google.golang.org/grpc"

+ 2 - 2
clientv3/integration/maintenance_test.go

@@ -27,8 +27,8 @@ import (
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	"github.com/coreos/etcd/integration"
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/pkg/testutil"
 )
 

+ 1 - 1
clientv3/integration/mirror_test.go

@@ -24,7 +24,7 @@ import (
 
 	"github.com/coreos/etcd/clientv3/mirror"
 	"github.com/coreos/etcd/integration"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 )
 

+ 1 - 1
clientv3/integration/namespace_test.go

@@ -22,7 +22,7 @@ import (
 	"github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/clientv3/namespace"
 	"github.com/coreos/etcd/integration"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 )
 

+ 1 - 1
clientv3/integration/watch_test.go

@@ -27,7 +27,7 @@ import (
 	"github.com/coreos/etcd/etcdserver/api/v3rpc"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	"github.com/coreos/etcd/integration"
-	mvccpb "github.com/coreos/etcd/mvcc/mvccpb"
+	mvccpb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 
 	"google.golang.org/grpc"

+ 1 - 1
clientv3/leasing/cache.go

@@ -22,7 +22,7 @@ import (
 
 	v3 "github.com/coreos/etcd/clientv3"
 	v3pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 const revokeBackoff = 2 * time.Second

+ 1 - 1
clientv3/leasing/kv.go

@@ -24,7 +24,7 @@ import (
 	"github.com/coreos/etcd/clientv3/concurrency"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"

+ 1 - 1
clientv3/watch.go

@@ -22,7 +22,7 @@ import (
 
 	v3rpc "github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	mvccpb "github.com/coreos/etcd/mvcc/mvccpb"
+	mvccpb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"

+ 1 - 1
clientv3/watch_test.go

@@ -17,7 +17,7 @@ package clientv3
 import (
 	"testing"
 
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 func TestEvent(t *testing.T) {

+ 1 - 1
contrib/recipes/barrier.go

@@ -18,7 +18,7 @@ import (
 	"context"
 
 	v3 "github.com/coreos/etcd/clientv3"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // Barrier creates a key in etcd to block processes, then deletes the key to

+ 1 - 1
contrib/recipes/client.go

@@ -19,7 +19,7 @@ import (
 	"errors"
 
 	v3 "github.com/coreos/etcd/clientv3"
-	spb "github.com/coreos/etcd/mvcc/mvccpb"
+	spb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 var (

+ 1 - 1
contrib/recipes/double_barrier.go

@@ -19,7 +19,7 @@ import (
 
 	"github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/clientv3/concurrency"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // DoubleBarrier blocks processes on Enter until an expected count enters, then

+ 1 - 1
contrib/recipes/priority_queue.go

@@ -19,7 +19,7 @@ import (
 	"fmt"
 
 	v3 "github.com/coreos/etcd/clientv3"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // PriorityQueue implements a multi-reader, multi-writer distributed queue.

+ 1 - 1
contrib/recipes/queue.go

@@ -18,7 +18,7 @@ import (
 	"context"
 
 	v3 "github.com/coreos/etcd/clientv3"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // Queue implements a multi-reader, multi-writer distributed queue.

+ 1 - 1
contrib/recipes/rwmutex.go

@@ -19,7 +19,7 @@ import (
 
 	v3 "github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/clientv3/concurrency"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 type RWMutex struct {

+ 1 - 1
contrib/recipes/watch.go

@@ -18,7 +18,7 @@ import (
 	"context"
 
 	"github.com/coreos/etcd/clientv3"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // WaitEvents waits on a key until it observes the given events and returns the final one.

+ 1 - 1
e2e/etcd_corrupt_test.go

@@ -24,7 +24,7 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/clientv3"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 	bolt "github.com/coreos/bbolt"
 )

+ 1 - 1
etcdctl/ctlv3/command/defrag_command.go

@@ -20,7 +20,7 @@ import (
 	"path/filepath"
 	"time"
 
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/spf13/cobra"
 )
 

+ 1 - 1
etcdctl/ctlv3/command/make_mirror_command.go

@@ -25,7 +25,7 @@ import (
 	"github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/clientv3/mirror"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 	"github.com/spf13/cobra"
 )

+ 3 - 3
etcdctl/ctlv3/command/migrate_command.go

@@ -30,11 +30,11 @@ import (
 	"github.com/coreos/etcd/etcdserver/api"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/etcdserver/membership"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/internal/raftsnap"
 	"github.com/coreos/etcd/internal/store"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/pbutil"
 	"github.com/coreos/etcd/pkg/types"
 	"github.com/coreos/etcd/raft/raftpb"

+ 1 - 1
etcdctl/ctlv3/command/printer_fields.go

@@ -19,7 +19,7 @@ import (
 
 	v3 "github.com/coreos/etcd/clientv3"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	spb "github.com/coreos/etcd/mvcc/mvccpb"
+	spb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/snapshot"
 )
 

+ 1 - 1
etcdctl/ctlv3/command/printer_protobuf.go

@@ -20,7 +20,7 @@ import (
 
 	v3 "github.com/coreos/etcd/clientv3"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	mvccpb "github.com/coreos/etcd/mvcc/mvccpb"
+	mvccpb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 type pbPrinter struct{ printer }

+ 1 - 1
etcdctl/ctlv3/command/util.go

@@ -20,7 +20,7 @@ import (
 	"fmt"
 	"regexp"
 
-	pb "github.com/coreos/etcd/mvcc/mvccpb"
+	pb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 	"github.com/spf13/cobra"
 )

+ 1 - 1
etcdserver/api/v2v3/store.go

@@ -24,8 +24,8 @@ import (
 	"github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/clientv3/concurrency"
 	etcdErr "github.com/coreos/etcd/error"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/internal/store"
-	"github.com/coreos/etcd/mvcc/mvccpb"
 )
 
 // store implements the Store interface for V2 using

+ 1 - 1
etcdserver/api/v3election/v3electionpb/v3election.pb.go

@@ -31,7 +31,7 @@ import (
 
 	etcdserverpb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 
-	mvccpb "github.com/coreos/etcd/mvcc/mvccpb"
+	mvccpb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 	context "golang.org/x/net/context"
 

+ 2 - 2
etcdserver/api/v3rpc/maintenance.go

@@ -23,8 +23,8 @@ import (
 	"github.com/coreos/etcd/etcdserver"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/pkg/types"
 	"github.com/coreos/etcd/raft"
 	"github.com/coreos/etcd/version"

+ 1 - 1
etcdserver/api/v3rpc/util.go

@@ -23,7 +23,7 @@ import (
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	"github.com/coreos/etcd/etcdserver/membership"
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc"
+	"github.com/coreos/etcd/internal/mvcc"
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"

+ 1 - 1
etcdserver/api/v3rpc/util_test.go

@@ -20,7 +20,7 @@ import (
 	"testing"
 
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
-	"github.com/coreos/etcd/mvcc"
+	"github.com/coreos/etcd/internal/mvcc"
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"

+ 2 - 2
etcdserver/api/v3rpc/watch.go

@@ -24,8 +24,8 @@ import (
 	"github.com/coreos/etcd/etcdserver"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 type watchServer struct {

+ 2 - 2
etcdserver/apply.go

@@ -23,8 +23,8 @@ import (
 	"github.com/coreos/etcd/auth"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/types"
 
 	"github.com/gogo/protobuf/proto"

+ 1 - 1
etcdserver/apply_auth.go

@@ -20,7 +20,7 @@ import (
 	"github.com/coreos/etcd/auth"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc"
+	"github.com/coreos/etcd/internal/mvcc"
 )
 
 type authApplierV3 struct {

+ 2 - 2
etcdserver/backend.go

@@ -20,9 +20,9 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
 	"github.com/coreos/etcd/raft/raftpb"
 )
 

+ 1 - 1
etcdserver/corrupt.go

@@ -22,7 +22,7 @@ import (
 	"github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc"
+	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/pkg/types"
 )
 

+ 1 - 1
etcdserver/etcdserverpb/rpc.pb.go

@@ -12,7 +12,7 @@ import (
 
 	_ "github.com/gogo/protobuf/gogoproto"
 
-	mvccpb "github.com/coreos/etcd/mvcc/mvccpb"
+	mvccpb "github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 	authpb "github.com/coreos/etcd/auth/authpb"
 

+ 1 - 1
etcdserver/membership/cluster.go

@@ -27,8 +27,8 @@ import (
 	"sync"
 	"time"
 
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/store"
-	"github.com/coreos/etcd/mvcc/backend"
 	"github.com/coreos/etcd/pkg/netutil"
 	"github.com/coreos/etcd/pkg/types"
 	"github.com/coreos/etcd/raft"

+ 1 - 1
etcdserver/membership/store.go

@@ -19,8 +19,8 @@ import (
 	"fmt"
 	"path"
 
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/store"
-	"github.com/coreos/etcd/mvcc/backend"
 	"github.com/coreos/etcd/pkg/types"
 
 	"github.com/coreos/go-semver/semver"

+ 2 - 2
etcdserver/server.go

@@ -40,10 +40,10 @@ import (
 	"github.com/coreos/etcd/internal/discovery"
 	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/lease/leasehttp"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
 	"github.com/coreos/etcd/internal/store"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
 	"github.com/coreos/etcd/pkg/fileutil"
 	"github.com/coreos/etcd/pkg/idutil"
 	"github.com/coreos/etcd/pkg/pbutil"

+ 2 - 2
etcdserver/server_test.go

@@ -29,10 +29,10 @@ import (
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/etcdserver/membership"
 	"github.com/coreos/etcd/internal/lease"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
 	"github.com/coreos/etcd/internal/store"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
 	"github.com/coreos/etcd/pkg/fileutil"
 	"github.com/coreos/etcd/pkg/idutil"
 	"github.com/coreos/etcd/pkg/mock/mockstorage"

+ 1 - 1
etcdserver/snapshot_merge.go

@@ -17,8 +17,8 @@ package etcdserver
 import (
 	"io"
 
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
-	"github.com/coreos/etcd/mvcc/backend"
 	"github.com/coreos/etcd/raft/raftpb"
 )
 

+ 1 - 1
etcdserver/v3_server.go

@@ -25,7 +25,7 @@ import (
 	"github.com/coreos/etcd/etcdserver/membership"
 	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/lease/leasehttp"
-	"github.com/coreos/etcd/mvcc"
+	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/raft"
 
 	"github.com/gogo/protobuf/proto"

+ 2 - 2
integration/v3_alarm_test.go

@@ -24,8 +24,8 @@ import (
 
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/pkg/testutil"
 )
 

+ 1 - 1
integration/v3_lease_test.go

@@ -22,7 +22,7 @@ import (
 
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 
 	"google.golang.org/grpc/metadata"

+ 1 - 1
integration/v3_lock_test.go

@@ -24,7 +24,7 @@ import (
 	"github.com/coreos/etcd/clientv3"
 	"github.com/coreos/etcd/clientv3/concurrency"
 	"github.com/coreos/etcd/contrib/recipes"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 )
 

+ 1 - 1
integration/v3_watch_test.go

@@ -26,7 +26,7 @@ import (
 
 	"github.com/coreos/etcd/etcdserver/api/v3rpc"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 )
 

+ 1 - 1
internal/alarm/alarms.go

@@ -19,7 +19,7 @@ import (
 	"sync"
 
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/pkg/types"
 	"github.com/coreos/pkg/capnslog"
 )

+ 1 - 1
internal/compactor/periodic.go

@@ -20,7 +20,7 @@ import (
 	"time"
 
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc"
+	"github.com/coreos/etcd/internal/mvcc"
 
 	"github.com/jonboulle/clockwork"
 )

+ 1 - 1
internal/compactor/revision.go

@@ -19,7 +19,7 @@ import (
 	"sync"
 
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc"
+	"github.com/coreos/etcd/internal/mvcc"
 
 	"github.com/jonboulle/clockwork"
 )

+ 1 - 1
internal/lease/leasehttp/http_test.go

@@ -24,7 +24,7 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 )
 
 func TestRenewHTTP(t *testing.T) {

+ 1 - 1
internal/lease/lessor.go

@@ -23,7 +23,7 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease/leasepb"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 )
 
 // NoLease is a special LeaseID representing the absence of a lease.

+ 1 - 1
internal/lease/lessor_test.go

@@ -25,7 +25,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 )
 
 const (

+ 0 - 0
mvcc/backend/backend.go → internal/mvcc/backend/backend.go


+ 0 - 0
mvcc/backend/backend_bench_test.go → internal/mvcc/backend/backend_bench_test.go


+ 0 - 0
mvcc/backend/backend_test.go → internal/mvcc/backend/backend_test.go


+ 0 - 0
mvcc/backend/batch_tx.go → internal/mvcc/backend/batch_tx.go


+ 0 - 0
mvcc/backend/batch_tx_test.go → internal/mvcc/backend/batch_tx_test.go


+ 0 - 0
mvcc/backend/config_default.go → internal/mvcc/backend/config_default.go


+ 0 - 0
mvcc/backend/config_linux.go → internal/mvcc/backend/config_linux.go


+ 0 - 0
mvcc/backend/config_windows.go → internal/mvcc/backend/config_windows.go


+ 0 - 0
mvcc/backend/doc.go → internal/mvcc/backend/doc.go


+ 0 - 0
mvcc/backend/metrics.go → internal/mvcc/backend/metrics.go


+ 0 - 0
mvcc/backend/read_tx.go → internal/mvcc/backend/read_tx.go


+ 0 - 0
mvcc/backend/tx_buffer.go → internal/mvcc/backend/tx_buffer.go


+ 0 - 0
mvcc/doc.go → internal/mvcc/doc.go


+ 0 - 0
mvcc/index.go → internal/mvcc/index.go


+ 0 - 0
mvcc/index_test.go → internal/mvcc/index_test.go


+ 0 - 0
mvcc/key_index.go → internal/mvcc/key_index.go


+ 0 - 0
mvcc/key_index_test.go → internal/mvcc/key_index_test.go


+ 2 - 2
mvcc/kv.go → internal/mvcc/kv.go

@@ -16,8 +16,8 @@ package mvcc
 
 import (
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 type RangeOptions struct {

+ 2 - 2
mvcc/kv_test.go → internal/mvcc/kv_test.go

@@ -22,8 +22,8 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/testutil"
 
 	"github.com/prometheus/client_golang/prometheus"

+ 0 - 0
mvcc/kv_view.go → internal/mvcc/kv_view.go


+ 2 - 2
mvcc/kvstore.go → internal/mvcc/kvstore.go

@@ -25,8 +25,8 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/schedule"
 	"github.com/coreos/pkg/capnslog"
 )

+ 1 - 1
mvcc/kvstore_bench_test.go → internal/mvcc/kvstore_bench_test.go

@@ -19,7 +19,7 @@ import (
 	"testing"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 )
 
 type fakeConsistentIndex uint64

+ 0 - 0
mvcc/kvstore_compaction.go → internal/mvcc/kvstore_compaction.go


+ 1 - 1
mvcc/kvstore_compaction_test.go → internal/mvcc/kvstore_compaction_test.go

@@ -21,7 +21,7 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 )
 
 func TestScheduleCompaction(t *testing.T) {

+ 2 - 2
mvcc/kvstore_test.go → internal/mvcc/kvstore_test.go

@@ -27,8 +27,8 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/schedule"
 	"github.com/coreos/etcd/pkg/testutil"
 )

+ 2 - 2
mvcc/kvstore_txn.go → internal/mvcc/kvstore_txn.go

@@ -16,8 +16,8 @@ package mvcc
 
 import (
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 type storeTxnRead struct {

+ 0 - 0
mvcc/metrics.go → internal/mvcc/metrics.go


+ 0 - 0
mvcc/metrics_txn.go → internal/mvcc/metrics_txn.go


+ 0 - 0
mvcc/mvccpb/kv.pb.go → internal/mvcc/mvccpb/kv.pb.go


+ 0 - 0
mvcc/mvccpb/kv.proto → internal/mvcc/mvccpb/kv.proto


+ 0 - 0
mvcc/revision.go → internal/mvcc/revision.go


+ 0 - 0
mvcc/revision_test.go → internal/mvcc/revision_test.go


+ 2 - 2
mvcc/util.go → internal/mvcc/util.go

@@ -17,8 +17,8 @@ package mvcc
 import (
 	"encoding/binary"
 
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 func UpdateConsistentIndex(be backend.Backend, index uint64) {

+ 2 - 2
mvcc/watchable_store.go → internal/mvcc/watchable_store.go

@@ -19,8 +19,8 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // non-const so modifiable by tests

+ 1 - 1
mvcc/watchable_store_bench_test.go → internal/mvcc/watchable_store_bench_test.go

@@ -20,7 +20,7 @@ import (
 	"testing"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 )
 
 func BenchmarkWatchableStorePut(b *testing.B) {

+ 2 - 2
mvcc/watchable_store_test.go → internal/mvcc/watchable_store_test.go

@@ -24,8 +24,8 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 func TestWatch(t *testing.T) {

+ 1 - 3
mvcc/watchable_store_txn.go → internal/mvcc/watchable_store_txn.go

@@ -14,9 +14,7 @@
 
 package mvcc
 
-import (
-	"github.com/coreos/etcd/mvcc/mvccpb"
-)
+import "github.com/coreos/etcd/internal/mvcc/mvccpb"
 
 func (tw *watchableStoreTxnWrite) End() {
 	changes := tw.Changes()

+ 1 - 1
mvcc/watcher.go → internal/mvcc/watcher.go

@@ -19,7 +19,7 @@ import (
 	"errors"
 	"sync"
 
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // AutoWatchID is the watcher ID passed in WatchStream.Watch when no

+ 1 - 1
mvcc/watcher_bench_test.go → internal/mvcc/watcher_bench_test.go

@@ -19,7 +19,7 @@ import (
 	"testing"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 )
 
 func BenchmarkKVWatcherMemoryUsage(b *testing.B) {

+ 1 - 1
mvcc/watcher_group.go → internal/mvcc/watcher_group.go

@@ -17,7 +17,7 @@ package mvcc
 import (
 	"math"
 
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 	"github.com/coreos/etcd/pkg/adt"
 )
 

+ 2 - 2
mvcc/watcher_test.go → internal/mvcc/watcher_test.go

@@ -23,8 +23,8 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 // TestWatcherWatchID tests that each watcher provides unique watchID,

+ 2 - 2
proxy/grpcproxy/watcher.go

@@ -19,8 +19,8 @@ import (
 
 	"github.com/coreos/etcd/clientv3"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 type watchRange struct {

+ 2 - 2
snapshot/v3_snapshot.go

@@ -31,10 +31,10 @@ import (
 	"github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/etcdserver/membership"
 	"github.com/coreos/etcd/internal/lease"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
 	"github.com/coreos/etcd/internal/store"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
 	"github.com/coreos/etcd/pkg/fileutil"
 	"github.com/coreos/etcd/pkg/logger"
 	"github.com/coreos/etcd/pkg/types"

+ 2 - 2
tools/benchmark/cmd/mvcc.go

@@ -19,8 +19,8 @@ import (
 	"time"
 
 	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/spf13/cobra"
 )
 

+ 3 - 3
tools/etcd-dump-db/backend.go

@@ -21,9 +21,9 @@ import (
 
 	bolt "github.com/coreos/bbolt"
 	"github.com/coreos/etcd/internal/lease/leasepb"
-	"github.com/coreos/etcd/mvcc"
-	"github.com/coreos/etcd/mvcc/backend"
-	"github.com/coreos/etcd/mvcc/mvccpb"
+	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/internal/mvcc/mvccpb"
 )
 
 func snapDir(dataDir string) string {