diff --git a/Documentation/learning/api.md b/Documentation/learning/api.md index 828c73eee..90de19c31 100644 --- a/Documentation/learning/api.md +++ b/Documentation/learning/api.md @@ -475,9 +475,9 @@ message LeaseKeepAliveResponse { * TTL - the new time-to-live, in seconds, that the lease has remaining. [elections]: https://github.com/etcd-io/etcd/blob/master/clientv3/concurrency/election.go -[kv-proto]: https://github.com/etcd-io/etcd/blob/master/mvcc/mvccpb/kv.proto +[kv-proto]: https://github.com/etcd-io/etcd/blob/master/api/mvccpb/kv.proto [grpc-api]: ../dev-guide/api_reference_v3.md -[grpc-service]: https://github.com/etcd-io/etcd/blob/master/etcdserver/etcdserverpb/rpc.proto +[grpc-service]: https://github.com/etcd-io/etcd/blob/master/api/etcdserverpb/rpc.proto [locks]: https://github.com/etcd-io/etcd/blob/master/clientv3/concurrency/mutex.go [mvcc]: https://en.wikipedia.org/wiki/Multiversion_concurrency_control [stm]: https://github.com/etcd-io/etcd/blob/master/clientv3/concurrency/stm.go diff --git a/Documentation/rfc/v3api.md b/Documentation/rfc/v3api.md index 21e081da4..6cee95e06 100644 --- a/Documentation/rfc/v3api.md +++ b/Documentation/rfc/v3api.md @@ -209,5 +209,5 @@ WatchResponse { ``` -[api-protobuf]: https://github.com/etcd-io/etcd/blob/master/etcdserver/etcdserverpb/rpc.proto -[kv-protobuf]: https://github.com/etcd-io/etcd/blob/master/mvcc/mvccpb/kv.proto +[api-protobuf]: https://github.com/etcd-io/etcd/blob/master/api/etcdserverpb/rpc.proto +[kv-protobuf]: https://github.com/etcd-io/etcd/blob/master/api/mvccpb/kv.proto diff --git a/api/etcdserverpb/gw/rpc.pb.gw.go b/api/etcdserverpb/gw/rpc.pb.gw.go index 5b1f7eba2..2ace64f13 100644 --- a/api/etcdserverpb/gw/rpc.pb.gw.go +++ b/api/etcdserverpb/gw/rpc.pb.gw.go @@ -1,5 +1,5 @@ // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT. -// source: etcdserver/etcdserverpb/rpc.proto +// source: client/api/etcdserverpb/rpc.proto /* Package etcdserverpb is a reverse proxy. @@ -9,7 +9,7 @@ It translates gRPC into RESTful JSON APIs. package gw import ( - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + "go.etcd.io/etcd/v3/api/etcdserverpb" "io" "net/http" diff --git a/api/etcdserverpb/raft_internal.proto b/api/etcdserverpb/raft_internal.proto index b7f2f311f..68926e59f 100644 --- a/api/etcdserverpb/raft_internal.proto +++ b/api/etcdserverpb/raft_internal.proto @@ -4,7 +4,7 @@ package etcdserverpb; import "gogoproto/gogo.proto"; import "etcdserver.proto"; import "rpc.proto"; -import "etcd/etcdserver/api/membership/membershippb/membership.proto"; +import "etcd/api/membershippb/membership.proto"; option (gogoproto.marshaler_all) = true; option (gogoproto.sizer_all) = true; diff --git a/api/etcdserverpb/raft_internal_stringer_test.go b/api/etcdserverpb/raft_internal_stringer_test.go index 49e38e77c..35be87824 100644 --- a/api/etcdserverpb/raft_internal_stringer_test.go +++ b/api/etcdserverpb/raft_internal_stringer_test.go @@ -17,7 +17,7 @@ package etcdserverpb_test import ( "testing" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" ) // TestInvalidGoYypeIntPanic tests conditions that caused diff --git a/api/etcdserverpb/rpc.proto b/api/etcdserverpb/rpc.proto index 1c27bafae..e63d4057b 100644 --- a/api/etcdserverpb/rpc.proto +++ b/api/etcdserverpb/rpc.proto @@ -2,8 +2,8 @@ syntax = "proto3"; package etcdserverpb; import "gogoproto/gogo.proto"; -import "etcd/mvcc/mvccpb/kv.proto"; -import "etcd/auth/authpb/auth.proto"; +import "etcd/api/mvccpb/kv.proto"; +import "etcd/api/authpb/auth.proto"; // for grpc-gateway import "google/api/annotations.proto"; diff --git a/auth/range_perm_cache.go b/auth/range_perm_cache.go index 9e33c0535..c4ad8e7c4 100644 --- a/auth/range_perm_cache.go +++ b/auth/range_perm_cache.go @@ -15,7 +15,7 @@ package auth import ( - "go.etcd.io/etcd/v3/auth/authpb" + "go.etcd.io/etcd/api/v3/authpb" "go.etcd.io/etcd/v3/mvcc/backend" "go.etcd.io/etcd/v3/pkg/adt" diff --git a/auth/range_perm_cache_test.go b/auth/range_perm_cache_test.go index 5e697d1b2..99be6b840 100644 --- a/auth/range_perm_cache_test.go +++ b/auth/range_perm_cache_test.go @@ -17,7 +17,7 @@ package auth import ( "testing" - "go.etcd.io/etcd/v3/auth/authpb" + "go.etcd.io/etcd/api/v3/authpb" "go.etcd.io/etcd/v3/pkg/adt" "go.uber.org/zap" diff --git a/auth/store.go b/auth/store.go index c6d02495b..674577a98 100644 --- a/auth/store.go +++ b/auth/store.go @@ -26,10 +26,10 @@ import ( "sync/atomic" "time" - "go.etcd.io/etcd/v3/auth/authpb" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/authpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/etcdserver/cindex" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/mvcc/backend" "go.uber.org/zap" diff --git a/auth/store_test.go b/auth/store_test.go index 760126f23..9448a7655 100644 --- a/auth/store_test.go +++ b/auth/store_test.go @@ -25,9 +25,9 @@ import ( "testing" "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/api/v3/authpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/mvcc/backend" "go.uber.org/zap" diff --git a/client/client.go b/client/client.go index 197b90247..ee6e0ef96 100644 --- a/client/client.go +++ b/client/client.go @@ -29,7 +29,7 @@ import ( "sync" "time" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" ) var ( diff --git a/client/client_test.go b/client/client_test.go index 8691db2df..efca97b01 100644 --- a/client/client_test.go +++ b/client/client_test.go @@ -29,8 +29,8 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/pkg/testutil" - "go.etcd.io/etcd/v3/version" ) type actionAssertingHTTPClient struct { diff --git a/clientv3/auth.go b/clientv3/auth.go index 39d391e94..a6f75d321 100644 --- a/clientv3/auth.go +++ b/clientv3/auth.go @@ -19,8 +19,8 @@ import ( "fmt" "strings" - "go.etcd.io/etcd/v3/auth/authpb" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + "go.etcd.io/etcd/api/v3/authpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" ) diff --git a/clientv3/balancer/balancer_test.go b/clientv3/balancer/balancer_test.go index 31f1fcbab..28ace00fd 100644 --- a/clientv3/balancer/balancer_test.go +++ b/clientv3/balancer/balancer_test.go @@ -21,9 +21,9 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "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.uber.org/zap" diff --git a/clientv3/client.go b/clientv3/client.go index 960bb4099..8adf75551 100644 --- a/clientv3/client.go +++ b/clientv3/client.go @@ -26,11 +26,11 @@ import ( "time" "github.com/google/uuid" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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/clientv3/credentials" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/logutil" "go.uber.org/zap" "google.golang.org/grpc" diff --git a/clientv3/client_test.go b/clientv3/client_test.go index 232aa441c..963a737f3 100644 --- a/clientv3/client_test.go +++ b/clientv3/client_test.go @@ -21,7 +21,7 @@ import ( "testing" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/testutil" "google.golang.org/grpc" diff --git a/clientv3/cluster.go b/clientv3/cluster.go index 58721c4e0..3c9d88c0b 100644 --- a/clientv3/cluster.go +++ b/clientv3/cluster.go @@ -17,7 +17,7 @@ package clientv3 import ( "context" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" "google.golang.org/grpc" diff --git a/clientv3/compact_op.go b/clientv3/compact_op.go index b1b09708a..a6e660aa8 100644 --- a/clientv3/compact_op.go +++ b/clientv3/compact_op.go @@ -15,7 +15,7 @@ package clientv3 import ( - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" ) // CompactOp represents a compact operation. diff --git a/clientv3/compact_op_test.go b/clientv3/compact_op_test.go index c4ddfc89e..f483322ad 100644 --- a/clientv3/compact_op_test.go +++ b/clientv3/compact_op_test.go @@ -18,7 +18,7 @@ import ( "reflect" "testing" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + "go.etcd.io/etcd/api/v3/etcdserverpb" ) func TestCompactOp(t *testing.T) { diff --git a/clientv3/compare.go b/clientv3/compare.go index 149ab7893..e2967cf38 100644 --- a/clientv3/compare.go +++ b/clientv3/compare.go @@ -15,7 +15,7 @@ package clientv3 import ( - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" ) type CompareTarget int diff --git a/clientv3/concurrency/election.go b/clientv3/concurrency/election.go index 5dadb2e1b..7e7821579 100644 --- a/clientv3/concurrency/election.go +++ b/clientv3/concurrency/election.go @@ -19,9 +19,9 @@ import ( "errors" "fmt" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) var ( diff --git a/clientv3/concurrency/key.go b/clientv3/concurrency/key.go index 684019ac5..61f2abe5a 100644 --- a/clientv3/concurrency/key.go +++ b/clientv3/concurrency/key.go @@ -18,9 +18,9 @@ import ( "context" "fmt" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) func waitDelete(ctx context.Context, client *v3.Client, key string, rev int64) error { diff --git a/clientv3/concurrency/mutex.go b/clientv3/concurrency/mutex.go index 8a1ef3fb9..22ecf2d1f 100644 --- a/clientv3/concurrency/mutex.go +++ b/clientv3/concurrency/mutex.go @@ -20,8 +20,8 @@ import ( "fmt" "sync" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" v3 "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) // ErrLocked is returned by TryLock when Mutex is already locked by another session. diff --git a/clientv3/credentials/credentials.go b/clientv3/credentials/credentials.go index bb049d045..42f688eb3 100644 --- a/clientv3/credentials/credentials.go +++ b/clientv3/credentials/credentials.go @@ -22,7 +22,7 @@ import ( "net" "sync" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" grpccredentials "google.golang.org/grpc/credentials" ) diff --git a/clientv3/ctx.go b/clientv3/ctx.go index a937f94e0..56b69cf2e 100644 --- a/clientv3/ctx.go +++ b/clientv3/ctx.go @@ -17,8 +17,8 @@ package clientv3 import ( "context" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/version" "google.golang.org/grpc/metadata" ) diff --git a/clientv3/ctx_test.go b/clientv3/ctx_test.go index 74deed61b..c0e054341 100644 --- a/clientv3/ctx_test.go +++ b/clientv3/ctx_test.go @@ -19,8 +19,8 @@ import ( "reflect" "testing" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/version" "google.golang.org/grpc/metadata" ) diff --git a/clientv3/example_kv_test.go b/clientv3/example_kv_test.go index f5cbd7921..7aa4f6856 100644 --- a/clientv3/example_kv_test.go +++ b/clientv3/example_kv_test.go @@ -19,8 +19,8 @@ import ( "fmt" "log" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" ) func ExampleKV_put() { diff --git a/clientv3/integration/black_hole_test.go b/clientv3/integration/black_hole_test.go index 950e0dae5..769bdbf42 100644 --- a/clientv3/integration/black_hole_test.go +++ b/clientv3/integration/black_hole_test.go @@ -21,8 +21,8 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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" "google.golang.org/grpc" diff --git a/clientv3/integration/dial_test.go b/clientv3/integration/dial_test.go index ecf1a05dc..9e62ce6ab 100644 --- a/clientv3/integration/dial_test.go +++ b/clientv3/integration/dial_test.go @@ -21,8 +21,8 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "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" diff --git a/clientv3/integration/kv_test.go b/clientv3/integration/kv_test.go index 168e64a20..3e25430c8 100644 --- a/clientv3/integration/kv_test.go +++ b/clientv3/integration/kv_test.go @@ -25,12 +25,12 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/version" "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/v3/version" "google.golang.org/grpc" "google.golang.org/grpc/codes" diff --git a/clientv3/integration/lease_test.go b/clientv3/integration/lease_test.go index 51b0cd05e..49815806c 100644 --- a/clientv3/integration/lease_test.go +++ b/clientv3/integration/lease_test.go @@ -23,9 +23,9 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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" ) diff --git a/clientv3/integration/maintenance_test.go b/clientv3/integration/maintenance_test.go index db160d212..b3cea9dbb 100644 --- a/clientv3/integration/maintenance_test.go +++ b/clientv3/integration/maintenance_test.go @@ -28,8 +28,8 @@ import ( "go.uber.org/zap" "google.golang.org/grpc" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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" diff --git a/clientv3/integration/mirror_test.go b/clientv3/integration/mirror_test.go index 48756ef2c..1d2397415 100644 --- a/clientv3/integration/mirror_test.go +++ b/clientv3/integration/mirror_test.go @@ -22,9 +22,9 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "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" ) diff --git a/clientv3/integration/namespace_test.go b/clientv3/integration/namespace_test.go index 959f419e8..7fa5ced08 100644 --- a/clientv3/integration/namespace_test.go +++ b/clientv3/integration/namespace_test.go @@ -19,10 +19,10 @@ import ( "reflect" "testing" + "go.etcd.io/etcd/api/v3/mvccpb" "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" ) diff --git a/clientv3/integration/network_partition_test.go b/clientv3/integration/network_partition_test.go index 2787b4c54..e3523d325 100644 --- a/clientv3/integration/network_partition_test.go +++ b/clientv3/integration/network_partition_test.go @@ -22,9 +22,9 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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" "google.golang.org/grpc" diff --git a/clientv3/integration/role_test.go b/clientv3/integration/role_test.go index 61f2db6a2..0a75cf47c 100644 --- a/clientv3/integration/role_test.go +++ b/clientv3/integration/role_test.go @@ -18,7 +18,7 @@ import ( "context" "testing" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/integration" "go.etcd.io/etcd/v3/pkg/testutil" ) diff --git a/clientv3/integration/server_shutdown_test.go b/clientv3/integration/server_shutdown_test.go index d3cef6c18..a95c96237 100644 --- a/clientv3/integration/server_shutdown_test.go +++ b/clientv3/integration/server_shutdown_test.go @@ -21,8 +21,8 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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" diff --git a/clientv3/integration/txn_test.go b/clientv3/integration/txn_test.go index 9c4a4fd6f..050ae5011 100644 --- a/clientv3/integration/txn_test.go +++ b/clientv3/integration/txn_test.go @@ -20,9 +20,9 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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" ) diff --git a/clientv3/integration/user_test.go b/clientv3/integration/user_test.go index 81fcd7721..e697f3cb8 100644 --- a/clientv3/integration/user_test.go +++ b/clientv3/integration/user_test.go @@ -19,8 +19,8 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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" "google.golang.org/grpc" diff --git a/clientv3/integration/watch_test.go b/clientv3/integration/watch_test.go index e33e7605a..8e53f83f1 100644 --- a/clientv3/integration/watch_test.go +++ b/clientv3/integration/watch_test.go @@ -24,13 +24,13 @@ import ( "testing" "time" + mvccpb "go.etcd.io/etcd/api/v3/mvccpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/version" "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/v3/version" "google.golang.org/grpc/metadata" ) diff --git a/clientv3/kv.go b/clientv3/kv.go index 0628ed0f1..5e9fb7d45 100644 --- a/clientv3/kv.go +++ b/clientv3/kv.go @@ -17,7 +17,7 @@ package clientv3 import ( "context" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" ) diff --git a/clientv3/lease.go b/clientv3/lease.go index 5a26709c4..eb6e8dc3c 100644 --- a/clientv3/lease.go +++ b/clientv3/lease.go @@ -19,8 +19,8 @@ import ( "sync" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.uber.org/zap" "google.golang.org/grpc" diff --git a/clientv3/leasing/cache.go b/clientv3/leasing/cache.go index 377a487c7..d2683a549 100644 --- a/clientv3/leasing/cache.go +++ b/clientv3/leasing/cache.go @@ -20,9 +20,9 @@ import ( "sync" "time" + v3pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - v3pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) const revokeBackoff = 2 * time.Second diff --git a/clientv3/leasing/kv.go b/clientv3/leasing/kv.go index 804eeb2cf..d7bf95fe8 100644 --- a/clientv3/leasing/kv.go +++ b/clientv3/leasing/kv.go @@ -20,11 +20,11 @@ import ( "sync" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" 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" "google.golang.org/grpc/codes" "google.golang.org/grpc/status" diff --git a/clientv3/leasing/txn.go b/clientv3/leasing/txn.go index a9e4ed4a6..db34e48cb 100644 --- a/clientv3/leasing/txn.go +++ b/clientv3/leasing/txn.go @@ -18,8 +18,8 @@ import ( "context" "strings" + v3pb "go.etcd.io/etcd/api/v3/etcdserverpb" v3 "go.etcd.io/etcd/v3/clientv3" - v3pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type txnLeasing struct { diff --git a/clientv3/leasing/util.go b/clientv3/leasing/util.go index f72e1bcf4..5ab191d49 100644 --- a/clientv3/leasing/util.go +++ b/clientv3/leasing/util.go @@ -17,8 +17,8 @@ package leasing import ( "bytes" + v3pb "go.etcd.io/etcd/api/v3/etcdserverpb" v3 "go.etcd.io/etcd/v3/clientv3" - v3pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) func compareInt64(a, b int64) int { diff --git a/clientv3/maintenance.go b/clientv3/maintenance.go index a2a7fd3b6..dbea530e6 100644 --- a/clientv3/maintenance.go +++ b/clientv3/maintenance.go @@ -19,7 +19,7 @@ import ( "fmt" "io" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.uber.org/zap" "google.golang.org/grpc" ) diff --git a/clientv3/namespace/kv.go b/clientv3/namespace/kv.go index 9899222a5..5cc902899 100644 --- a/clientv3/namespace/kv.go +++ b/clientv3/namespace/kv.go @@ -17,9 +17,9 @@ package namespace import ( "context" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type kvPrefix struct { diff --git a/clientv3/op.go b/clientv3/op.go index f0592ccf5..03b0cceaa 100644 --- a/clientv3/op.go +++ b/clientv3/op.go @@ -14,7 +14,7 @@ package clientv3 -import pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" +import pb "go.etcd.io/etcd/api/v3/etcdserverpb" type opType int diff --git a/clientv3/op_test.go b/clientv3/op_test.go index cb0feb59e..762044fc5 100644 --- a/clientv3/op_test.go +++ b/clientv3/op_test.go @@ -18,7 +18,7 @@ import ( "reflect" "testing" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" ) // TestOpWithSort tests if WithSort(ASCEND, KEY) and WithLimit are specified, diff --git a/clientv3/ordering/kv_test.go b/clientv3/ordering/kv_test.go index 6dc1989e4..a349f6019 100644 --- a/clientv3/ordering/kv_test.go +++ b/clientv3/ordering/kv_test.go @@ -20,8 +20,8 @@ import ( "sync" "testing" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type mockKV struct { diff --git a/clientv3/retry.go b/clientv3/retry.go index c4e840303..69ecc6314 100644 --- a/clientv3/retry.go +++ b/clientv3/retry.go @@ -17,8 +17,8 @@ package clientv3 import ( "context" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "google.golang.org/grpc" "google.golang.org/grpc/codes" diff --git a/clientv3/retry_interceptor.go b/clientv3/retry_interceptor.go index 75f51be67..ff9ad601a 100644 --- a/clientv3/retry_interceptor.go +++ b/clientv3/retry_interceptor.go @@ -23,7 +23,7 @@ import ( "sync" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.uber.org/zap" "google.golang.org/grpc" "google.golang.org/grpc/codes" diff --git a/clientv3/snapshot/v3_snapshot.go b/clientv3/snapshot/v3_snapshot.go index 0e883e772..4b1196042 100644 --- a/clientv3/snapshot/v3_snapshot.go +++ b/clientv3/snapshot/v3_snapshot.go @@ -30,13 +30,13 @@ import ( "github.com/dustin/go-humanize" bolt "go.etcd.io/bbolt" + "go.etcd.io/etcd/api/v3/etcdserverpb" "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/cindex" - "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" diff --git a/clientv3/txn.go b/clientv3/txn.go index e4cac1521..22301fba6 100644 --- a/clientv3/txn.go +++ b/clientv3/txn.go @@ -18,7 +18,7 @@ import ( "context" "sync" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" ) diff --git a/clientv3/watch.go b/clientv3/watch.go index 773688488..73b65539e 100644 --- a/clientv3/watch.go +++ b/clientv3/watch.go @@ -21,9 +21,9 @@ import ( "sync" "time" - v3rpc "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - "go.etcd.io/etcd/v3/mvcc/mvccpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" + v3rpc "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.uber.org/zap" "google.golang.org/grpc" diff --git a/clientv3/watch_test.go b/clientv3/watch_test.go index 2efe81076..2a56ca4a9 100644 --- a/clientv3/watch_test.go +++ b/clientv3/watch_test.go @@ -17,7 +17,7 @@ package clientv3 import ( "testing" - "go.etcd.io/etcd/v3/mvcc/mvccpb" + "go.etcd.io/etcd/api/v3/mvccpb" ) func TestEvent(t *testing.T) { diff --git a/contrib/recipes/barrier.go b/contrib/recipes/barrier.go index 0f82b9833..95d1ca866 100644 --- a/contrib/recipes/barrier.go +++ b/contrib/recipes/barrier.go @@ -17,8 +17,8 @@ package recipe import ( "context" + "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) // Barrier creates a key in etcd to block processes, then deletes the key to diff --git a/contrib/recipes/client.go b/contrib/recipes/client.go index d97d0303f..cdaf15553 100644 --- a/contrib/recipes/client.go +++ b/contrib/recipes/client.go @@ -18,8 +18,8 @@ import ( "context" "errors" + spb "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - spb "go.etcd.io/etcd/v3/mvcc/mvccpb" ) var ( diff --git a/contrib/recipes/double_barrier.go b/contrib/recipes/double_barrier.go index 393b22a20..ba6cf3d29 100644 --- a/contrib/recipes/double_barrier.go +++ b/contrib/recipes/double_barrier.go @@ -17,9 +17,9 @@ package recipe import ( "context" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/concurrency" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) // DoubleBarrier blocks processes on Enter until an expected count enters, then diff --git a/contrib/recipes/priority_queue.go b/contrib/recipes/priority_queue.go index cd7b9ecf0..2c4e916aa 100644 --- a/contrib/recipes/priority_queue.go +++ b/contrib/recipes/priority_queue.go @@ -18,8 +18,8 @@ import ( "context" "fmt" + "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) // PriorityQueue implements a multi-reader, multi-writer distributed queue. diff --git a/contrib/recipes/queue.go b/contrib/recipes/queue.go index ef609965b..b71ba1b0e 100644 --- a/contrib/recipes/queue.go +++ b/contrib/recipes/queue.go @@ -17,8 +17,8 @@ package recipe import ( "context" + "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) // Queue implements a multi-reader, multi-writer distributed queue. diff --git a/contrib/recipes/rwmutex.go b/contrib/recipes/rwmutex.go index 6b3a96473..ce6ff2a82 100644 --- a/contrib/recipes/rwmutex.go +++ b/contrib/recipes/rwmutex.go @@ -17,9 +17,9 @@ package recipe import ( "context" + "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/concurrency" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) type RWMutex struct { diff --git a/contrib/recipes/watch.go b/contrib/recipes/watch.go index 0ef394cd7..339fb2e0e 100644 --- a/contrib/recipes/watch.go +++ b/contrib/recipes/watch.go @@ -17,8 +17,8 @@ package recipe import ( "context" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) // WaitEvents waits on a key until it observes the given events and returns the final one. diff --git a/embed/etcd.go b/embed/etcd.go index 85a4c7932..95e43ced9 100644 --- a/embed/etcd.go +++ b/embed/etcd.go @@ -29,6 +29,7 @@ import ( "sync" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api/etcdhttp" "go.etcd.io/etcd/v3/etcdserver/api/rafthttp" @@ -40,7 +41,6 @@ import ( runtimeutil "go.etcd.io/etcd/v3/pkg/runtime" "go.etcd.io/etcd/v3/pkg/transport" "go.etcd.io/etcd/v3/pkg/types" - "go.etcd.io/etcd/v3/version" grpc_prometheus "github.com/grpc-ecosystem/go-grpc-prometheus" "github.com/soheilhy/cmux" diff --git a/embed/serve.go b/embed/serve.go index 71d892c5f..ffd42f2f9 100644 --- a/embed/serve.go +++ b/embed/serve.go @@ -23,6 +23,7 @@ import ( "net/http" "strings" + etcdservergw "go.etcd.io/etcd/api/v3/etcdserverpb/gw" "go.etcd.io/etcd/v3/clientv3/credentials" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api/v3client" @@ -33,7 +34,6 @@ import ( "go.etcd.io/etcd/v3/etcdserver/api/v3lock/v3lockpb" v3lockgw "go.etcd.io/etcd/v3/etcdserver/api/v3lock/v3lockpb/gw" "go.etcd.io/etcd/v3/etcdserver/api/v3rpc" - etcdservergw "go.etcd.io/etcd/v3/etcdserver/etcdserverpb/gw" "go.etcd.io/etcd/v3/pkg/debugutil" "go.etcd.io/etcd/v3/pkg/httputil" "go.etcd.io/etcd/v3/pkg/transport" diff --git a/etcdctl/README.md b/etcdctl/README.md index 5ec84dfd4..2fa019868 100644 --- a/etcdctl/README.md +++ b/etcdctl/README.md @@ -1682,6 +1682,6 @@ backward compatibility for `JSON` format and the format in non-interactive mode. [etcd]: https://github.com/coreos/etcd [READMEv2]: READMEv2.md [v2key]: ../store/node_extern.go#L28-L37 -[v3key]: ../mvcc/mvccpb/kv.proto#L12-L29 -[etcdrpc]: ../etcdserver/etcdserverpb/rpc.proto -[storagerpc]: ../mvcc/mvccpb/kv.proto +[v3key]: ../api/mvccpb/kv.proto#L12-L29 +[etcdrpc]: ../api/etcdserverpb/rpc.proto +[storagerpc]: ../api/mvccpb/kv.proto diff --git a/etcdctl/ctlv2/command/backup_command.go b/etcdctl/ctlv2/command/backup_command.go index 3b6e0c576..a4072684c 100644 --- a/etcdctl/ctlv2/command/backup_command.go +++ b/etcdctl/ctlv2/command/backup_command.go @@ -23,9 +23,9 @@ import ( "regexp" "time" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/etcdserver/api/snap" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/fileutil" "go.etcd.io/etcd/v3/pkg/idutil" "go.etcd.io/etcd/v3/pkg/pbutil" diff --git a/etcdctl/ctlv2/ctl.go b/etcdctl/ctlv2/ctl.go index 4cbfd9415..5e48c3ff6 100644 --- a/etcdctl/ctlv2/ctl.go +++ b/etcdctl/ctlv2/ctl.go @@ -20,8 +20,8 @@ import ( "os" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdctl/ctlv2/command" - "go.etcd.io/etcd/v3/version" "github.com/urfave/cli" ) diff --git a/etcdctl/ctlv3/command/auth_command.go b/etcdctl/ctlv3/command/auth_command.go index 3ec7cb2b4..8a889c60d 100644 --- a/etcdctl/ctlv3/command/auth_command.go +++ b/etcdctl/ctlv3/command/auth_command.go @@ -18,7 +18,7 @@ import ( "fmt" "github.com/spf13/cobra" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" ) // NewAuthCommand returns the cobra command for "auth". diff --git a/etcdctl/ctlv3/command/ep_command.go b/etcdctl/ctlv3/command/ep_command.go index 7cb6bb149..9b97a6681 100644 --- a/etcdctl/ctlv3/command/ep_command.go +++ b/etcdctl/ctlv3/command/ep_command.go @@ -20,8 +20,8 @@ import ( "sync" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" v3 "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/flags" "github.com/spf13/cobra" diff --git a/etcdctl/ctlv3/command/make_mirror_command.go b/etcdctl/ctlv3/command/make_mirror_command.go index eea33e179..9b69077bf 100644 --- a/etcdctl/ctlv3/command/make_mirror_command.go +++ b/etcdctl/ctlv3/command/make_mirror_command.go @@ -23,10 +23,10 @@ import ( "sync/atomic" "time" + "go.etcd.io/etcd/api/v3/mvccpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/mirror" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "github.com/spf13/cobra" ) diff --git a/etcdctl/ctlv3/command/migrate_command.go b/etcdctl/ctlv3/command/migrate_command.go index 12620d136..d45beb7cb 100644 --- a/etcdctl/ctlv3/command/migrate_command.go +++ b/etcdctl/ctlv3/command/migrate_command.go @@ -24,6 +24,8 @@ import ( "path/filepath" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/client" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api" @@ -31,10 +33,8 @@ import ( "go.etcd.io/etcd/v3/etcdserver/api/snap" "go.etcd.io/etcd/v3/etcdserver/api/v2error" "go.etcd.io/etcd/v3/etcdserver/api/v2store" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/mvcc" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/pbutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" diff --git a/etcdctl/ctlv3/command/printer.go b/etcdctl/ctlv3/command/printer.go index 2bb6086c8..7ad9676de 100644 --- a/etcdctl/ctlv3/command/printer.go +++ b/etcdctl/ctlv3/command/printer.go @@ -19,9 +19,9 @@ import ( "fmt" "strings" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" v3 "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/snapshot" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "github.com/dustin/go-humanize" ) diff --git a/etcdctl/ctlv3/command/printer_fields.go b/etcdctl/ctlv3/command/printer_fields.go index 38f5c7d93..6941636fc 100644 --- a/etcdctl/ctlv3/command/printer_fields.go +++ b/etcdctl/ctlv3/command/printer_fields.go @@ -17,10 +17,10 @@ package command import ( "fmt" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + spb "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/snapshot" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - spb "go.etcd.io/etcd/v3/mvcc/mvccpb" ) type fieldsPrinter struct{ printer } diff --git a/etcdctl/ctlv3/command/printer_protobuf.go b/etcdctl/ctlv3/command/printer_protobuf.go index 9c2446c84..8dd04e39d 100644 --- a/etcdctl/ctlv3/command/printer_protobuf.go +++ b/etcdctl/ctlv3/command/printer_protobuf.go @@ -18,9 +18,9 @@ import ( "fmt" "os" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + mvccpb "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - mvccpb "go.etcd.io/etcd/v3/mvcc/mvccpb" ) type pbPrinter struct{ printer } diff --git a/etcdctl/ctlv3/command/printer_simple.go b/etcdctl/ctlv3/command/printer_simple.go index 1ed5c21da..e0213a2a2 100644 --- a/etcdctl/ctlv3/command/printer_simple.go +++ b/etcdctl/ctlv3/command/printer_simple.go @@ -19,9 +19,9 @@ import ( "os" "strings" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" v3 "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/snapshot" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" ) diff --git a/etcdctl/ctlv3/command/txn_command.go b/etcdctl/ctlv3/command/txn_command.go index a04a06f7e..a56ea00ee 100644 --- a/etcdctl/ctlv3/command/txn_command.go +++ b/etcdctl/ctlv3/command/txn_command.go @@ -22,8 +22,8 @@ import ( "strconv" "strings" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "github.com/spf13/cobra" ) diff --git a/etcdctl/ctlv3/command/util.go b/etcdctl/ctlv3/command/util.go index f256ef01b..5c572f069 100644 --- a/etcdctl/ctlv3/command/util.go +++ b/etcdctl/ctlv3/command/util.go @@ -25,8 +25,8 @@ import ( "strings" "time" + pb "go.etcd.io/etcd/api/v3/mvccpb" v3 "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/mvcc/mvccpb" "github.com/spf13/cobra" ) diff --git a/etcdctl/ctlv3/command/version_command.go b/etcdctl/ctlv3/command/version_command.go index e59c64ca0..b65c29904 100644 --- a/etcdctl/ctlv3/command/version_command.go +++ b/etcdctl/ctlv3/command/version_command.go @@ -17,7 +17,7 @@ package command import ( "fmt" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" "github.com/spf13/cobra" ) diff --git a/etcdctl/ctlv3/help.go b/etcdctl/ctlv3/help.go index 229d02092..331e20cdd 100644 --- a/etcdctl/ctlv3/help.go +++ b/etcdctl/ctlv3/help.go @@ -25,7 +25,7 @@ import ( "text/tabwriter" "text/template" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" "github.com/spf13/cobra" "github.com/spf13/pflag" diff --git a/etcdmain/config.go b/etcdmain/config.go index d576d70b9..7295f34f9 100644 --- a/etcdmain/config.go +++ b/etcdmain/config.go @@ -24,10 +24,10 @@ import ( "os" "runtime" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/embed" "go.etcd.io/etcd/v3/pkg/flags" "go.etcd.io/etcd/v3/pkg/logutil" - "go.etcd.io/etcd/v3/version" "go.uber.org/zap" "sigs.k8s.io/yaml" diff --git a/etcdmain/grpc_proxy.go b/etcdmain/grpc_proxy.go index dcab44e4a..29e36b384 100644 --- a/etcdmain/grpc_proxy.go +++ b/etcdmain/grpc_proxy.go @@ -29,6 +29,7 @@ import ( "path/filepath" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/leasing" "go.etcd.io/etcd/v3/clientv3/namespace" @@ -36,7 +37,6 @@ import ( "go.etcd.io/etcd/v3/embed" "go.etcd.io/etcd/v3/etcdserver/api/v3election/v3electionpb" "go.etcd.io/etcd/v3/etcdserver/api/v3lock/v3lockpb" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/debugutil" "go.etcd.io/etcd/v3/pkg/logutil" "go.etcd.io/etcd/v3/pkg/transport" diff --git a/etcdserver/api/capability.go b/etcdserver/api/capability.go index a0edd5b4e..08ca4c186 100644 --- a/etcdserver/api/capability.go +++ b/etcdserver/api/capability.go @@ -17,8 +17,8 @@ package api import ( "sync" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdserver/api/membership" - "go.etcd.io/etcd/v3/version" "go.uber.org/zap" "github.com/coreos/go-semver/semver" diff --git a/etcdserver/api/etcdhttp/base.go b/etcdserver/api/etcdhttp/base.go index 5a1dfa64d..80e97479d 100644 --- a/etcdserver/api/etcdhttp/base.go +++ b/etcdserver/api/etcdhttp/base.go @@ -20,11 +20,11 @@ import ( "fmt" "net/http" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/v2error" "go.etcd.io/etcd/v3/etcdserver/api/v2http/httptypes" - "go.etcd.io/etcd/v3/version" "go.uber.org/zap" ) diff --git a/etcdserver/api/etcdhttp/metrics.go b/etcdserver/api/etcdhttp/metrics.go index 96fd189d5..5765028a7 100644 --- a/etcdserver/api/etcdhttp/metrics.go +++ b/etcdserver/api/etcdhttp/metrics.go @@ -23,8 +23,8 @@ import ( "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/raft" "go.uber.org/zap" ) diff --git a/etcdserver/api/etcdhttp/peer_test.go b/etcdserver/api/etcdhttp/peer_test.go index bc2f206eb..89222d46a 100644 --- a/etcdserver/api/etcdhttp/peer_test.go +++ b/etcdserver/api/etcdhttp/peer_test.go @@ -29,10 +29,10 @@ import ( "go.uber.org/zap" "github.com/coreos/go-semver/semver" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/etcdserver/api/rafthttp" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/types" ) diff --git a/etcdserver/api/etcdhttp/version_test.go b/etcdserver/api/etcdhttp/version_test.go index 63271c704..37a14dd1d 100644 --- a/etcdserver/api/etcdhttp/version_test.go +++ b/etcdserver/api/etcdhttp/version_test.go @@ -20,7 +20,7 @@ import ( "net/http/httptest" "testing" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" ) func TestServeVersion(t *testing.T) { diff --git a/etcdserver/api/membership/cluster.go b/etcdserver/api/membership/cluster.go index b0939131b..aecd9ed15 100644 --- a/etcdserver/api/membership/cluster.go +++ b/etcdserver/api/membership/cluster.go @@ -27,13 +27,13 @@ import ( "sync" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdserver/api/v2store" "go.etcd.io/etcd/v3/mvcc/backend" "go.etcd.io/etcd/v3/pkg/netutil" "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/version" "github.com/coreos/go-semver/semver" "github.com/prometheus/client_golang/prometheus" diff --git a/etcdserver/api/membership/downgrade.go b/etcdserver/api/membership/downgrade.go index 2ec2363c9..9fdafe22a 100644 --- a/etcdserver/api/membership/downgrade.go +++ b/etcdserver/api/membership/downgrade.go @@ -16,7 +16,7 @@ package membership import ( "github.com/coreos/go-semver/semver" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" "go.uber.org/zap" ) diff --git a/etcdserver/api/membership/downgrade_test.go b/etcdserver/api/membership/downgrade_test.go index cbe7e7e5f..8bb612d35 100644 --- a/etcdserver/api/membership/downgrade_test.go +++ b/etcdserver/api/membership/downgrade_test.go @@ -25,7 +25,7 @@ import ( "testing" "github.com/coreos/go-semver/semver" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" "go.uber.org/zap" ) diff --git a/etcdserver/api/rafthttp/http.go b/etcdserver/api/rafthttp/http.go index 51dd290cc..b586e31ff 100644 --- a/etcdserver/api/rafthttp/http.go +++ b/etcdserver/api/rafthttp/http.go @@ -24,11 +24,11 @@ import ( "strings" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdserver/api/snap" pioutil "go.etcd.io/etcd/v3/pkg/ioutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" - "go.etcd.io/etcd/v3/version" humanize "github.com/dustin/go-humanize" "go.uber.org/zap" diff --git a/etcdserver/api/rafthttp/http_test.go b/etcdserver/api/rafthttp/http_test.go index 5cb248c65..7cd4fa982 100644 --- a/etcdserver/api/rafthttp/http_test.go +++ b/etcdserver/api/rafthttp/http_test.go @@ -26,11 +26,11 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdserver/api/snap" "go.etcd.io/etcd/v3/pkg/pbutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" - "go.etcd.io/etcd/v3/version" "go.uber.org/zap" ) diff --git a/etcdserver/api/rafthttp/pipeline_test.go b/etcdserver/api/rafthttp/pipeline_test.go index 0f8388ce8..bf4f33646 100644 --- a/etcdserver/api/rafthttp/pipeline_test.go +++ b/etcdserver/api/rafthttp/pipeline_test.go @@ -24,11 +24,11 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/version" stats "go.etcd.io/etcd/v3/etcdserver/api/v2stats" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" - "go.etcd.io/etcd/v3/version" "go.uber.org/zap" ) diff --git a/etcdserver/api/rafthttp/stream.go b/etcdserver/api/rafthttp/stream.go index 4ee5ed749..f7a9714c2 100644 --- a/etcdserver/api/rafthttp/stream.go +++ b/etcdserver/api/rafthttp/stream.go @@ -25,12 +25,12 @@ import ( "sync" "time" + "go.etcd.io/etcd/api/v3/version" stats "go.etcd.io/etcd/v3/etcdserver/api/v2stats" "go.etcd.io/etcd/v3/pkg/httputil" "go.etcd.io/etcd/v3/pkg/transport" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" - "go.etcd.io/etcd/v3/version" "github.com/coreos/go-semver/semver" "go.uber.org/zap" diff --git a/etcdserver/api/rafthttp/stream_test.go b/etcdserver/api/rafthttp/stream_test.go index d6bf5c153..f97e5ed6d 100644 --- a/etcdserver/api/rafthttp/stream_test.go +++ b/etcdserver/api/rafthttp/stream_test.go @@ -26,11 +26,11 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/version" stats "go.etcd.io/etcd/v3/etcdserver/api/v2stats" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" - "go.etcd.io/etcd/v3/version" "github.com/coreos/go-semver/semver" "go.uber.org/zap" diff --git a/etcdserver/api/rafthttp/util.go b/etcdserver/api/rafthttp/util.go index 204f028f1..f084c0c68 100644 --- a/etcdserver/api/rafthttp/util.go +++ b/etcdserver/api/rafthttp/util.go @@ -23,9 +23,9 @@ import ( "strings" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/pkg/transport" "go.etcd.io/etcd/v3/pkg/types" - "go.etcd.io/etcd/v3/version" "github.com/coreos/go-semver/semver" "go.uber.org/zap" diff --git a/etcdserver/api/rafthttp/util_test.go b/etcdserver/api/rafthttp/util_test.go index 41e1256c6..857f06bc5 100644 --- a/etcdserver/api/rafthttp/util_test.go +++ b/etcdserver/api/rafthttp/util_test.go @@ -22,8 +22,8 @@ import ( "reflect" "testing" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/raft/raftpb" - "go.etcd.io/etcd/v3/version" "github.com/coreos/go-semver/semver" ) diff --git a/etcdserver/api/v2auth/auth.go b/etcdserver/api/v2auth/auth.go index dfefc3545..6cb4d676b 100644 --- a/etcdserver/api/v2auth/auth.go +++ b/etcdserver/api/v2auth/auth.go @@ -26,9 +26,9 @@ import ( "strings" "time" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api/v2error" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" "go.uber.org/zap" diff --git a/etcdserver/api/v2auth/auth_requests.go b/etcdserver/api/v2auth/auth_requests.go index a6cbfe7e5..d3742b889 100644 --- a/etcdserver/api/v2auth/auth_requests.go +++ b/etcdserver/api/v2auth/auth_requests.go @@ -19,9 +19,9 @@ import ( "encoding/json" "path" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api/v2error" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.uber.org/zap" ) diff --git a/etcdserver/api/v2auth/auth_test.go b/etcdserver/api/v2auth/auth_test.go index 6fdac203d..4264a976f 100644 --- a/etcdserver/api/v2auth/auth_test.go +++ b/etcdserver/api/v2auth/auth_test.go @@ -20,10 +20,10 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api/v2error" "go.etcd.io/etcd/v3/etcdserver/api/v2store" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.uber.org/zap" ) diff --git a/etcdserver/api/v2http/client.go b/etcdserver/api/v2http/client.go index d758bd49c..f8a93a7ce 100644 --- a/etcdserver/api/v2http/client.go +++ b/etcdserver/api/v2http/client.go @@ -27,6 +27,7 @@ import ( "strings" "time" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/etcdhttp" @@ -36,7 +37,6 @@ import ( "go.etcd.io/etcd/v3/etcdserver/api/v2http/httptypes" stats "go.etcd.io/etcd/v3/etcdserver/api/v2stats" "go.etcd.io/etcd/v3/etcdserver/api/v2store" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" "github.com/jonboulle/clockwork" diff --git a/etcdserver/api/v2http/client_test.go b/etcdserver/api/v2http/client_test.go index fbf1fae38..2722d9701 100644 --- a/etcdserver/api/v2http/client_test.go +++ b/etcdserver/api/v2http/client_test.go @@ -29,13 +29,13 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/etcdserver/api/v2error" "go.etcd.io/etcd/v3/etcdserver/api/v2http/httptypes" "go.etcd.io/etcd/v3/etcdserver/api/v2store" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" diff --git a/etcdserver/api/v2http/http_test.go b/etcdserver/api/v2http/http_test.go index a5cdbcad4..cc0ddb099 100644 --- a/etcdserver/api/v2http/http_test.go +++ b/etcdserver/api/v2http/http_test.go @@ -22,10 +22,10 @@ import ( "sort" "testing" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/etcdserver/api/v2error" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" diff --git a/etcdserver/api/v2http/metrics.go b/etcdserver/api/v2http/metrics.go index 03ca58b96..848ceade5 100644 --- a/etcdserver/api/v2http/metrics.go +++ b/etcdserver/api/v2http/metrics.go @@ -20,9 +20,9 @@ import ( "net/http" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/v2error" "go.etcd.io/etcd/v3/etcdserver/api/v2http/httptypes" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "github.com/prometheus/client_golang/prometheus" ) diff --git a/etcdserver/api/v2v3/server.go b/etcdserver/api/v2v3/server.go index 0093f6e0a..773b688e1 100644 --- a/etcdserver/api/v2v3/server.go +++ b/etcdserver/api/v2v3/server.go @@ -19,11 +19,11 @@ import ( "net/http" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/membership" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" "github.com/coreos/go-semver/semver" diff --git a/etcdserver/api/v2v3/store.go b/etcdserver/api/v2v3/store.go index e446ceda1..d225181b4 100644 --- a/etcdserver/api/v2v3/store.go +++ b/etcdserver/api/v2v3/store.go @@ -22,11 +22,11 @@ import ( "strings" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/concurrency" "go.etcd.io/etcd/v3/etcdserver/api/v2error" "go.etcd.io/etcd/v3/etcdserver/api/v2store" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) // store implements the Store interface for V2 using diff --git a/etcdserver/api/v3alarm/alarms.go b/etcdserver/api/v3alarm/alarms.go index 0a46f735b..e1035b537 100644 --- a/etcdserver/api/v3alarm/alarms.go +++ b/etcdserver/api/v3alarm/alarms.go @@ -18,7 +18,7 @@ package v3alarm import ( "sync" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/mvcc/backend" "go.etcd.io/etcd/v3/pkg/types" diff --git a/etcdserver/api/v3compactor/compactor.go b/etcdserver/api/v3compactor/compactor.go index 7a05f0693..e352670c1 100644 --- a/etcdserver/api/v3compactor/compactor.go +++ b/etcdserver/api/v3compactor/compactor.go @@ -19,7 +19,7 @@ import ( "fmt" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "github.com/jonboulle/clockwork" "go.uber.org/zap" diff --git a/etcdserver/api/v3compactor/compactor_test.go b/etcdserver/api/v3compactor/compactor_test.go index c10a39858..1060ddb44 100644 --- a/etcdserver/api/v3compactor/compactor_test.go +++ b/etcdserver/api/v3compactor/compactor_test.go @@ -18,7 +18,7 @@ import ( "context" "sync/atomic" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" ) diff --git a/etcdserver/api/v3compactor/periodic.go b/etcdserver/api/v3compactor/periodic.go index fa0d45330..b3c1d3900 100644 --- a/etcdserver/api/v3compactor/periodic.go +++ b/etcdserver/api/v3compactor/periodic.go @@ -19,7 +19,7 @@ import ( "sync" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/mvcc" "github.com/jonboulle/clockwork" diff --git a/etcdserver/api/v3compactor/periodic_test.go b/etcdserver/api/v3compactor/periodic_test.go index 31248d772..08e4eddf3 100644 --- a/etcdserver/api/v3compactor/periodic_test.go +++ b/etcdserver/api/v3compactor/periodic_test.go @@ -19,7 +19,7 @@ import ( "testing" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" "github.com/jonboulle/clockwork" diff --git a/etcdserver/api/v3compactor/revision.go b/etcdserver/api/v3compactor/revision.go index a4d6d3c52..1ab216662 100644 --- a/etcdserver/api/v3compactor/revision.go +++ b/etcdserver/api/v3compactor/revision.go @@ -19,7 +19,7 @@ import ( "sync" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/mvcc" "github.com/jonboulle/clockwork" diff --git a/etcdserver/api/v3compactor/revision_test.go b/etcdserver/api/v3compactor/revision_test.go index f4085abca..90ae6c7c1 100644 --- a/etcdserver/api/v3compactor/revision_test.go +++ b/etcdserver/api/v3compactor/revision_test.go @@ -19,7 +19,7 @@ import ( "testing" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" "github.com/jonboulle/clockwork" diff --git a/etcdserver/api/v3election/v3electionpb/v3election.proto b/etcdserver/api/v3election/v3electionpb/v3election.proto index 918f39fa8..24ccaf138 100644 --- a/etcdserver/api/v3election/v3electionpb/v3election.proto +++ b/etcdserver/api/v3election/v3electionpb/v3election.proto @@ -2,8 +2,8 @@ syntax = "proto3"; package v3electionpb; import "gogoproto/gogo.proto"; -import "etcd/etcdserver/etcdserverpb/rpc.proto"; -import "etcd/mvcc/mvccpb/kv.proto"; +import "etcd/api/etcdserverpb/rpc.proto"; +import "etcd/api/mvccpb/kv.proto"; // for grpc-gateway import "google/api/annotations.proto"; diff --git a/etcdserver/api/v3lock/v3lockpb/v3lock.proto b/etcdserver/api/v3lock/v3lockpb/v3lock.proto index 7220c7f0a..1b5c456ae 100644 --- a/etcdserver/api/v3lock/v3lockpb/v3lock.proto +++ b/etcdserver/api/v3lock/v3lockpb/v3lock.proto @@ -2,7 +2,7 @@ syntax = "proto3"; package v3lockpb; import "gogoproto/gogo.proto"; -import "etcd/etcdserver/etcdserverpb/rpc.proto"; +import "etcd/api/etcdserverpb/rpc.proto"; // for grpc-gateway import "google/api/annotations.proto"; diff --git a/etcdserver/api/v3rpc/auth.go b/etcdserver/api/v3rpc/auth.go index 97129aa03..52cdd6965 100644 --- a/etcdserver/api/v3rpc/auth.go +++ b/etcdserver/api/v3rpc/auth.go @@ -17,8 +17,8 @@ package v3rpc import ( "context" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type AuthServer struct { diff --git a/etcdserver/api/v3rpc/grpc.go b/etcdserver/api/v3rpc/grpc.go index 2e9910746..f3c973d7b 100644 --- a/etcdserver/api/v3rpc/grpc.go +++ b/etcdserver/api/v3rpc/grpc.go @@ -18,8 +18,8 @@ import ( "crypto/tls" "math" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" grpc_middleware "github.com/grpc-ecosystem/go-grpc-middleware" grpc_prometheus "github.com/grpc-ecosystem/go-grpc-prometheus" diff --git a/etcdserver/api/v3rpc/header.go b/etcdserver/api/v3rpc/header.go index 04c5f5714..0238d811c 100644 --- a/etcdserver/api/v3rpc/header.go +++ b/etcdserver/api/v3rpc/header.go @@ -15,8 +15,8 @@ package v3rpc import ( + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type header struct { diff --git a/etcdserver/api/v3rpc/interceptor.go b/etcdserver/api/v3rpc/interceptor.go index fb0328166..3b31b6deb 100644 --- a/etcdserver/api/v3rpc/interceptor.go +++ b/etcdserver/api/v3rpc/interceptor.go @@ -19,13 +19,13 @@ import ( "sync" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.uber.org/zap" "google.golang.org/grpc" "google.golang.org/grpc/metadata" diff --git a/etcdserver/api/v3rpc/key.go b/etcdserver/api/v3rpc/key.go index 19a0320cf..748e9804a 100644 --- a/etcdserver/api/v3rpc/key.go +++ b/etcdserver/api/v3rpc/key.go @@ -18,9 +18,9 @@ package v3rpc import ( "context" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/etcdserver" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/adt" ) diff --git a/etcdserver/api/v3rpc/lease.go b/etcdserver/api/v3rpc/lease.go index 8bbcebad3..170892c21 100644 --- a/etcdserver/api/v3rpc/lease.go +++ b/etcdserver/api/v3rpc/lease.go @@ -18,9 +18,9 @@ import ( "context" "io" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/etcdserver" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/lease" "go.uber.org/zap" diff --git a/etcdserver/api/v3rpc/maintenance.go b/etcdserver/api/v3rpc/maintenance.go index 1d96e970a..9d2dde2b6 100644 --- a/etcdserver/api/v3rpc/maintenance.go +++ b/etcdserver/api/v3rpc/maintenance.go @@ -21,14 +21,14 @@ import ( "time" "github.com/dustin/go-humanize" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/auth" "go.etcd.io/etcd/v3/etcdserver" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/mvcc" "go.etcd.io/etcd/v3/mvcc/backend" "go.etcd.io/etcd/v3/raft" - "go.etcd.io/etcd/v3/version" "go.uber.org/zap" ) diff --git a/etcdserver/api/v3rpc/member.go b/etcdserver/api/v3rpc/member.go index 5cf3feaf7..394594c06 100644 --- a/etcdserver/api/v3rpc/member.go +++ b/etcdserver/api/v3rpc/member.go @@ -18,11 +18,11 @@ import ( "context" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/membership" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" ) diff --git a/etcdserver/api/v3rpc/quota.go b/etcdserver/api/v3rpc/quota.go index b40edbdfc..b26bd27a3 100644 --- a/etcdserver/api/v3rpc/quota.go +++ b/etcdserver/api/v3rpc/quota.go @@ -17,9 +17,9 @@ package v3rpc import ( "context" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/etcdserver" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" ) diff --git a/etcdserver/api/v3rpc/util.go b/etcdserver/api/v3rpc/util.go index 2ae37af05..89938fe05 100644 --- a/etcdserver/api/v3rpc/util.go +++ b/etcdserver/api/v3rpc/util.go @@ -18,11 +18,11 @@ import ( "context" "strings" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/auth" "go.etcd.io/etcd/v3/etcdserver" "go.etcd.io/etcd/v3/etcdserver/api/membership" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc" diff --git a/etcdserver/api/v3rpc/util_test.go b/etcdserver/api/v3rpc/util_test.go index b84a267d5..cd5674a57 100644 --- a/etcdserver/api/v3rpc/util_test.go +++ b/etcdserver/api/v3rpc/util_test.go @@ -19,7 +19,7 @@ import ( "errors" "testing" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/mvcc" "google.golang.org/grpc/codes" diff --git a/etcdserver/api/v3rpc/watch.go b/etcdserver/api/v3rpc/watch.go index 2144779fc..4c7794f6a 100644 --- a/etcdserver/api/v3rpc/watch.go +++ b/etcdserver/api/v3rpc/watch.go @@ -21,12 +21,12 @@ import ( "sync" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/auth" "go.etcd.io/etcd/v3/etcdserver" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/mvcc" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.uber.org/zap" ) diff --git a/etcdserver/api/v3rpc/watch_test.go b/etcdserver/api/v3rpc/watch_test.go index f507f5eab..bd3f4943b 100644 --- a/etcdserver/api/v3rpc/watch_test.go +++ b/etcdserver/api/v3rpc/watch_test.go @@ -19,8 +19,8 @@ import ( "math" "testing" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - "go.etcd.io/etcd/v3/mvcc/mvccpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" ) func TestSendFragment(t *testing.T) { diff --git a/etcdserver/apply.go b/etcdserver/apply.go index 201486a71..fc7667585 100644 --- a/etcdserver/apply.go +++ b/etcdserver/apply.go @@ -22,14 +22,14 @@ import ( "time" "github.com/coreos/go-semver/semver" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/membershippb" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/auth" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/membership" - "go.etcd.io/etcd/v3/etcdserver/api/membership/membershippb" - pb "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/mvccpb" "go.etcd.io/etcd/v3/pkg/traceutil" "go.etcd.io/etcd/v3/pkg/types" diff --git a/etcdserver/apply_auth.go b/etcdserver/apply_auth.go index 40ed7bde5..f36217a52 100644 --- a/etcdserver/apply_auth.go +++ b/etcdserver/apply_auth.go @@ -18,8 +18,8 @@ import ( "context" "sync" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/auth" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc" "go.etcd.io/etcd/v3/pkg/traceutil" diff --git a/etcdserver/cluster_util.go b/etcdserver/cluster_util.go index fc09e1a39..8b9edbb03 100644 --- a/etcdserver/cluster_util.go +++ b/etcdserver/cluster_util.go @@ -24,9 +24,9 @@ import ( "strings" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/pkg/types" - "go.etcd.io/etcd/v3/version" "github.com/coreos/go-semver/semver" "go.uber.org/zap" diff --git a/etcdserver/cluster_util_test.go b/etcdserver/cluster_util_test.go index 29ba9f90d..8571cc08a 100644 --- a/etcdserver/cluster_util_test.go +++ b/etcdserver/cluster_util_test.go @@ -18,8 +18,8 @@ import ( "reflect" "testing" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/pkg/types" - "go.etcd.io/etcd/v3/version" "github.com/coreos/go-semver/semver" "go.uber.org/zap" diff --git a/etcdserver/corrupt.go b/etcdserver/corrupt.go index 5e68c4bd0..a57b993d7 100644 --- a/etcdserver/corrupt.go +++ b/etcdserver/corrupt.go @@ -24,8 +24,8 @@ import ( "strings" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/mvcc" "go.etcd.io/etcd/v3/pkg/traceutil" "go.etcd.io/etcd/v3/pkg/types" diff --git a/etcdserver/metrics.go b/etcdserver/metrics.go index 417e05f21..502f9f739 100644 --- a/etcdserver/metrics.go +++ b/etcdserver/metrics.go @@ -18,8 +18,8 @@ import ( goruntime "runtime" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/pkg/runtime" - "go.etcd.io/etcd/v3/version" "github.com/prometheus/client_golang/prometheus" "go.uber.org/zap" diff --git a/etcdserver/quota.go b/etcdserver/quota.go index 4727ac14a..eb8967d62 100644 --- a/etcdserver/quota.go +++ b/etcdserver/quota.go @@ -17,7 +17,7 @@ package etcdserver import ( "sync" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" humanize "github.com/dustin/go-humanize" "go.uber.org/zap" diff --git a/etcdserver/raft.go b/etcdserver/raft.go index e4bd7635b..b68d1b444 100644 --- a/etcdserver/raft.go +++ b/etcdserver/raft.go @@ -23,9 +23,9 @@ import ( "sync" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/etcdserver/api/rafthttp" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/contention" "go.etcd.io/etcd/v3/pkg/logutil" "go.etcd.io/etcd/v3/pkg/pbutil" diff --git a/etcdserver/server.go b/etcdserver/server.go index 6e04a14d8..fb5d04ea6 100644 --- a/etcdserver/server.go +++ b/etcdserver/server.go @@ -34,10 +34,12 @@ import ( "github.com/prometheus/client_golang/prometheus" "go.uber.org/zap" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/membershippb" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/auth" "go.etcd.io/etcd/v3/etcdserver/api" "go.etcd.io/etcd/v3/etcdserver/api/membership" - "go.etcd.io/etcd/v3/etcdserver/api/membership/membershippb" "go.etcd.io/etcd/v3/etcdserver/api/rafthttp" "go.etcd.io/etcd/v3/etcdserver/api/snap" "go.etcd.io/etcd/v3/etcdserver/api/v2discovery" @@ -47,7 +49,6 @@ import ( "go.etcd.io/etcd/v3/etcdserver/api/v3alarm" "go.etcd.io/etcd/v3/etcdserver/api/v3compactor" "go.etcd.io/etcd/v3/etcdserver/cindex" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/lease/leasehttp" "go.etcd.io/etcd/v3/mvcc" @@ -62,7 +63,6 @@ import ( "go.etcd.io/etcd/v3/pkg/wait" "go.etcd.io/etcd/v3/raft" "go.etcd.io/etcd/v3/raft/raftpb" - "go.etcd.io/etcd/v3/version" "go.etcd.io/etcd/v3/wal" ) diff --git a/etcdserver/server_test.go b/etcdserver/server_test.go index d09ccc30b..fb34d2283 100644 --- a/etcdserver/server_test.go +++ b/etcdserver/server_test.go @@ -27,12 +27,12 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/etcdserver/api/rafthttp" "go.etcd.io/etcd/v3/etcdserver/api/snap" "go.etcd.io/etcd/v3/etcdserver/api/v2store" "go.etcd.io/etcd/v3/etcdserver/cindex" - pb "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" diff --git a/etcdserver/storage.go b/etcdserver/storage.go index 88271aaca..bf8b954d7 100644 --- a/etcdserver/storage.go +++ b/etcdserver/storage.go @@ -17,8 +17,8 @@ package etcdserver import ( "io" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/snap" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/pbutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb" diff --git a/etcdserver/util.go b/etcdserver/util.go index 9c7128097..c519cfbf7 100644 --- a/etcdserver/util.go +++ b/etcdserver/util.go @@ -21,9 +21,9 @@ import ( "time" "github.com/golang/protobuf/proto" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/membership" "go.etcd.io/etcd/v3/etcdserver/api/rafthttp" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/types" "go.uber.org/zap" diff --git a/etcdserver/v2_server.go b/etcdserver/v2_server.go index cf6bc05d6..a95408d8d 100644 --- a/etcdserver/v2_server.go +++ b/etcdserver/v2_server.go @@ -18,8 +18,8 @@ import ( "context" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/v2store" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type RequestV2 pb.Request diff --git a/etcdserver/v3_server.go b/etcdserver/v3_server.go index 2f50f0f0e..8c3881b33 100644 --- a/etcdserver/v3_server.go +++ b/etcdserver/v3_server.go @@ -22,10 +22,10 @@ import ( "strconv" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/membershippb" "go.etcd.io/etcd/v3/auth" "go.etcd.io/etcd/v3/etcdserver/api/membership" - "go.etcd.io/etcd/v3/etcdserver/api/membership/membershippb" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/lease/leasehttp" "go.etcd.io/etcd/v3/mvcc" diff --git a/functional/rpcpb/member.go b/functional/rpcpb/member.go index f9ea5528b..47bd9438d 100644 --- a/functional/rpcpb/member.go +++ b/functional/rpcpb/member.go @@ -22,9 +22,9 @@ import ( "os" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/snapshot" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/logutil" "go.etcd.io/etcd/v3/pkg/transport" diff --git a/functional/runner/help.go b/functional/runner/help.go index 06196a89e..9bf9560a7 100644 --- a/functional/runner/help.go +++ b/functional/runner/help.go @@ -25,7 +25,7 @@ import ( "text/tabwriter" "text/template" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" "github.com/spf13/cobra" "github.com/spf13/pflag" diff --git a/functional/tester/checker_lease_expire.go b/functional/tester/checker_lease_expire.go index 668ee41dc..524977df5 100644 --- a/functional/tester/checker_lease_expire.go +++ b/functional/tester/checker_lease_expire.go @@ -19,8 +19,8 @@ import ( "fmt" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" "go.etcd.io/etcd/v3/functional/rpcpb" "go.uber.org/zap" diff --git a/functional/tester/stresser_key.go b/functional/tester/stresser_key.go index ca3d50ecf..402a1aef9 100644 --- a/functional/tester/stresser_key.go +++ b/functional/tester/stresser_key.go @@ -23,9 +23,9 @@ import ( "sync/atomic" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/etcdserver" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" "go.etcd.io/etcd/v3/functional/rpcpb" "go.etcd.io/etcd/v3/raft" diff --git a/functional/tester/stresser_lease.go b/functional/tester/stresser_lease.go index 45671154e..e046234e8 100644 --- a/functional/tester/stresser_lease.go +++ b/functional/tester/stresser_lease.go @@ -22,8 +22,8 @@ import ( "sync/atomic" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" "go.etcd.io/etcd/v3/functional/rpcpb" "go.uber.org/zap" diff --git a/go.mod b/go.mod index e585a0019..b5e2bb9b7 100644 --- a/go.mod +++ b/go.mod @@ -39,6 +39,7 @@ require ( github.com/urfave/cli v1.20.0 github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2 go.etcd.io/bbolt v1.3.5 + go.etcd.io/etcd/api/v3 v3.0.0-00010101000000-000000000000 go.uber.org/zap v1.15.0 golang.org/x/crypto v0.0.0-20191002192127-34f69633bfdc golang.org/x/net v0.0.0-20190813141303-74dc4d7220e7 @@ -50,3 +51,9 @@ require ( gopkg.in/yaml.v2 v2.2.2 sigs.k8s.io/yaml v1.1.0 ) + +// Bad imports are sometimes causing attempts to pull that code. +// This makes the error more explicit. +replace go.etcd.io/etcd => ./FORBIDDEN_DEPENDENCY + +replace go.etcd.io/etcd/api/v3 => ./api diff --git a/integration/cluster.go b/integration/cluster.go index e29f66616..284319e19 100644 --- a/integration/cluster.go +++ b/integration/cluster.go @@ -33,6 +33,7 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/client" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/embed" @@ -46,7 +47,6 @@ import ( "go.etcd.io/etcd/v3/etcdserver/api/v3lock" lockpb "go.etcd.io/etcd/v3/etcdserver/api/v3lock/v3lockpb" "go.etcd.io/etcd/v3/etcdserver/api/v3rpc" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/logutil" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/tlsutil" diff --git a/integration/cluster_direct.go b/integration/cluster_direct.go index 0db7b232e..c0b15908b 100644 --- a/integration/cluster_direct.go +++ b/integration/cluster_direct.go @@ -17,10 +17,10 @@ package integration import ( + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/etcdserver/api/v3election/v3electionpb" "go.etcd.io/etcd/v3/etcdserver/api/v3lock/v3lockpb" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) const ThroughProxy = false diff --git a/integration/metrics_test.go b/integration/metrics_test.go index 288d5c2a0..8e429b837 100644 --- a/integration/metrics_test.go +++ b/integration/metrics_test.go @@ -22,8 +22,8 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/transport" ) diff --git a/integration/v3_alarm_test.go b/integration/v3_alarm_test.go index 02fa128ca..57aa07ba1 100644 --- a/integration/v3_alarm_test.go +++ b/integration/v3_alarm_test.go @@ -22,9 +22,9 @@ import ( "testing" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/etcdserver/cindex" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/mvcc" "go.etcd.io/etcd/v3/mvcc/backend" "go.etcd.io/etcd/v3/pkg/testutil" diff --git a/integration/v3_auth_test.go b/integration/v3_auth_test.go index 93764d2fc..f928be48e 100644 --- a/integration/v3_auth_test.go +++ b/integration/v3_auth_test.go @@ -21,10 +21,10 @@ import ( "testing" "time" - "go.etcd.io/etcd/v3/auth/authpb" + "go.etcd.io/etcd/api/v3/authpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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/pkg/testutil" ) diff --git a/integration/v3_grpc_inflight_test.go b/integration/v3_grpc_inflight_test.go index 4b7ccea02..8745cd540 100644 --- a/integration/v3_grpc_inflight_test.go +++ b/integration/v3_grpc_inflight_test.go @@ -20,8 +20,8 @@ import ( "testing" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/testutil" "google.golang.org/grpc" diff --git a/integration/v3_grpc_test.go b/integration/v3_grpc_test.go index b27f99572..2191a5d17 100644 --- a/integration/v3_grpc_test.go +++ b/integration/v3_grpc_test.go @@ -25,9 +25,9 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "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/pkg/testutil" "go.etcd.io/etcd/v3/pkg/transport" diff --git a/integration/v3_leadership_test.go b/integration/v3_leadership_test.go index 5b51dab86..ec79e2552 100644 --- a/integration/v3_leadership_test.go +++ b/integration/v3_leadership_test.go @@ -20,8 +20,8 @@ import ( "testing" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/testutil" ) diff --git a/integration/v3_lease_test.go b/integration/v3_lease_test.go index 4f88995ee..6a4c9c7d2 100644 --- a/integration/v3_lease_test.go +++ b/integration/v3_lease_test.go @@ -20,9 +20,9 @@ import ( "testing" "time" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - "go.etcd.io/etcd/v3/mvcc/mvccpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/testutil" "google.golang.org/grpc/codes" diff --git a/integration/v3_lock_test.go b/integration/v3_lock_test.go index bafaf9d03..bb85ccaab 100644 --- a/integration/v3_lock_test.go +++ b/integration/v3_lock_test.go @@ -21,10 +21,10 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/concurrency" recipe "go.etcd.io/etcd/v3/contrib/recipes" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/testutil" ) diff --git a/integration/v3_watch_restore_test.go b/integration/v3_watch_restore_test.go index f2f64fae9..a7dc0b504 100644 --- a/integration/v3_watch_restore_test.go +++ b/integration/v3_watch_restore_test.go @@ -20,7 +20,7 @@ import ( "testing" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" ) // MustFetchNotEmptyMetric attempts to fetch given 'metric' from 'member', diff --git a/integration/v3_watch_test.go b/integration/v3_watch_test.go index 38cc17dd9..444b79d47 100644 --- a/integration/v3_watch_test.go +++ b/integration/v3_watch_test.go @@ -24,9 +24,9 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/etcdserver/api/v3rpc" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/testutil" ) diff --git a/integration/v3election_grpc_test.go b/integration/v3election_grpc_test.go index 2e13a7c0d..60ede52e5 100644 --- a/integration/v3election_grpc_test.go +++ b/integration/v3election_grpc_test.go @@ -20,8 +20,8 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" epb "go.etcd.io/etcd/v3/etcdserver/api/v3election/v3electionpb" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" ) diff --git a/integration/v3lock_grpc_test.go b/integration/v3lock_grpc_test.go index 3ecb7e2a1..d4c6b03af 100644 --- a/integration/v3lock_grpc_test.go +++ b/integration/v3lock_grpc_test.go @@ -19,8 +19,8 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" lockpb "go.etcd.io/etcd/v3/etcdserver/api/v3lock/v3lockpb" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" ) diff --git a/lease/leasehttp/http.go b/lease/leasehttp/http.go index 27f042bb4..933b0b737 100644 --- a/lease/leasehttp/http.go +++ b/lease/leasehttp/http.go @@ -23,7 +23,7 @@ import ( "net/http" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/lease/leasepb" "go.etcd.io/etcd/v3/pkg/httputil" diff --git a/lease/leasepb/lease.proto b/lease/leasepb/lease.proto index 1169d9f10..5b40e3b17 100644 --- a/lease/leasepb/lease.proto +++ b/lease/leasepb/lease.proto @@ -2,7 +2,7 @@ syntax = "proto3"; package leasepb; import "gogoproto/gogo.proto"; -import "etcd/etcdserver/etcdserverpb/rpc.proto"; +import "etcd/api/etcdserverpb/rpc.proto"; option (gogoproto.marshaler_all) = true; option (gogoproto.sizer_all) = true; diff --git a/lease/lessor.go b/lease/lessor.go index 9a8ba5a81..f4f82d7ba 100644 --- a/lease/lessor.go +++ b/lease/lessor.go @@ -24,8 +24,8 @@ import ( "sync" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/cindex" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/lease/leasepb" "go.etcd.io/etcd/v3/mvcc/backend" "go.uber.org/zap" diff --git a/lease/lessor_test.go b/lease/lessor_test.go index 200171eb6..38f5b42d2 100644 --- a/lease/lessor_test.go +++ b/lease/lessor_test.go @@ -26,7 +26,7 @@ import ( "testing" "time" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/mvcc/backend" "go.uber.org/zap" ) diff --git a/mvcc/kv.go b/mvcc/kv.go index e26d8a637..0b8831610 100644 --- a/mvcc/kv.go +++ b/mvcc/kv.go @@ -15,9 +15,9 @@ package mvcc import ( + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/traceutil" ) diff --git a/mvcc/kv_test.go b/mvcc/kv_test.go index 25b45403e..03dd3b04d 100644 --- a/mvcc/kv_test.go +++ b/mvcc/kv_test.go @@ -21,9 +21,9 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/traceutil" diff --git a/mvcc/kvstore.go b/mvcc/kvstore.go index 6bafb270a..ac6a7735f 100644 --- a/mvcc/kvstore.go +++ b/mvcc/kvstore.go @@ -23,10 +23,10 @@ import ( "sync" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/etcdserver/cindex" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/schedule" "go.etcd.io/etcd/v3/pkg/traceutil" diff --git a/mvcc/kvstore_test.go b/mvcc/kvstore_test.go index d61f392be..81d519562 100644 --- a/mvcc/kvstore_test.go +++ b/mvcc/kvstore_test.go @@ -29,9 +29,9 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/schedule" "go.etcd.io/etcd/v3/pkg/testutil" "go.etcd.io/etcd/v3/pkg/traceutil" diff --git a/mvcc/kvstore_txn.go b/mvcc/kvstore_txn.go index 28e39d0c6..c1d3b7f57 100644 --- a/mvcc/kvstore_txn.go +++ b/mvcc/kvstore_txn.go @@ -15,9 +15,9 @@ package mvcc import ( + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/traceutil" "go.uber.org/zap" ) diff --git a/mvcc/util.go b/mvcc/util.go index 86d4805fe..b99d6c838 100644 --- a/mvcc/util.go +++ b/mvcc/util.go @@ -18,8 +18,8 @@ import ( "encoding/binary" "fmt" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) func UpdateConsistentIndex(be backend.Backend, index uint64) { diff --git a/mvcc/watchable_store.go b/mvcc/watchable_store.go index 130279f54..42f6b455a 100644 --- a/mvcc/watchable_store.go +++ b/mvcc/watchable_store.go @@ -18,10 +18,10 @@ import ( "sync" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/etcdserver/cindex" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/traceutil" "go.uber.org/zap" diff --git a/mvcc/watchable_store_test.go b/mvcc/watchable_store_test.go index 7f2a720d3..48047d2ca 100644 --- a/mvcc/watchable_store_test.go +++ b/mvcc/watchable_store_test.go @@ -23,10 +23,10 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/etcdserver/cindex" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.etcd.io/etcd/v3/pkg/traceutil" "go.uber.org/zap" ) diff --git a/mvcc/watchable_store_txn.go b/mvcc/watchable_store_txn.go index 7bf6cdb7f..bc3dc85c7 100644 --- a/mvcc/watchable_store_txn.go +++ b/mvcc/watchable_store_txn.go @@ -15,7 +15,7 @@ package mvcc import ( - "go.etcd.io/etcd/v3/mvcc/mvccpb" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/pkg/traceutil" ) diff --git a/mvcc/watcher.go b/mvcc/watcher.go index 2a3cb4ada..f48a9ef3b 100644 --- a/mvcc/watcher.go +++ b/mvcc/watcher.go @@ -19,7 +19,7 @@ import ( "errors" "sync" - "go.etcd.io/etcd/v3/mvcc/mvccpb" + "go.etcd.io/etcd/api/v3/mvccpb" ) // AutoWatchID is the watcher ID passed in WatchStream.Watch when no diff --git a/mvcc/watcher_group.go b/mvcc/watcher_group.go index 310220360..3bad9f281 100644 --- a/mvcc/watcher_group.go +++ b/mvcc/watcher_group.go @@ -18,7 +18,7 @@ import ( "fmt" "math" - "go.etcd.io/etcd/v3/mvcc/mvccpb" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/pkg/adt" ) diff --git a/mvcc/watcher_test.go b/mvcc/watcher_test.go index b4b426edb..ef53e6843 100644 --- a/mvcc/watcher_test.go +++ b/mvcc/watcher_test.go @@ -22,9 +22,9 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/lease" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" "go.uber.org/zap" ) diff --git a/pkg/mock/mockserver/mockserver.go b/pkg/mock/mockserver/mockserver.go index c68cb3c2c..21a8b013b 100644 --- a/pkg/mock/mockserver/mockserver.go +++ b/pkg/mock/mockserver/mockserver.go @@ -22,7 +22,7 @@ import ( "os" "sync" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" "google.golang.org/grpc/resolver" diff --git a/proxy/grpcproxy/adapter/auth_client_adapter.go b/proxy/grpcproxy/adapter/auth_client_adapter.go index ffdb3449f..140212b96 100644 --- a/proxy/grpcproxy/adapter/auth_client_adapter.go +++ b/proxy/grpcproxy/adapter/auth_client_adapter.go @@ -17,7 +17,7 @@ package adapter import ( "context" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" grpc "google.golang.org/grpc" ) diff --git a/proxy/grpcproxy/adapter/cluster_client_adapter.go b/proxy/grpcproxy/adapter/cluster_client_adapter.go index b5dab26ca..c1fff054d 100644 --- a/proxy/grpcproxy/adapter/cluster_client_adapter.go +++ b/proxy/grpcproxy/adapter/cluster_client_adapter.go @@ -17,7 +17,7 @@ package adapter import ( "context" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" ) diff --git a/proxy/grpcproxy/adapter/kv_client_adapter.go b/proxy/grpcproxy/adapter/kv_client_adapter.go index cc08e09d0..ddb6ada47 100644 --- a/proxy/grpcproxy/adapter/kv_client_adapter.go +++ b/proxy/grpcproxy/adapter/kv_client_adapter.go @@ -17,7 +17,7 @@ package adapter import ( "context" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" grpc "google.golang.org/grpc" ) diff --git a/proxy/grpcproxy/adapter/lease_client_adapter.go b/proxy/grpcproxy/adapter/lease_client_adapter.go index e2c9518c5..6640d1d39 100644 --- a/proxy/grpcproxy/adapter/lease_client_adapter.go +++ b/proxy/grpcproxy/adapter/lease_client_adapter.go @@ -17,7 +17,7 @@ package adapter import ( "context" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" ) diff --git a/proxy/grpcproxy/adapter/maintenance_client_adapter.go b/proxy/grpcproxy/adapter/maintenance_client_adapter.go index ca5b0c86c..6369a16d8 100644 --- a/proxy/grpcproxy/adapter/maintenance_client_adapter.go +++ b/proxy/grpcproxy/adapter/maintenance_client_adapter.go @@ -17,7 +17,7 @@ package adapter import ( "context" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" ) diff --git a/proxy/grpcproxy/adapter/watch_client_adapter.go b/proxy/grpcproxy/adapter/watch_client_adapter.go index 5bede2594..fbc09f6ff 100644 --- a/proxy/grpcproxy/adapter/watch_client_adapter.go +++ b/proxy/grpcproxy/adapter/watch_client_adapter.go @@ -18,7 +18,7 @@ import ( "context" "errors" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "google.golang.org/grpc" ) diff --git a/proxy/grpcproxy/auth.go b/proxy/grpcproxy/auth.go index f5c652ed7..be699d9ca 100644 --- a/proxy/grpcproxy/auth.go +++ b/proxy/grpcproxy/auth.go @@ -17,8 +17,8 @@ package grpcproxy import ( "context" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type AuthProxy struct { diff --git a/proxy/grpcproxy/cache/store.go b/proxy/grpcproxy/cache/store.go index bfbae2682..e85c691a3 100644 --- a/proxy/grpcproxy/cache/store.go +++ b/proxy/grpcproxy/cache/store.go @@ -21,8 +21,8 @@ import ( "sync" "github.com/golang/groupcache/lru" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/pkg/adt" ) diff --git a/proxy/grpcproxy/cluster.go b/proxy/grpcproxy/cluster.go index d91d0c847..5f3ab7658 100644 --- a/proxy/grpcproxy/cluster.go +++ b/proxy/grpcproxy/cluster.go @@ -21,10 +21,10 @@ import ( "os" "sync" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/clientv3/naming" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.uber.org/zap" "golang.org/x/time/rate" diff --git a/proxy/grpcproxy/cluster_test.go b/proxy/grpcproxy/cluster_test.go index 3d63180a9..530531cb4 100644 --- a/proxy/grpcproxy/cluster_test.go +++ b/proxy/grpcproxy/cluster_test.go @@ -20,8 +20,8 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "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" diff --git a/proxy/grpcproxy/health.go b/proxy/grpcproxy/health.go index 0e1f2f015..a546dadae 100644 --- a/proxy/grpcproxy/health.go +++ b/proxy/grpcproxy/health.go @@ -20,9 +20,9 @@ import ( "net/http" "time" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/etcdserver/api/etcdhttp" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" "go.uber.org/zap" ) diff --git a/proxy/grpcproxy/kv.go b/proxy/grpcproxy/kv.go index 7340326f5..6fbbedf00 100644 --- a/proxy/grpcproxy/kv.go +++ b/proxy/grpcproxy/kv.go @@ -17,8 +17,8 @@ package grpcproxy import ( "context" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/proxy/grpcproxy/cache" ) diff --git a/proxy/grpcproxy/kv_test.go b/proxy/grpcproxy/kv_test.go index 49ee69863..86a3106de 100644 --- a/proxy/grpcproxy/kv_test.go +++ b/proxy/grpcproxy/kv_test.go @@ -20,8 +20,8 @@ import ( "testing" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "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" diff --git a/proxy/grpcproxy/lease.go b/proxy/grpcproxy/lease.go index f10acf60a..5fb3cad4a 100644 --- a/proxy/grpcproxy/lease.go +++ b/proxy/grpcproxy/lease.go @@ -21,9 +21,9 @@ import ( "sync/atomic" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "google.golang.org/grpc" "google.golang.org/grpc/codes" diff --git a/proxy/grpcproxy/maintenance.go b/proxy/grpcproxy/maintenance.go index ca6c0b638..82cc53616 100644 --- a/proxy/grpcproxy/maintenance.go +++ b/proxy/grpcproxy/maintenance.go @@ -18,8 +18,8 @@ import ( "context" "io" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" ) type maintenanceProxy struct { diff --git a/proxy/grpcproxy/util.go b/proxy/grpcproxy/util.go index f33479c24..856ac5769 100644 --- a/proxy/grpcproxy/util.go +++ b/proxy/grpcproxy/util.go @@ -17,7 +17,7 @@ package grpcproxy import ( "context" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "google.golang.org/grpc" "google.golang.org/grpc/metadata" diff --git a/proxy/grpcproxy/watch.go b/proxy/grpcproxy/watch.go index 146b466a6..e884d9bd1 100644 --- a/proxy/grpcproxy/watch.go +++ b/proxy/grpcproxy/watch.go @@ -18,10 +18,10 @@ import ( "context" "sync" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" "go.etcd.io/etcd/v3/clientv3" "go.etcd.io/etcd/v3/etcdserver/api/v3rpc" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.uber.org/zap" "google.golang.org/grpc/codes" diff --git a/proxy/grpcproxy/watch_broadcast.go b/proxy/grpcproxy/watch_broadcast.go index fc62e6dd6..e7d901e53 100644 --- a/proxy/grpcproxy/watch_broadcast.go +++ b/proxy/grpcproxy/watch_broadcast.go @@ -19,8 +19,8 @@ import ( "sync" "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.uber.org/zap" ) diff --git a/proxy/grpcproxy/watcher.go b/proxy/grpcproxy/watcher.go index 879b8179e..881fe030c 100644 --- a/proxy/grpcproxy/watcher.go +++ b/proxy/grpcproxy/watcher.go @@ -17,10 +17,10 @@ package grpcproxy import ( "time" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/clientv3" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/mvcc" - "go.etcd.io/etcd/v3/mvcc/mvccpb" ) type watchRange struct { diff --git a/scripts/genproto.sh b/scripts/genproto.sh index d50d535a0..31462485c 100755 --- a/scripts/genproto.sh +++ b/scripts/genproto.sh @@ -10,13 +10,13 @@ if ! [[ "$0" =~ scripts/genproto.sh ]]; then exit 255 fi -if [[ $(protoc --version | cut -f2 -d' ') != "3.7.1" ]]; then - echo "could not find protoc 3.7.1, is it installed + in PATH?" +if [[ $(protoc --version | cut -f2 -d' ') != "3.12.3" ]]; then + echo "could not find protoc 3.12.3, is it installed + in PATH?" exit 255 fi # directories containing protos to be built -DIRS="./wal/walpb ./etcdserver/etcdserverpb ./etcdserver/api/snap/snappb ./raft/raftpb ./mvcc/mvccpb ./lease/leasepb ./auth/authpb ./etcdserver/api/v3lock/v3lockpb ./etcdserver/api/v3election/v3electionpb ./etcdserver/api/membership/membershippb" +DIRS="./wal/walpb ./api/etcdserverpb ./etcdserver/api/snap/snappb ./raft/raftpb ./api/mvccpb ./lease/leasepb ./api/authpb ./etcdserver/api/v3lock/v3lockpb ./etcdserver/api/v3election/v3electionpb ./api/membershippb" # disable go mod - this is for the go get/install invocations export GO111MODULE=off @@ -82,7 +82,9 @@ for dir in ${DIRS}; do # shellcheck disable=SC1117 sed -i.bak -E 's/import _ \"google\.golang\.org\/genproto\/googleapis\/api\/annotations\"//g' ./*.pb.go # shellcheck disable=SC1117 - sed -i.bak -E "s/go.etcd.io\/etcd\//go.etcd.io\/etcd\/v3\//" ./*.pb.go + sed -i.bak -E "s|go.etcd.io/etcd|go.etcd.io/etcd/v3|g" ./*.pb.go + # shellcheck disable=SC1117 + sed -i.bak -E "s|go.etcd.io/etcd/v3/api|go.etcd.io/etcd/api/v3|g" ./*.pb.go rm -f ./*.bak gofmt -s -w ./*.pb.go goimports -w ./*.pb.go @@ -91,8 +93,8 @@ done # remove old swagger files so it's obvious whether the files fail to generate rm -rf Documentation/dev-guide/apispec/swagger/*json -for pb in etcdserverpb/rpc api/v3lock/v3lockpb/v3lock api/v3election/v3electionpb/v3election; do - protobase="etcdserver/${pb}" +for pb in api/etcdserverpb/rpc etcdserver/api/v3lock/v3lockpb/v3lock etcdserver/api/v3election/v3electionpb/v3election; do + protobase="${pb}" protoc -I. \ -I"${GRPC_GATEWAY_ROOT}"/third_party/googleapis \ -I"${GOGOPROTO_PATH}" \ @@ -104,6 +106,10 @@ for pb in etcdserverpb/rpc api/v3lock/v3lockpb/v3lock api/v3election/v3electionp pkgpath=$(dirname "${protobase}") pkg=$(basename "${pkgpath}") gwfile="${protobase}.pb.gw.go" + + echo ">>> $gwfile" + head -n 30 "$gwfile" + sed -i.bak -E "s/package $pkg/package gw/g" ${gwfile} # shellcheck disable=SC1117 sed -i.bak -E "s/protoReq /&$pkg\./g" ${gwfile} @@ -113,15 +119,17 @@ for pb in etcdserverpb/rpc api/v3lock/v3lockpb/v3lock api/v3election/v3electionp sed -i.bak -E "s/New[A-Za-z]*Client/${pkg}.&/" ${gwfile} # darwin doesn't like newlines in sed... # shellcheck disable=SC1117 - sed -i.bak -E "s|import \(|& \"go.etcd.io/etcd/v3/${pkgpath}\"|" ${gwfile} + sed -i.bak -E "s|import \(|& \"go.etcd.io/etcd/${pkgpath}\"|" ${gwfile} # shellcheck disable=SC1117 - sed -i.bak -E "s/go.etcd.io\etcd\//go.etcd.io\/etcd\/v3/" ${gwfile} + sed -i.bak -E "s|go.etcd.io/etcd|go.etcd.io/etcd/v3|g" ${gwfile} + # shellcheck disable=SC1117 + sed -i.bak -E "s|go.etcd.io/etcd/v3/api|go.etcd.io/etcd/api/v3|g" ${gwfile} mkdir -p "${pkgpath}"/gw/ go fmt ${gwfile} mv ${gwfile} "${pkgpath}/gw/" - rm -f ./etcdserver/${pb}*.bak - swaggerName=$(basename ${pb}) - mv Documentation/dev-guide/apispec/swagger/etcdserver/${pb}.swagger.json \ + rm -f ./${protobase}*.bak + swaggerName=$(basename ${protobase}) + mv Documentation/dev-guide/apispec/swagger/${protobase}.swagger.json \ Documentation/dev-guide/apispec/swagger/"${swaggerName}".swagger.json done rm -rf Documentation/dev-guide/apispec/swagger/etcdserver/ @@ -151,13 +159,13 @@ if [ "$1" != "--skip-protodoc" ]; then echo "protodoc is updated" popd - protodoc --directories="etcdserver/etcdserverpb=service_message,mvcc/mvccpb=service_message,lease/leasepb=service_message,auth/authpb=service_message" \ + protodoc --directories="api/etcdserverpb=service_message,api/mvccpb=service_message,lease/leasepb=service_message,api/authpb=service_message" \ --title="etcd API Reference" \ --output="Documentation/dev-guide/api_reference_v3.md" \ - --message-only-from-this-file="etcdserver/etcdserverpb/rpc.proto" \ + --message-only-from-this-file="api/etcdserverpb/rpc.proto" \ --disclaimer="This is a generated documentation. Please read the proto files for more." - protodoc --directories="etcdserver/api/v3lock/v3lockpb=service_message,etcdserver/api/v3election/v3electionpb=service_message,mvcc/mvccpb=service_message" \ + protodoc --directories="etcdserver/api/v3lock/v3lockpb=service_message,etcdserver/api/v3election/v3electionpb=service_message,api/mvccpb=service_message" \ --title="etcd concurrency API Reference" \ --output="Documentation/dev-guide/api_concurrency_reference_v3.md" \ --disclaimer="This is a generated documentation. Please read the proto files for more." diff --git a/tests/e2e/ctl_v3_member_test.go b/tests/e2e/ctl_v3_member_test.go index b324160fd..a711d0d23 100644 --- a/tests/e2e/ctl_v3_member_test.go +++ b/tests/e2e/ctl_v3_member_test.go @@ -22,7 +22,7 @@ import ( "strings" "testing" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + "go.etcd.io/etcd/api/v3/etcdserverpb" ) func TestCtlV3MemberList(t *testing.T) { testCtl(t, memberListTest) } diff --git a/tests/e2e/ctl_v3_test.go b/tests/e2e/ctl_v3_test.go index fdcb6d234..532e2fddf 100644 --- a/tests/e2e/ctl_v3_test.go +++ b/tests/e2e/ctl_v3_test.go @@ -21,10 +21,10 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/pkg/fileutil" "go.etcd.io/etcd/v3/pkg/flags" "go.etcd.io/etcd/v3/pkg/testutil" - "go.etcd.io/etcd/v3/version" ) func TestCtlV3Version(t *testing.T) { testCtl(t, versionTest) } diff --git a/tests/e2e/etcd_corrupt_test.go b/tests/e2e/etcd_corrupt_test.go index f5aed150c..78f448662 100644 --- a/tests/e2e/etcd_corrupt_test.go +++ b/tests/e2e/etcd_corrupt_test.go @@ -23,8 +23,8 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/clientv3" - "go.etcd.io/etcd/v3/mvcc/mvccpb" bolt "go.etcd.io/bbolt" ) diff --git a/tests/e2e/etcd_release_upgrade_test.go b/tests/e2e/etcd_release_upgrade_test.go index 53ecde18e..3f666745f 100644 --- a/tests/e2e/etcd_release_upgrade_test.go +++ b/tests/e2e/etcd_release_upgrade_test.go @@ -21,9 +21,9 @@ import ( "testing" "time" + "go.etcd.io/etcd/api/v3/version" "go.etcd.io/etcd/v3/pkg/fileutil" "go.etcd.io/etcd/v3/pkg/testutil" - "go.etcd.io/etcd/v3/version" ) // TestReleaseUpgrade ensures that changes to master branch does not affect diff --git a/tests/e2e/metrics_test.go b/tests/e2e/metrics_test.go index e20b0f88d..6ae6d2fed 100644 --- a/tests/e2e/metrics_test.go +++ b/tests/e2e/metrics_test.go @@ -18,7 +18,7 @@ import ( "fmt" "testing" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" ) func TestV3MetricsSecure(t *testing.T) { diff --git a/tests/e2e/v3_cipher_suite_test.go b/tests/e2e/v3_cipher_suite_test.go index 9b0548878..16db27e47 100644 --- a/tests/e2e/v3_cipher_suite_test.go +++ b/tests/e2e/v3_cipher_suite_test.go @@ -20,7 +20,7 @@ import ( "fmt" "testing" - "go.etcd.io/etcd/v3/version" + "go.etcd.io/etcd/api/v3/version" ) func TestV3CurlCipherSuitesValid(t *testing.T) { testV3CurlCipherSuites(t, true) } diff --git a/tests/e2e/v3_curl_lease_test.go b/tests/e2e/v3_curl_lease_test.go index 91e59243c..5dea0726e 100644 --- a/tests/e2e/v3_curl_lease_test.go +++ b/tests/e2e/v3_curl_lease_test.go @@ -18,7 +18,7 @@ import ( "fmt" "testing" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" ) func TestV3CurlLeaseGrantNoTLS(t *testing.T) { diff --git a/tests/e2e/v3_curl_test.go b/tests/e2e/v3_curl_test.go index a19cb68d4..76e24204c 100644 --- a/tests/e2e/v3_curl_test.go +++ b/tests/e2e/v3_curl_test.go @@ -22,10 +22,10 @@ import ( "strconv" "testing" - "go.etcd.io/etcd/v3/auth/authpb" + "go.etcd.io/etcd/api/v3/authpb" + pb "go.etcd.io/etcd/api/v3/etcdserverpb" + "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" epb "go.etcd.io/etcd/v3/etcdserver/api/v3election/v3electionpb" - "go.etcd.io/etcd/v3/etcdserver/api/v3rpc/rpctypes" - pb "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/testutil" "github.com/grpc-ecosystem/grpc-gateway/runtime" diff --git a/tools/etcd-dump-db/backend.go b/tools/etcd-dump-db/backend.go index 44e304209..7e8f64d8f 100644 --- a/tools/etcd-dump-db/backend.go +++ b/tools/etcd-dump-db/backend.go @@ -17,13 +17,13 @@ package main import ( "encoding/binary" "fmt" - "go.etcd.io/etcd/v3/auth/authpb" + "go.etcd.io/etcd/api/v3/authpb" "path/filepath" + "go.etcd.io/etcd/api/v3/mvccpb" "go.etcd.io/etcd/v3/lease/leasepb" "go.etcd.io/etcd/v3/mvcc" "go.etcd.io/etcd/v3/mvcc/backend" - "go.etcd.io/etcd/v3/mvcc/mvccpb" bolt "go.etcd.io/bbolt" ) diff --git a/tools/etcd-dump-logs/etcd-dump-log_test.go b/tools/etcd-dump-logs/etcd-dump-log_test.go index f7c802341..99ebd4213 100644 --- a/tools/etcd-dump-logs/etcd-dump-log_test.go +++ b/tools/etcd-dump-logs/etcd-dump-log_test.go @@ -24,8 +24,8 @@ import ( "strings" "testing" - "go.etcd.io/etcd/v3/auth/authpb" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" + "go.etcd.io/etcd/api/v3/authpb" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/pkg/fileutil" "go.etcd.io/etcd/v3/pkg/pbutil" "go.etcd.io/etcd/v3/raft/raftpb" diff --git a/tools/etcd-dump-logs/main.go b/tools/etcd-dump-logs/main.go index c59b3c9e2..a75382439 100644 --- a/tools/etcd-dump-logs/main.go +++ b/tools/etcd-dump-logs/main.go @@ -28,8 +28,8 @@ import ( "strings" "time" + "go.etcd.io/etcd/api/v3/etcdserverpb" "go.etcd.io/etcd/v3/etcdserver/api/snap" - "go.etcd.io/etcd/v3/etcdserver/etcdserverpb" "go.etcd.io/etcd/v3/pkg/pbutil" "go.etcd.io/etcd/v3/pkg/types" "go.etcd.io/etcd/v3/raft/raftpb"