*: Update references to code moved to the api/ dir.

Follow up to file-moves done in the previous commit.

The commit contains purely mechanical consequences of execution (apart
of scripts/genproto.sh):

  % find ./ -name '*.go'  | xargs sed --follow-symlinks -i 's|v3/etcdserver/api/v3rpc/rpctypes|v3/api/v3rpc/rpctypes|g'
  % find ./ -name '*.go'  | xargs sed --follow-symlinks -i 's|v3/version|v3/api/version|g'
  % find ./ -name '*.go'  | xargs sed --follow-symlinks -i 's|v3/mvcc/mvccpb|v3/api/mvccpb|g'
  % find ./ -name '*.go'  | xargs sed --follow-symlinks -i 's|v3/etcdserver/etcdserverpb|v3/api/etcdserverpb|g'
  % find ./ -name '*.go'  | xargs sed --follow-symlinks -i 's|v3/etcdserver/api/membership/membershippb|v3/api/membershippb|g'
  % find ./ -name '*.go'  | xargs sed --follow-symlinks -i 's|v3/auth/authpb|v3/api/authpb|g'

  % find ./ -name '*.proto' -o -name '*.md'  | xargs -L 1 sed --follow-symlinks -i 's|/mvcc/mvccpb/kv.proto|/api/mvccpb/kv.proto|g'
  % find ./ -name '*.proto' -o -name '*.md'  | xargs -L 1 sed --follow-symlinks -i 's|/auth/authpb/auth.proto|/api/authpb/auth.proto|g'
  % find ./ -name '*.proto' -o -name '*.md'  | xargs -L 1 sed --follow-symlinks -i 's|/etcdserver/api/membership/membershippb/membership.proto|/api/membershippb/membership.proto|g'

  I also modified manually paths in scripts/genproto.sh.

  % go fmt ./...
release-3.5
Piotr Tabor 2020-10-05 17:21:03 +02:00
parent 2edb08642c
commit 28f2b07623
211 changed files with 306 additions and 291 deletions

View File

@ -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

View File

@ -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

View File

@ -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"

View File

@ -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;

View File

@ -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

View File

@ -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";

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

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

View File

@ -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 {

View File

@ -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"
)

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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.

View File

@ -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) {

View File

@ -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

View File

@ -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 (

View File

@ -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 {

View File

@ -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.

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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() {

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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"
)

View File

@ -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"

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"

View File

@ -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"
)

View File

@ -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"

View File

@ -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"
)

View File

@ -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"

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"

View File

@ -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

View File

@ -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"

View File

@ -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 {

View File

@ -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 {

View File

@ -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"
)

View File

@ -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 {

View File

@ -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

View File

@ -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,

View File

@ -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 {

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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"
)

View File

@ -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"

View File

@ -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) {

View File

@ -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

View File

@ -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 (

View File

@ -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

View File

@ -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.

View File

@ -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.

View File

@ -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 {

View File

@ -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.

View File

@ -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"

View File

@ -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"

View File

@ -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

View File

@ -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"

View File

@ -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"
)

View File

@ -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".

View File

@ -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"

View File

@ -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"
)

View File

@ -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"

View File

@ -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"
)

View File

@ -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 }

View File

@ -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 }

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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) {

View File

@ -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"

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"

View File

@ -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"
)

View File

@ -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"
)

View File

@ -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"

View File

@ -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"

View File

@ -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"

View File

@ -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"
)

View File

@ -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"

View File

@ -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"
)

Some files were not shown because too many files have changed in this diff Show More