Prechádzať zdrojové kódy

*: revert module import paths

Signed-off-by: Gyuho Lee <leegyuho@amazon.com>
Gyuho Lee 6 rokov pred
rodič
commit
34bd797e67
100 zmenil súbory, kde vykonal 241 pridanie a 245 odobranie
  1. 1 3
      Documentation/dev-guide/api_concurrency_reference_v3.md
  2. 1 3
      Documentation/dev-guide/api_reference_v3.md
  3. 3 3
      auth/range_perm_cache.go
  4. 2 2
      auth/range_perm_cache_test.go
  5. 4 4
      auth/store.go
  6. 4 4
      auth/store_test.go
  7. 1 1
      client/client.go
  8. 2 2
      client/client_test.go
  9. 1 1
      client/discover.go
  10. 1 1
      client/doc.go
  11. 1 1
      client/example_keys_test.go
  12. 3 3
      client/integration/client_test.go
  13. 1 1
      client/integration/main_test.go
  14. 1 1
      client/keys.go
  15. 3 3
      client/main_test.go
  16. 1 1
      client/members.go
  17. 1 1
      client/members_test.go
  18. 2 2
      clientv3/auth.go
  19. 1 1
      clientv3/balancer/balancer.go
  20. 4 4
      clientv3/balancer/balancer_test.go
  21. 1 1
      clientv3/balancer/config.go
  22. 2 2
      clientv3/balancer/grpc1.7-health_test.go
  23. 5 5
      clientv3/client.go
  24. 2 2
      clientv3/client_test.go
  25. 2 2
      clientv3/clientv3util/example_key_test.go
  26. 1 1
      clientv3/clientv3util/util.go
  27. 2 2
      clientv3/cluster.go
  28. 1 1
      clientv3/compact_op.go
  29. 1 1
      clientv3/compact_op_test.go
  30. 1 1
      clientv3/compare.go
  31. 3 3
      clientv3/concurrency/election.go
  32. 2 2
      clientv3/concurrency/election_test.go
  33. 2 2
      clientv3/concurrency/example_election_test.go
  34. 2 2
      clientv3/concurrency/example_mutex_test.go
  35. 2 2
      clientv3/concurrency/example_stm_test.go
  36. 3 3
      clientv3/concurrency/key.go
  37. 2 2
      clientv3/concurrency/main_test.go
  38. 2 2
      clientv3/concurrency/mutex.go
  39. 1 1
      clientv3/concurrency/session.go
  40. 1 1
      clientv3/concurrency/stm.go
  41. 1 1
      clientv3/example_auth_test.go
  42. 1 1
      clientv3/example_cluster_test.go
  43. 2 2
      clientv3/example_kv_test.go
  44. 1 1
      clientv3/example_lease_test.go
  45. 1 1
      clientv3/example_maintenance_test.go
  46. 1 1
      clientv3/example_metrics_test.go
  47. 2 2
      clientv3/example_test.go
  48. 1 1
      clientv3/example_watch_test.go
  49. 4 4
      clientv3/integration/black_hole_test.go
  50. 3 3
      clientv3/integration/cluster_test.go
  51. 5 5
      clientv3/integration/dial_test.go
  52. 5 5
      clientv3/integration/kv_test.go
  53. 5 5
      clientv3/integration/lease_test.go
  54. 5 5
      clientv3/integration/leasing_test.go
  55. 1 1
      clientv3/integration/logger_test.go
  56. 1 1
      clientv3/integration/main_test.go
  57. 7 7
      clientv3/integration/maintenance_test.go
  58. 4 4
      clientv3/integration/metrics_test.go
  59. 4 4
      clientv3/integration/mirror_test.go
  60. 5 5
      clientv3/integration/namespace_test.go
  61. 5 5
      clientv3/integration/network_partition_test.go
  62. 3 3
      clientv3/integration/role_test.go
  63. 4 4
      clientv3/integration/server_shutdown_test.go
  64. 5 5
      clientv3/integration/txn_test.go
  65. 4 4
      clientv3/integration/user_test.go
  66. 1 1
      clientv3/integration/util.go
  67. 3 3
      clientv3/integration/watch_fragment_test.go
  68. 6 6
      clientv3/integration/watch_test.go
  69. 1 1
      clientv3/kv.go
  70. 2 2
      clientv3/lease.go
  71. 3 3
      clientv3/leasing/cache.go
  72. 5 5
      clientv3/leasing/kv.go
  73. 2 2
      clientv3/leasing/txn.go
  74. 2 2
      clientv3/leasing/util.go
  75. 1 1
      clientv3/logger.go
  76. 2 2
      clientv3/main_test.go
  77. 1 1
      clientv3/maintenance.go
  78. 1 1
      clientv3/mirror/syncer.go
  79. 3 3
      clientv3/namespace/kv.go
  80. 1 1
      clientv3/namespace/lease.go
  81. 1 1
      clientv3/namespace/watch.go
  82. 2 2
      clientv3/naming/doc.go
  83. 1 1
      clientv3/naming/grpc.go
  84. 3 3
      clientv3/naming/grpc_test.go
  85. 1 1
      clientv3/op.go
  86. 1 1
      clientv3/op_test.go
  87. 1 1
      clientv3/ordering/kv.go
  88. 4 4
      clientv3/ordering/kv_test.go
  89. 1 1
      clientv3/ordering/logger_test.go
  90. 1 1
      clientv3/ordering/util.go
  91. 3 3
      clientv3/ordering/util_test.go
  92. 2 2
      clientv3/retry.go
  93. 1 1
      clientv3/retry_interceptor.go
  94. 4 4
      clientv3/snapshot/member_test.go
  95. 15 15
      clientv3/snapshot/v3_snapshot.go
  96. 4 4
      clientv3/snapshot/v3_snapshot_test.go
  97. 1 1
      clientv3/txn.go
  98. 1 1
      clientv3/txn_test.go
  99. 3 3
      clientv3/watch.go
  100. 1 1
      clientv3/watch_test.go

+ 1 - 3
Documentation/dev-guide/api_concurrency_reference_v3.md

@@ -1,6 +1,4 @@
----
-title: etcd concurrency API Reference
----
+### etcd concurrency API Reference
 
 
 
 
 This is a generated documentation. Please read the proto files for more.
 This is a generated documentation. Please read the proto files for more.

+ 1 - 3
Documentation/dev-guide/api_reference_v3.md

@@ -1,6 +1,4 @@
----
-title: etcd API Reference
----
+### etcd API Reference
 
 
 
 
 This is a generated documentation. Please read the proto files for more.
 This is a generated documentation. Please read the proto files for more.

+ 3 - 3
auth/range_perm_cache.go

@@ -15,9 +15,9 @@
 package auth
 package auth
 
 
 import (
 import (
-	"go.etcd.io/etcd/v3/auth/authpb"
-	"go.etcd.io/etcd/v3/mvcc/backend"
-	"go.etcd.io/etcd/v3/pkg/adt"
+	"go.etcd.io/etcd/auth/authpb"
+	"go.etcd.io/etcd/mvcc/backend"
+	"go.etcd.io/etcd/pkg/adt"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 )
 )

+ 2 - 2
auth/range_perm_cache_test.go

@@ -17,8 +17,8 @@ package auth
 import (
 import (
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/auth/authpb"
-	"go.etcd.io/etcd/v3/pkg/adt"
+	"go.etcd.io/etcd/auth/authpb"
+	"go.etcd.io/etcd/pkg/adt"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 )
 )

+ 4 - 4
auth/store.go

@@ -24,10 +24,10 @@ import (
 	"sync"
 	"sync"
 	"sync/atomic"
 	"sync/atomic"
 
 
-	"go.etcd.io/etcd/v3/auth/authpb"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/mvcc/backend"
+	"go.etcd.io/etcd/auth/authpb"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/mvcc/backend"
 
 
 	"github.com/coreos/pkg/capnslog"
 	"github.com/coreos/pkg/capnslog"
 	"go.uber.org/zap"
 	"go.uber.org/zap"

+ 4 - 4
auth/store_test.go

@@ -24,10 +24,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/auth/authpb"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/mvcc/backend"
+	"go.etcd.io/etcd/auth/authpb"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/mvcc/backend"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 	"golang.org/x/crypto/bcrypt"
 	"golang.org/x/crypto/bcrypt"

+ 1 - 1
client/client.go

@@ -29,7 +29,7 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/version"
+	"go.etcd.io/etcd/version"
 )
 )
 
 
 var (
 var (

+ 2 - 2
client/client_test.go

@@ -29,8 +29,8 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/pkg/testutil"
-	"go.etcd.io/etcd/v3/version"
+	"go.etcd.io/etcd/pkg/testutil"
+	"go.etcd.io/etcd/version"
 )
 )
 
 
 type actionAssertingHTTPClient struct {
 type actionAssertingHTTPClient struct {

+ 1 - 1
client/discover.go

@@ -15,7 +15,7 @@
 package client
 package client
 
 
 import (
 import (
-	"go.etcd.io/etcd/v3/pkg/srv"
+	"go.etcd.io/etcd/pkg/srv"
 )
 )
 
 
 // Discoverer is an interface that wraps the Discover method.
 // Discoverer is an interface that wraps the Discover method.

+ 1 - 1
client/doc.go

@@ -21,7 +21,7 @@ Create a Config and exchange it for a Client:
 		"net/http"
 		"net/http"
 		"context"
 		"context"
 
 
-		"go.etcd.io/etcd/v3/client"
+		"go.etcd.io/etcd/client"
 	)
 	)
 
 
 	cfg := client.Config{
 	cfg := client.Config{

+ 1 - 1
client/example_keys_test.go

@@ -20,7 +20,7 @@ import (
 	"log"
 	"log"
 	"sort"
 	"sort"
 
 
-	"go.etcd.io/etcd/v3/client"
+	"go.etcd.io/etcd/client"
 )
 )
 
 
 func ExampleKeysAPI_directory() {
 func ExampleKeysAPI_directory() {

+ 3 - 3
client/integration/client_test.go

@@ -24,9 +24,9 @@ import (
 	"sync/atomic"
 	"sync/atomic"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/client"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/client"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 // TestV2NoRetryEOF tests destructive api calls won't retry on a disconnection.
 // TestV2NoRetryEOF tests destructive api calls won't retry on a disconnection.

+ 1 - 1
client/integration/main_test.go

@@ -8,7 +8,7 @@ import (
 	"os"
 	"os"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestMain(m *testing.M) {
 func TestMain(m *testing.M) {

+ 1 - 1
client/keys.go

@@ -19,7 +19,7 @@ import (
 	"encoding/json"
 	"encoding/json"
 	"errors"
 	"errors"
 	"fmt"
 	"fmt"
-	"go.etcd.io/etcd/v3/pkg/pathutil"
+	"go.etcd.io/etcd/pkg/pathutil"
 	"net/http"
 	"net/http"
 	"net/url"
 	"net/url"
 	"strconv"
 	"strconv"

+ 3 - 3
client/main_test.go

@@ -23,9 +23,9 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
-	"go.etcd.io/etcd/v3/pkg/transport"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
+	"go.etcd.io/etcd/pkg/transport"
 )
 )
 
 
 var exampleEndpoints []string
 var exampleEndpoints []string

+ 1 - 1
client/members.go

@@ -23,7 +23,7 @@ import (
 	"net/url"
 	"net/url"
 	"path"
 	"path"
 
 
-	"go.etcd.io/etcd/v3/pkg/types"
+	"go.etcd.io/etcd/pkg/types"
 )
 )
 
 
 var (
 var (

+ 1 - 1
client/members_test.go

@@ -23,7 +23,7 @@ import (
 	"reflect"
 	"reflect"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/pkg/types"
+	"go.etcd.io/etcd/pkg/types"
 )
 )
 
 
 func TestMembersAPIActionList(t *testing.T) {
 func TestMembersAPIActionList(t *testing.T) {

+ 2 - 2
clientv3/auth.go

@@ -19,8 +19,8 @@ import (
 	"fmt"
 	"fmt"
 	"strings"
 	"strings"
 
 
-	"go.etcd.io/etcd/v3/auth/authpb"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/auth/authpb"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )
 
 

+ 1 - 1
clientv3/balancer/balancer.go

@@ -20,7 +20,7 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3/balancer/picker"
+	"go.etcd.io/etcd/clientv3/balancer/picker"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 	"google.golang.org/grpc/balancer"
 	"google.golang.org/grpc/balancer"

+ 4 - 4
clientv3/balancer/balancer_test.go

@@ -21,10 +21,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3/balancer/picker"
-	"go.etcd.io/etcd/v3/clientv3/balancer/resolver/endpoint"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/pkg/mock/mockserver"
+	"go.etcd.io/etcd/clientv3/balancer/picker"
+	"go.etcd.io/etcd/clientv3/balancer/resolver/endpoint"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/pkg/mock/mockserver"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"

+ 1 - 1
clientv3/balancer/config.go

@@ -15,7 +15,7 @@
 package balancer
 package balancer
 
 
 import (
 import (
-	"go.etcd.io/etcd/v3/clientv3/balancer/picker"
+	"go.etcd.io/etcd/clientv3/balancer/picker"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 )
 )

+ 2 - 2
clientv3/balancer/grpc1.7-health_test.go

@@ -22,8 +22,8 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )

+ 5 - 5
clientv3/client.go

@@ -27,11 +27,11 @@ import (
 	"time"
 	"time"
 
 
 	"github.com/google/uuid"
 	"github.com/google/uuid"
-	"go.etcd.io/etcd/v3/clientv3/balancer"
-	"go.etcd.io/etcd/v3/clientv3/balancer/picker"
-	"go.etcd.io/etcd/v3/clientv3/balancer/resolver/endpoint"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/pkg/logutil"
+	"go.etcd.io/etcd/clientv3/balancer"
+	"go.etcd.io/etcd/clientv3/balancer/picker"
+	"go.etcd.io/etcd/clientv3/balancer/resolver/endpoint"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/pkg/logutil"
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"

+ 2 - 2
clientv3/client_test.go

@@ -21,8 +21,8 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )

+ 2 - 2
clientv3/clientv3util/example_key_test.go

@@ -18,8 +18,8 @@ import (
 	"context"
 	"context"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/clientv3util"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/clientv3util"
 )
 )
 
 
 func ExampleKeyMissing() {
 func ExampleKeyMissing() {

+ 1 - 1
clientv3/clientv3util/util.go

@@ -16,7 +16,7 @@
 package clientv3util
 package clientv3util
 
 
 import (
 import (
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 // KeyExists returns a comparison operation that evaluates to true iff the given
 // KeyExists returns a comparison operation that evaluates to true iff the given

+ 2 - 2
clientv3/cluster.go

@@ -17,8 +17,8 @@ package clientv3
 import (
 import (
 	"context"
 	"context"
 
 
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/pkg/types"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/pkg/types"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )

+ 1 - 1
clientv3/compact_op.go

@@ -15,7 +15,7 @@
 package clientv3
 package clientv3
 
 
 import (
 import (
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 // CompactOp represents a compact operation.
 // CompactOp represents a compact operation.

+ 1 - 1
clientv3/compact_op_test.go

@@ -18,7 +18,7 @@ import (
 	"reflect"
 	"reflect"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 func TestCompactOp(t *testing.T) {
 func TestCompactOp(t *testing.T) {

+ 1 - 1
clientv3/compare.go

@@ -15,7 +15,7 @@
 package clientv3
 package clientv3
 
 
 import (
 import (
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 type CompareTarget int
 type CompareTarget int

+ 3 - 3
clientv3/concurrency/election.go

@@ -19,9 +19,9 @@ import (
 	"errors"
 	"errors"
 	"fmt"
 	"fmt"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
+	v3 "go.etcd.io/etcd/clientv3"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/mvcc/mvccpb"
 )
 )
 
 
 var (
 var (

+ 2 - 2
clientv3/concurrency/election_test.go

@@ -21,8 +21,8 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/concurrency"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/concurrency"
 )
 )
 
 
 func TestResumeElection(t *testing.T) {
 func TestResumeElection(t *testing.T) {

+ 2 - 2
clientv3/concurrency/example_election_test.go

@@ -21,8 +21,8 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/concurrency"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/concurrency"
 )
 )
 
 
 func ExampleElection_Campaign() {
 func ExampleElection_Campaign() {

+ 2 - 2
clientv3/concurrency/example_mutex_test.go

@@ -19,8 +19,8 @@ import (
 	"fmt"
 	"fmt"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/concurrency"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/concurrency"
 )
 )
 
 
 func ExampleMutex_Lock() {
 func ExampleMutex_Lock() {

+ 2 - 2
clientv3/concurrency/example_stm_test.go

@@ -21,8 +21,8 @@ import (
 	"math/rand"
 	"math/rand"
 	"sync"
 	"sync"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/concurrency"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/concurrency"
 )
 )
 
 
 // ExampleSTM_apply shows how to use STM with a transactional
 // ExampleSTM_apply shows how to use STM with a transactional

+ 3 - 3
clientv3/concurrency/key.go

@@ -18,9 +18,9 @@ import (
 	"context"
 	"context"
 	"fmt"
 	"fmt"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
+	v3 "go.etcd.io/etcd/clientv3"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/mvcc/mvccpb"
 )
 )
 
 
 func waitDelete(ctx context.Context, client *v3.Client, key string, rev int64) error {
 func waitDelete(ctx context.Context, client *v3.Client, key string, rev int64) error {

+ 2 - 2
clientv3/concurrency/main_test.go

@@ -20,8 +20,8 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 var endpoints []string
 var endpoints []string

+ 2 - 2
clientv3/concurrency/mutex.go

@@ -19,8 +19,8 @@ import (
 	"fmt"
 	"fmt"
 	"sync"
 	"sync"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	v3 "go.etcd.io/etcd/clientv3"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 // Mutex implements the sync Locker interface with etcd
 // Mutex implements the sync Locker interface with etcd

+ 1 - 1
clientv3/concurrency/session.go

@@ -18,7 +18,7 @@ import (
 	"context"
 	"context"
 	"time"
 	"time"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
+	v3 "go.etcd.io/etcd/clientv3"
 )
 )
 
 
 const defaultSessionTTL = 60
 const defaultSessionTTL = 60

+ 1 - 1
clientv3/concurrency/stm.go

@@ -18,7 +18,7 @@ import (
 	"context"
 	"context"
 	"math"
 	"math"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
+	v3 "go.etcd.io/etcd/clientv3"
 )
 )
 
 
 // STM is an interface for software transactional memory.
 // STM is an interface for software transactional memory.

+ 1 - 1
clientv3/example_auth_test.go

@@ -19,7 +19,7 @@ import (
 	"fmt"
 	"fmt"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 func ExampleAuth() {
 func ExampleAuth() {

+ 1 - 1
clientv3/example_cluster_test.go

@@ -19,7 +19,7 @@ import (
 	"fmt"
 	"fmt"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 func ExampleCluster_memberList() {
 func ExampleCluster_memberList() {

+ 2 - 2
clientv3/example_kv_test.go

@@ -19,8 +19,8 @@ import (
 	"fmt"
 	"fmt"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
 )
 )
 
 
 func ExampleKV_put() {
 func ExampleKV_put() {

+ 1 - 1
clientv3/example_lease_test.go

@@ -19,7 +19,7 @@ import (
 	"fmt"
 	"fmt"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 func ExampleLease_grant() {
 func ExampleLease_grant() {

+ 1 - 1
clientv3/example_maintenance_test.go

@@ -19,7 +19,7 @@ import (
 	"fmt"
 	"fmt"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 func ExampleMaintenance_status() {
 func ExampleMaintenance_status() {

+ 1 - 1
clientv3/example_metrics_test.go

@@ -23,7 +23,7 @@ import (
 	"net/http"
 	"net/http"
 	"strings"
 	"strings"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 
 
 	grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
 	grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 	"github.com/prometheus/client_golang/prometheus/promhttp"

+ 2 - 2
clientv3/example_test.go

@@ -20,8 +20,8 @@ import (
 	"os"
 	"os"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/pkg/transport"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/pkg/transport"
 
 
 	"google.golang.org/grpc/grpclog"
 	"google.golang.org/grpc/grpclog"
 )
 )

+ 1 - 1
clientv3/example_watch_test.go

@@ -19,7 +19,7 @@ import (
 	"fmt"
 	"fmt"
 	"log"
 	"log"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 func ExampleWatcher_watch() {
 func ExampleWatcher_watch() {

+ 4 - 4
clientv3/integration/black_hole_test.go

@@ -21,10 +21,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )
 
 

+ 3 - 3
clientv3/integration/cluster_test.go

@@ -20,9 +20,9 @@ import (
 	"strings"
 	"strings"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
-	"go.etcd.io/etcd/v3/pkg/types"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
+	"go.etcd.io/etcd/pkg/types"
 )
 )
 
 
 func TestMemberList(t *testing.T) {
 func TestMemberList(t *testing.T) {

+ 5 - 5
clientv3/integration/dial_test.go

@@ -21,11 +21,11 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
-	"go.etcd.io/etcd/v3/pkg/transport"
+	"go.etcd.io/etcd/clientv3"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
+	"go.etcd.io/etcd/pkg/transport"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )
 
 

+ 5 - 5
clientv3/integration/kv_test.go

@@ -23,11 +23,11 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/mvcc/mvccpb"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"

+ 5 - 5
clientv3/integration/lease_test.go

@@ -22,11 +22,11 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/concurrency"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/concurrency"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )

+ 5 - 5
clientv3/integration/leasing_test.go

@@ -23,11 +23,11 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/concurrency"
-	"go.etcd.io/etcd/v3/clientv3/leasing"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/concurrency"
+	"go.etcd.io/etcd/clientv3/leasing"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestLeasingPutGet(t *testing.T) {
 func TestLeasingPutGet(t *testing.T) {

+ 1 - 1
clientv3/integration/logger_test.go

@@ -17,7 +17,7 @@ package integration
 import (
 import (
 	"io/ioutil"
 	"io/ioutil"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 
 
 	"google.golang.org/grpc/grpclog"
 	"google.golang.org/grpc/grpclog"
 )
 )

+ 1 - 1
clientv3/integration/main_test.go

@@ -8,7 +8,7 @@ import (
 	"os"
 	"os"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestMain(m *testing.M) {
 func TestMain(m *testing.M) {

+ 7 - 7
clientv3/integration/maintenance_test.go

@@ -27,13 +27,13 @@ import (
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/lease"
-	"go.etcd.io/etcd/v3/mvcc"
-	"go.etcd.io/etcd/v3/mvcc/backend"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/lease"
+	"go.etcd.io/etcd/mvcc"
+	"go.etcd.io/etcd/mvcc/backend"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestMaintenanceHashKV(t *testing.T) {
 func TestMaintenanceHashKV(t *testing.T) {

+ 4 - 4
clientv3/integration/metrics_test.go

@@ -25,10 +25,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
-	"go.etcd.io/etcd/v3/pkg/transport"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
+	"go.etcd.io/etcd/pkg/transport"
 
 
 	grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
 	grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 	"github.com/prometheus/client_golang/prometheus/promhttp"

+ 4 - 4
clientv3/integration/mirror_test.go

@@ -22,10 +22,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3/mirror"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3/mirror"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/mvcc/mvccpb"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestMirrorSync(t *testing.T) {
 func TestMirrorSync(t *testing.T) {

+ 5 - 5
clientv3/integration/namespace_test.go

@@ -19,11 +19,11 @@ import (
 	"reflect"
 	"reflect"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/namespace"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/namespace"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/mvcc/mvccpb"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestNamespacePutGet(t *testing.T) {
 func TestNamespacePutGet(t *testing.T) {

+ 5 - 5
clientv3/integration/network_partition_test.go

@@ -22,11 +22,11 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )
 
 

+ 3 - 3
clientv3/integration/role_test.go

@@ -18,9 +18,9 @@ import (
 	"context"
 	"context"
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestRoleError(t *testing.T) {
 func TestRoleError(t *testing.T) {

+ 4 - 4
clientv3/integration/server_shutdown_test.go

@@ -21,10 +21,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
 	"google.golang.org/grpc/status"

+ 5 - 5
clientv3/integration/txn_test.go

@@ -20,11 +20,11 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/embed"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/embed"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestTxnError(t *testing.T) {
 func TestTxnError(t *testing.T) {

+ 4 - 4
clientv3/integration/user_test.go

@@ -19,10 +19,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )
 
 

+ 1 - 1
clientv3/integration/util.go

@@ -19,7 +19,7 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 // mustWaitPinReady waits up to 3-second until connection is up (pin endpoint).
 // mustWaitPinReady waits up to 3-second until connection is up (pin endpoint).

+ 3 - 3
clientv3/integration/watch_fragment_test.go

@@ -23,9 +23,9 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 // TestWatchFragmentDisable ensures that large watch
 // TestWatchFragmentDisable ensures that large watch

+ 6 - 6
clientv3/integration/watch_test.go

@@ -23,12 +23,12 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	"go.etcd.io/etcd/v3/integration"
-	mvccpb "go.etcd.io/etcd/v3/mvcc/mvccpb"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/integration"
+	mvccpb "go.etcd.io/etcd/mvcc/mvccpb"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"google.golang.org/grpc/metadata"
 	"google.golang.org/grpc/metadata"
 )
 )

+ 1 - 1
clientv3/kv.go

@@ -17,7 +17,7 @@ package clientv3
 import (
 import (
 	"context"
 	"context"
 
 
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )

+ 2 - 2
clientv3/lease.go

@@ -19,8 +19,8 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"

+ 3 - 3
clientv3/leasing/cache.go

@@ -20,9 +20,9 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
-	v3pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
+	v3 "go.etcd.io/etcd/clientv3"
+	v3pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/mvcc/mvccpb"
 )
 )
 
 
 const revokeBackoff = 2 * time.Second
 const revokeBackoff = 2 * time.Second

+ 5 - 5
clientv3/leasing/kv.go

@@ -20,11 +20,11 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/clientv3/concurrency"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
+	v3 "go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/clientv3/concurrency"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/mvcc/mvccpb"
 
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
 	"google.golang.org/grpc/status"

+ 2 - 2
clientv3/leasing/txn.go

@@ -18,8 +18,8 @@ import (
 	"context"
 	"context"
 	"strings"
 	"strings"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
-	v3pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	v3 "go.etcd.io/etcd/clientv3"
+	v3pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 type txnLeasing struct {
 type txnLeasing struct {

+ 2 - 2
clientv3/leasing/util.go

@@ -17,8 +17,8 @@ package leasing
 import (
 import (
 	"bytes"
 	"bytes"
 
 
-	v3 "go.etcd.io/etcd/v3/clientv3"
-	v3pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	v3 "go.etcd.io/etcd/clientv3"
+	v3pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 func compareInt64(a, b int64) int {
 func compareInt64(a, b int64) int {

+ 1 - 1
clientv3/logger.go

@@ -18,7 +18,7 @@ import (
 	"io/ioutil"
 	"io/ioutil"
 	"sync"
 	"sync"
 
 
-	"go.etcd.io/etcd/v3/pkg/logutil"
+	"go.etcd.io/etcd/pkg/logutil"
 
 
 	"google.golang.org/grpc/grpclog"
 	"google.golang.org/grpc/grpclog"
 )
 )

+ 2 - 2
clientv3/main_test.go

@@ -22,8 +22,8 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 // TestMain sets up an etcd cluster if running the examples.
 // TestMain sets up an etcd cluster if running the examples.

+ 1 - 1
clientv3/maintenance.go

@@ -19,7 +19,7 @@ import (
 	"fmt"
 	"fmt"
 	"io"
 	"io"
 
 
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )

+ 1 - 1
clientv3/mirror/syncer.go

@@ -18,7 +18,7 @@ package mirror
 import (
 import (
 	"context"
 	"context"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 const (
 const (

+ 3 - 3
clientv3/namespace/kv.go

@@ -17,9 +17,9 @@ package namespace
 import (
 import (
 	"context"
 	"context"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 type kvPrefix struct {
 type kvPrefix struct {

+ 1 - 1
clientv3/namespace/lease.go

@@ -18,7 +18,7 @@ import (
 	"bytes"
 	"bytes"
 	"context"
 	"context"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 type leasePrefix struct {
 type leasePrefix struct {

+ 1 - 1
clientv3/namespace/watch.go

@@ -18,7 +18,7 @@ import (
 	"context"
 	"context"
 	"sync"
 	"sync"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 type watcherPrefix struct {
 type watcherPrefix struct {

+ 2 - 2
clientv3/naming/doc.go

@@ -17,8 +17,8 @@
 // To use, first import the packages:
 // To use, first import the packages:
 //
 //
 //	import (
 //	import (
-//		"go.etcd.io/etcd/v3/clientv3"
-//		etcdnaming "go.etcd.io/etcd/v3/clientv3/naming"
+//		"go.etcd.io/etcd/clientv3"
+//		etcdnaming "go.etcd.io/etcd/clientv3/naming"
 //
 //
 //		"google.golang.org/grpc"
 //		"google.golang.org/grpc"
 //		"google.golang.org/grpc/naming"
 //		"google.golang.org/grpc/naming"

+ 1 - 1
clientv3/naming/grpc.go

@@ -19,7 +19,7 @@ import (
 	"encoding/json"
 	"encoding/json"
 	"fmt"
 	"fmt"
 
 
-	etcd "go.etcd.io/etcd/v3/clientv3"
+	etcd "go.etcd.io/etcd/clientv3"
 
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/naming"
 	"google.golang.org/grpc/naming"

+ 3 - 3
clientv3/naming/grpc_test.go

@@ -20,9 +20,9 @@ import (
 	"reflect"
 	"reflect"
 	"testing"
 	"testing"
 
 
-	etcd "go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	etcd "go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"google.golang.org/grpc/naming"
 	"google.golang.org/grpc/naming"
 )
 )

+ 1 - 1
clientv3/op.go

@@ -14,7 +14,7 @@
 
 
 package clientv3
 package clientv3
 
 
-import pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+import pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 
 
 type opType int
 type opType int
 
 

+ 1 - 1
clientv3/op_test.go

@@ -18,7 +18,7 @@ import (
 	"reflect"
 	"reflect"
 	"testing"
 	"testing"
 
 
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 )
 )
 
 
 // TestOpWithSort tests if WithSort(ASCEND, KEY) and WithLimit are specified,
 // TestOpWithSort tests if WithSort(ASCEND, KEY) and WithLimit are specified,

+ 1 - 1
clientv3/ordering/kv.go

@@ -18,7 +18,7 @@ import (
 	"context"
 	"context"
 	"sync"
 	"sync"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 // kvOrdering ensures that serialized requests do not return
 // kvOrdering ensures that serialized requests do not return

+ 4 - 4
clientv3/ordering/kv_test.go

@@ -22,10 +22,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestDetectKvOrderViolation(t *testing.T) {
 func TestDetectKvOrderViolation(t *testing.T) {

+ 1 - 1
clientv3/ordering/logger_test.go

@@ -17,7 +17,7 @@ package ordering
 import (
 import (
 	"io/ioutil"
 	"io/ioutil"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 
 
 	"google.golang.org/grpc/grpclog"
 	"google.golang.org/grpc/grpclog"
 )
 )

+ 1 - 1
clientv3/ordering/util.go

@@ -19,7 +19,7 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
+	"go.etcd.io/etcd/clientv3"
 )
 )
 
 
 type OrderViolationFunc func(op clientv3.Op, resp clientv3.OpResponse, prevRev int64) error
 type OrderViolationFunc func(op clientv3.Op, resp clientv3.OpResponse, prevRev int64) error

+ 3 - 3
clientv3/ordering/util_test.go

@@ -19,9 +19,9 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/integration"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/integration"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestEndpointSwitchResolvesViolation(t *testing.T) {
 func TestEndpointSwitchResolvesViolation(t *testing.T) {

+ 2 - 2
clientv3/retry.go

@@ -17,8 +17,8 @@ package clientv3
 import (
 import (
 	"context"
 	"context"
 
 
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"

+ 1 - 1
clientv3/retry_interceptor.go

@@ -23,7 +23,7 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
+	"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"

+ 4 - 4
clientv3/snapshot/member_test.go

@@ -22,10 +22,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/embed"
-	"go.etcd.io/etcd/v3/etcdserver"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/embed"
+	"go.etcd.io/etcd/etcdserver"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 // TestSnapshotV3RestoreMultiMemberAdd ensures that multiple members
 // TestSnapshotV3RestoreMultiMemberAdd ensures that multiple members

+ 15 - 15
clientv3/snapshot/v3_snapshot.go

@@ -28,21 +28,21 @@ import (
 	"strings"
 	"strings"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/etcdserver"
-	"go.etcd.io/etcd/v3/etcdserver/api/membership"
-	"go.etcd.io/etcd/v3/etcdserver/api/snap"
-	"go.etcd.io/etcd/v3/etcdserver/api/v2store"
-	"go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	"go.etcd.io/etcd/v3/lease"
-	"go.etcd.io/etcd/v3/mvcc"
-	"go.etcd.io/etcd/v3/mvcc/backend"
-	"go.etcd.io/etcd/v3/pkg/fileutil"
-	"go.etcd.io/etcd/v3/pkg/types"
-	"go.etcd.io/etcd/v3/raft"
-	"go.etcd.io/etcd/v3/raft/raftpb"
-	"go.etcd.io/etcd/v3/wal"
-	"go.etcd.io/etcd/v3/wal/walpb"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/etcdserver"
+	"go.etcd.io/etcd/etcdserver/api/membership"
+	"go.etcd.io/etcd/etcdserver/api/snap"
+	"go.etcd.io/etcd/etcdserver/api/v2store"
+	"go.etcd.io/etcd/etcdserver/etcdserverpb"
+	"go.etcd.io/etcd/lease"
+	"go.etcd.io/etcd/mvcc"
+	"go.etcd.io/etcd/mvcc/backend"
+	"go.etcd.io/etcd/pkg/fileutil"
+	"go.etcd.io/etcd/pkg/types"
+	"go.etcd.io/etcd/raft"
+	"go.etcd.io/etcd/raft/raftpb"
+	"go.etcd.io/etcd/wal"
+	"go.etcd.io/etcd/wal/walpb"
 
 
 	bolt "go.etcd.io/bbolt"
 	bolt "go.etcd.io/bbolt"
 	"go.uber.org/zap"
 	"go.uber.org/zap"

+ 4 - 4
clientv3/snapshot/v3_snapshot_test.go

@@ -25,10 +25,10 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/clientv3"
-	"go.etcd.io/etcd/v3/embed"
-	"go.etcd.io/etcd/v3/pkg/fileutil"
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/clientv3"
+	"go.etcd.io/etcd/embed"
+	"go.etcd.io/etcd/pkg/fileutil"
+	"go.etcd.io/etcd/pkg/testutil"
 
 
 	"go.uber.org/zap"
 	"go.uber.org/zap"
 )
 )

+ 1 - 1
clientv3/txn.go

@@ -18,7 +18,7 @@ import (
 	"context"
 	"context"
 	"sync"
 	"sync"
 
 
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 )
 )

+ 1 - 1
clientv3/txn_test.go

@@ -18,7 +18,7 @@ import (
 	"testing"
 	"testing"
 	"time"
 	"time"
 
 
-	"go.etcd.io/etcd/v3/pkg/testutil"
+	"go.etcd.io/etcd/pkg/testutil"
 )
 )
 
 
 func TestTxnPanics(t *testing.T) {
 func TestTxnPanics(t *testing.T) {

+ 3 - 3
clientv3/watch.go

@@ -21,9 +21,9 @@ import (
 	"sync"
 	"sync"
 	"time"
 	"time"
 
 
-	v3rpc "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes"
-	pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb"
-	mvccpb "go.etcd.io/etcd/v3/mvcc/mvccpb"
+	v3rpc "go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
+	pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
+	mvccpb "go.etcd.io/etcd/mvcc/mvccpb"
 
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/codes"

+ 1 - 1
clientv3/watch_test.go

@@ -17,7 +17,7 @@ package clientv3
 import (
 import (
 	"testing"
 	"testing"
 
 
-	"go.etcd.io/etcd/v3/mvcc/mvccpb"
+	"go.etcd.io/etcd/mvcc/mvccpb"
 )
 )
 
 
 func TestEvent(t *testing.T) {
 func TestEvent(t *testing.T) {

Niektoré súbory nie sú zobrazené, pretože je v týchto rozdielových dátach zmenené mnoho súborov