mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
Merge pull request #10044 from gyuho/rename-import-paths
*: rename import paths to "go.etcd.io/etcd"
This commit is contained in:
commit
e8b940f268
2
.github/ISSUE_TEMPLATE.md
vendored
2
.github/ISSUE_TEMPLATE.md
vendored
@ -1,2 +1,2 @@
|
|||||||
|
|
||||||
Please read https://github.com/coreos/etcd/blob/master/Documentation/reporting_bugs.md.
|
Please read https://github.com/etcd-io/etcd/blob/master/Documentation/reporting_bugs.md.
|
||||||
|
2
.github/PULL_REQUEST_TEMPLATE.md
vendored
2
.github/PULL_REQUEST_TEMPLATE.md
vendored
@ -1,2 +1,2 @@
|
|||||||
|
|
||||||
Please read https://github.com/coreos/etcd/blob/master/CONTRIBUTING.md#contribution-flow.
|
Please read https://github.com/etcd-io/etcd/blob/master/CONTRIBUTING.md#contribution-flow.
|
||||||
|
18
.travis.yml
18
.travis.yml
@ -1,5 +1,5 @@
|
|||||||
language: go
|
language: go
|
||||||
go_import_path: github.com/coreos/etcd
|
go_import_path: go.etcd.io/etcd
|
||||||
|
|
||||||
sudo: required
|
sudo: required
|
||||||
|
|
||||||
@ -74,37 +74,37 @@ script:
|
|||||||
case "${TARGET}" in
|
case "${TARGET}" in
|
||||||
linux-amd64-fmt)
|
linux-amd64-fmt)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "GOARCH=amd64 PASSES='fmt bom dep' ./test"
|
/bin/bash -c "GOARCH=amd64 PASSES='fmt bom dep' ./test"
|
||||||
;;
|
;;
|
||||||
linux-amd64-integration-1-cpu)
|
linux-amd64-integration-1-cpu)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "GOARCH=amd64 CPU=1 PASSES='integration' ./test"
|
/bin/bash -c "GOARCH=amd64 CPU=1 PASSES='integration' ./test"
|
||||||
;;
|
;;
|
||||||
linux-amd64-integration-2-cpu)
|
linux-amd64-integration-2-cpu)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "GOARCH=amd64 CPU=2 PASSES='integration' ./test"
|
/bin/bash -c "GOARCH=amd64 CPU=2 PASSES='integration' ./test"
|
||||||
;;
|
;;
|
||||||
linux-amd64-integration-4-cpu)
|
linux-amd64-integration-4-cpu)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "GOARCH=amd64 CPU=4 PASSES='integration' ./test"
|
/bin/bash -c "GOARCH=amd64 CPU=4 PASSES='integration' ./test"
|
||||||
;;
|
;;
|
||||||
linux-amd64-functional)
|
linux-amd64-functional)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "./build && GOARCH=amd64 PASSES='functional' ./test"
|
/bin/bash -c "./build && GOARCH=amd64 PASSES='functional' ./test"
|
||||||
;;
|
;;
|
||||||
linux-amd64-unit)
|
linux-amd64-unit)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "GOARCH=amd64 PASSES='unit' ./test"
|
/bin/bash -c "GOARCH=amd64 PASSES='unit' ./test"
|
||||||
;;
|
;;
|
||||||
all-build)
|
all-build)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "GOARCH=amd64 PASSES='build' ./test \
|
/bin/bash -c "GOARCH=amd64 PASSES='build' ./test \
|
||||||
&& GOARCH=386 PASSES='build' ./test \
|
&& GOARCH=386 PASSES='build' ./test \
|
||||||
&& GO_BUILD_FLAGS='-v' GOOS=darwin GOARCH=amd64 ./build \
|
&& GO_BUILD_FLAGS='-v' GOOS=darwin GOARCH=amd64 ./build \
|
||||||
@ -124,7 +124,7 @@ script:
|
|||||||
;;
|
;;
|
||||||
linux-386-unit)
|
linux-386-unit)
|
||||||
docker run --rm \
|
docker run --rm \
|
||||||
--volume=`pwd`:/go/src/github.com/coreos/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
--volume=`pwd`:/go/src/go.etcd.io/etcd gcr.io/etcd-development/etcd-test:go${TRAVIS_GO_VERSION} \
|
||||||
/bin/bash -c "GOARCH=386 PASSES='unit' ./test"
|
/bin/bash -c "GOARCH=386 PASSES='unit' ./test"
|
||||||
;;
|
;;
|
||||||
esac
|
esac
|
||||||
|
@ -26,7 +26,7 @@ To build a vendored `etcd` from the `master` branch via `go get`:
|
|||||||
# GOPATH should be set
|
# GOPATH should be set
|
||||||
$ echo $GOPATH
|
$ echo $GOPATH
|
||||||
/Users/example/go
|
/Users/example/go
|
||||||
$ go get -v github.com/coreos/etcd
|
$ go get -v go.etcd.io/etcd
|
||||||
```
|
```
|
||||||
|
|
||||||
## Test the installation
|
## Test the installation
|
||||||
|
@ -14,4 +14,4 @@ Hitoshi Mitake <h.mitake@gmail.com> (@mitake) pkg:*
|
|||||||
Joe Betz <jpbetz@google.com> (@jpbetz) pkg:*
|
Joe Betz <jpbetz@google.com> (@jpbetz) pkg:*
|
||||||
Xiang Li <xiangli.cs@gmail.com> (@xiang90) pkg:*
|
Xiang Li <xiangli.cs@gmail.com> (@xiang90) pkg:*
|
||||||
|
|
||||||
Ben Darnell <ben@cockroachlabs.com> (@bdarnell) pkg:github.com/coreos/etcd/raft
|
Ben Darnell <ben@cockroachlabs.com> (@bdarnell) pkg:go.etcd.io/etcd/raft
|
||||||
|
6
Makefile
6
Makefile
@ -102,7 +102,7 @@ compile-with-docker-test:
|
|||||||
$(info GO_VERSION: $(GO_VERSION))
|
$(info GO_VERSION: $(GO_VERSION))
|
||||||
docker run \
|
docker run \
|
||||||
--rm \
|
--rm \
|
||||||
--mount type=bind,source=`pwd`,destination=/go/src/github.com/coreos/etcd \
|
--mount type=bind,source=`pwd`,destination=/go/src/go.etcd.io/etcd \
|
||||||
gcr.io/etcd-development/etcd-test:go$(GO_VERSION) \
|
gcr.io/etcd-development/etcd-test:go$(GO_VERSION) \
|
||||||
/bin/bash -c "GO_BUILD_FLAGS=-v ./build && ./bin/etcd --version"
|
/bin/bash -c "GO_BUILD_FLAGS=-v ./build && ./bin/etcd --version"
|
||||||
|
|
||||||
@ -158,7 +158,7 @@ docker-test:
|
|||||||
docker run \
|
docker run \
|
||||||
--rm \
|
--rm \
|
||||||
$(TMP_DIR_MOUNT_FLAG) \
|
$(TMP_DIR_MOUNT_FLAG) \
|
||||||
--mount type=bind,source=`pwd`,destination=/go/src/github.com/coreos/etcd \
|
--mount type=bind,source=`pwd`,destination=/go/src/go.etcd.io/etcd \
|
||||||
gcr.io/etcd-development/etcd-test:go$(GO_VERSION) \
|
gcr.io/etcd-development/etcd-test:go$(GO_VERSION) \
|
||||||
/bin/bash -c "$(TEST_OPTS) ./test 2>&1 | tee test-$(TEST_SUFFIX).log"
|
/bin/bash -c "$(TEST_OPTS) ./test 2>&1 | tee test-$(TEST_SUFFIX).log"
|
||||||
! egrep "(--- FAIL:|DATA RACE|panic: test timed out|appears to have leaked)" -B50 -A10 test-$(TEST_SUFFIX).log
|
! egrep "(--- FAIL:|DATA RACE|panic: test timed out|appears to have leaked)" -B50 -A10 test-$(TEST_SUFFIX).log
|
||||||
@ -172,7 +172,7 @@ docker-test-coverage:
|
|||||||
docker run \
|
docker run \
|
||||||
--rm \
|
--rm \
|
||||||
$(TMP_DIR_MOUNT_FLAG) \
|
$(TMP_DIR_MOUNT_FLAG) \
|
||||||
--mount type=bind,source=`pwd`,destination=/go/src/github.com/coreos/etcd \
|
--mount type=bind,source=`pwd`,destination=/go/src/go.etcd.io/etcd \
|
||||||
gcr.io/etcd-development/etcd-test:go$(GO_VERSION) \
|
gcr.io/etcd-development/etcd-test:go$(GO_VERSION) \
|
||||||
/bin/bash -c "COVERDIR=covdir PASSES='build build_cov cov' ./test 2>&1 | tee docker-test-coverage-$(TEST_SUFFIX).log && /codecov -t 6040de41-c073-4d6f-bbf8-d89256ef31e1"
|
/bin/bash -c "COVERDIR=covdir PASSES='build build_cov cov' ./test 2>&1 | tee docker-test-coverage-$(TEST_SUFFIX).log && /codecov -t 6040de41-c073-4d6f-bbf8-d89256ef31e1"
|
||||||
! egrep "(--- FAIL:|DATA RACE|panic: test timed out|appears to have leaked)" -B50 -A10 docker-test-coverage-$(TEST_SUFFIX).log
|
! egrep "(--- FAIL:|DATA RACE|panic: test timed out|appears to have leaked)" -B50 -A10 docker-test-coverage-$(TEST_SUFFIX).log
|
||||||
|
@ -4,7 +4,7 @@
|
|||||||
|
|
||||||
This document defines a high level roadmap for etcd development.
|
This document defines a high level roadmap for etcd development.
|
||||||
|
|
||||||
The dates below should not be considered authoritative, but rather indicative of the projected timeline of the project. The [milestones defined in GitHub](https://github.com/coreos/etcd/milestones) represent the most up-to-date and issue-for-issue plans.
|
The dates below should not be considered authoritative, but rather indicative of the projected timeline of the project. The [milestones defined in GitHub](https://github.com/etcd-io/etcd/milestones) represent the most up-to-date and issue-for-issue plans.
|
||||||
|
|
||||||
etcd 3.3 is our current stable branch. The roadmap below outlines new features that will be added to etcd, and while subject to change, define what future stable will look like.
|
etcd 3.3 is our current stable branch. The roadmap below outlines new features that will be added to etcd, and while subject to change, define what future stable will look like.
|
||||||
|
|
||||||
|
@ -15,9 +15,9 @@
|
|||||||
package auth
|
package auth
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/coreos/etcd/auth/authpb"
|
"go.etcd.io/etcd/auth/authpb"
|
||||||
"github.com/coreos/etcd/mvcc/backend"
|
"go.etcd.io/etcd/mvcc/backend"
|
||||||
"github.com/coreos/etcd/pkg/adt"
|
"go.etcd.io/etcd/pkg/adt"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
)
|
)
|
||||||
|
@ -17,8 +17,8 @@ package auth
|
|||||||
import (
|
import (
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/auth/authpb"
|
"go.etcd.io/etcd/auth/authpb"
|
||||||
"github.com/coreos/etcd/pkg/adt"
|
"go.etcd.io/etcd/pkg/adt"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
)
|
)
|
||||||
|
@ -24,10 +24,10 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"sync/atomic"
|
"sync/atomic"
|
||||||
|
|
||||||
"github.com/coreos/etcd/auth/authpb"
|
"go.etcd.io/etcd/auth/authpb"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/mvcc/backend"
|
"go.etcd.io/etcd/mvcc/backend"
|
||||||
|
|
||||||
"github.com/coreos/pkg/capnslog"
|
"github.com/coreos/pkg/capnslog"
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
@ -48,7 +48,7 @@ var (
|
|||||||
authUsersBucketName = []byte("authUsers")
|
authUsersBucketName = []byte("authUsers")
|
||||||
authRolesBucketName = []byte("authRoles")
|
authRolesBucketName = []byte("authRoles")
|
||||||
|
|
||||||
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "auth")
|
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "auth")
|
||||||
|
|
||||||
ErrRootUserNotExist = errors.New("auth: root user does not exist")
|
ErrRootUserNotExist = errors.New("auth: root user does not exist")
|
||||||
ErrRootRoleNotExist = errors.New("auth: root user does not have root role")
|
ErrRootRoleNotExist = errors.New("auth: root user does not have root role")
|
||||||
|
@ -24,10 +24,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/auth/authpb"
|
"go.etcd.io/etcd/auth/authpb"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/mvcc/backend"
|
"go.etcd.io/etcd/mvcc/backend"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"golang.org/x/crypto/bcrypt"
|
"golang.org/x/crypto/bcrypt"
|
||||||
|
@ -26,15 +26,6 @@
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"project": "github.com/coreos/etcd",
|
|
||||||
"licenses": [
|
|
||||||
{
|
|
||||||
"type": "Apache License 2.0",
|
|
||||||
"confidence": 1
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"project": "github.com/coreos/go-semver/semver",
|
"project": "github.com/coreos/go-semver/semver",
|
||||||
"licenses": [
|
"licenses": [
|
||||||
@ -314,6 +305,15 @@
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"project": "go.etcd.io/etcd",
|
||||||
|
"licenses": [
|
||||||
|
{
|
||||||
|
"type": "Apache License 2.0",
|
||||||
|
"confidence": 1
|
||||||
|
}
|
||||||
|
]
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"project": "go.uber.org/atomic",
|
"project": "go.uber.org/atomic",
|
||||||
"licenses": [
|
"licenses": [
|
||||||
|
6
build
6
build
@ -1,7 +1,7 @@
|
|||||||
#!/usr/bin/env bash
|
#!/usr/bin/env bash
|
||||||
|
|
||||||
# set some environment variables
|
# set some environment variables
|
||||||
ORG_PATH="github.com/coreos"
|
ORG_PATH="go.etcd.io"
|
||||||
REPO_PATH="${ORG_PATH}/etcd"
|
REPO_PATH="${ORG_PATH}/etcd"
|
||||||
|
|
||||||
GIT_SHA=$(git rev-parse --short HEAD || echo "GitNotFound")
|
GIT_SHA=$(git rev-parse --short HEAD || echo "GitNotFound")
|
||||||
@ -34,10 +34,10 @@ etcd_setup_gopath() {
|
|||||||
GOPATH=":$GOPATH"
|
GOPATH=":$GOPATH"
|
||||||
fi
|
fi
|
||||||
rm -rf "${etcdGOPATH:?}/"
|
rm -rf "${etcdGOPATH:?}/"
|
||||||
mkdir -p "${etcdGOPATH}/vendor" "${etcdGOPATH}/etcd_src/src/github.com/coreos"
|
mkdir -p "${etcdGOPATH}/vendor" "${etcdGOPATH}/etcd_src/src/go.etcd.io"
|
||||||
export GOPATH=${etcdGOPATH}/vendor:${etcdGOPATH}/etcd_src${GOPATH}
|
export GOPATH=${etcdGOPATH}/vendor:${etcdGOPATH}/etcd_src${GOPATH}
|
||||||
ln -s "${CDIR}/vendor" "${etcdGOPATH}/vendor/src"
|
ln -s "${CDIR}/vendor" "${etcdGOPATH}/vendor/src"
|
||||||
ln -s "${CDIR}" "${etcdGOPATH}/etcd_src/src/github.com/coreos/etcd"
|
ln -s "${CDIR}" "${etcdGOPATH}/etcd_src/src/go.etcd.io/etcd"
|
||||||
}
|
}
|
||||||
|
|
||||||
toggle_failpoints_default() {
|
toggle_failpoints_default() {
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
$ORG_PATH="github.com/coreos"
|
$ORG_PATH="go.etcd.io"
|
||||||
$REPO_PATH="$ORG_PATH/etcd"
|
$REPO_PATH="$ORG_PATH/etcd"
|
||||||
$PWD = $((Get-Item -Path ".\" -Verbose).FullName)
|
$PWD = $((Get-Item -Path ".\" -Verbose).FullName)
|
||||||
$FSROOT = $((Get-Location).Drive.Name+":")
|
$FSROOT = $((Get-Location).Drive.Name+":")
|
||||||
|
@ -29,7 +29,7 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/version"
|
"go.etcd.io/etcd/version"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -29,8 +29,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"github.com/coreos/etcd/version"
|
"go.etcd.io/etcd/version"
|
||||||
)
|
)
|
||||||
|
|
||||||
type actionAssertingHTTPClient struct {
|
type actionAssertingHTTPClient struct {
|
||||||
|
@ -15,7 +15,7 @@
|
|||||||
package client
|
package client
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/coreos/etcd/pkg/srv"
|
"go.etcd.io/etcd/pkg/srv"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Discoverer is an interface that wraps the Discover method.
|
// Discoverer is an interface that wraps the Discover method.
|
||||||
|
@ -21,7 +21,7 @@ Create a Config and exchange it for a Client:
|
|||||||
"net/http"
|
"net/http"
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
"github.com/coreos/etcd/client"
|
"go.etcd.io/etcd/client"
|
||||||
)
|
)
|
||||||
|
|
||||||
cfg := client.Config{
|
cfg := client.Config{
|
||||||
|
@ -20,7 +20,7 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"sort"
|
"sort"
|
||||||
|
|
||||||
"github.com/coreos/etcd/client"
|
"go.etcd.io/etcd/client"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleKeysAPI_directory() {
|
func ExampleKeysAPI_directory() {
|
||||||
|
@ -24,9 +24,9 @@ import (
|
|||||||
"sync/atomic"
|
"sync/atomic"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/client"
|
"go.etcd.io/etcd/client"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TestV2NoRetryEOF tests destructive api calls won't retry on a disconnection.
|
// TestV2NoRetryEOF tests destructive api calls won't retry on a disconnection.
|
||||||
|
@ -8,7 +8,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestMain(m *testing.M) {
|
func TestMain(m *testing.M) {
|
||||||
|
@ -27,8 +27,8 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/pkg/pathutil"
|
|
||||||
"github.com/ugorji/go/codec"
|
"github.com/ugorji/go/codec"
|
||||||
|
"go.etcd.io/etcd/pkg/pathutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
@ -23,9 +23,9 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"github.com/coreos/etcd/pkg/transport"
|
"go.etcd.io/etcd/pkg/transport"
|
||||||
)
|
)
|
||||||
|
|
||||||
var exampleEndpoints []string
|
var exampleEndpoints []string
|
||||||
|
@ -23,7 +23,7 @@ import (
|
|||||||
"net/url"
|
"net/url"
|
||||||
"path"
|
"path"
|
||||||
|
|
||||||
"github.com/coreos/etcd/pkg/types"
|
"go.etcd.io/etcd/pkg/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -23,7 +23,7 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/pkg/types"
|
"go.etcd.io/etcd/pkg/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestMembersAPIActionList(t *testing.T) {
|
func TestMembersAPIActionList(t *testing.T) {
|
||||||
|
@ -19,8 +19,8 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/coreos/etcd/auth/authpb"
|
"go.etcd.io/etcd/auth/authpb"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -20,7 +20,7 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3/balancer/picker"
|
"go.etcd.io/etcd/clientv3/balancer/picker"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"google.golang.org/grpc/balancer"
|
"google.golang.org/grpc/balancer"
|
||||||
|
@ -21,10 +21,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3/balancer/picker"
|
"go.etcd.io/etcd/clientv3/balancer/picker"
|
||||||
"github.com/coreos/etcd/clientv3/balancer/resolver/endpoint"
|
"go.etcd.io/etcd/clientv3/balancer/resolver/endpoint"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/pkg/mock/mockserver"
|
"go.etcd.io/etcd/pkg/mock/mockserver"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
|
@ -15,7 +15,7 @@
|
|||||||
package balancer
|
package balancer
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/coreos/etcd/clientv3/balancer/picker"
|
"go.etcd.io/etcd/clientv3/balancer/picker"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
)
|
)
|
||||||
|
@ -22,8 +22,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
@ -191,7 +191,7 @@ func TestOldHealthBalancerGraylist(t *testing.T) {
|
|||||||
|
|
||||||
// TestBalancerDoNotBlockOnClose ensures that balancer and grpc don't deadlock each other
|
// TestBalancerDoNotBlockOnClose ensures that balancer and grpc don't deadlock each other
|
||||||
// due to rapid open/close conn. The deadlock causes balancer.Close() to block forever.
|
// due to rapid open/close conn. The deadlock causes balancer.Close() to block forever.
|
||||||
// See issue: https://github.com/coreos/etcd/issues/7283 for more detail.
|
// See issue: https://go.etcd.io/etcd/issues/7283 for more detail.
|
||||||
func TestOldHealthBalancerDoNotBlockOnClose(t *testing.T) {
|
func TestOldHealthBalancerDoNotBlockOnClose(t *testing.T) {
|
||||||
defer testutil.AfterTest(t)
|
defer testutil.AfterTest(t)
|
||||||
|
|
||||||
|
@ -27,11 +27,11 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3/balancer"
|
|
||||||
"github.com/coreos/etcd/clientv3/balancer/picker"
|
|
||||||
"github.com/coreos/etcd/clientv3/balancer/resolver/endpoint"
|
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
|
||||||
"github.com/grpc-ecosystem/go-grpc-middleware/util/backoffutils"
|
"github.com/grpc-ecosystem/go-grpc-middleware/util/backoffutils"
|
||||||
|
"go.etcd.io/etcd/clientv3/balancer"
|
||||||
|
"go.etcd.io/etcd/clientv3/balancer/picker"
|
||||||
|
"go.etcd.io/etcd/clientv3/balancer/resolver/endpoint"
|
||||||
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
|
@ -21,8 +21,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
@ -18,8 +18,8 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/clientv3util"
|
"go.etcd.io/etcd/clientv3/clientv3util"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleKeyMissing() {
|
func ExampleKeyMissing() {
|
||||||
|
@ -16,7 +16,7 @@
|
|||||||
package clientv3util
|
package clientv3util
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
// KeyExists returns a comparison operation that evaluates to true iff the given
|
// KeyExists returns a comparison operation that evaluates to true iff the given
|
||||||
|
@ -17,8 +17,8 @@ package clientv3
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/pkg/types"
|
"go.etcd.io/etcd/pkg/types"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
@ -15,7 +15,7 @@
|
|||||||
package clientv3
|
package clientv3
|
||||||
|
|
||||||
import (
|
import (
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
// CompactOp represents a compact operation.
|
// CompactOp represents a compact operation.
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/etcdserver/etcdserverpb"
|
"go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestCompactOp(t *testing.T) {
|
func TestCompactOp(t *testing.T) {
|
||||||
|
@ -15,7 +15,7 @@
|
|||||||
package clientv3
|
package clientv3
|
||||||
|
|
||||||
import (
|
import (
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
type CompareTarget int
|
type CompareTarget int
|
||||||
|
@ -19,9 +19,9 @@ import (
|
|||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/mvcc/mvccpb"
|
"go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -21,8 +21,8 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/concurrency"
|
"go.etcd.io/etcd/clientv3/concurrency"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleElection_Campaign() {
|
func ExampleElection_Campaign() {
|
||||||
|
@ -19,8 +19,8 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/concurrency"
|
"go.etcd.io/etcd/clientv3/concurrency"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleMutex_Lock() {
|
func ExampleMutex_Lock() {
|
||||||
|
@ -21,8 +21,8 @@ import (
|
|||||||
"math/rand"
|
"math/rand"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/concurrency"
|
"go.etcd.io/etcd/clientv3/concurrency"
|
||||||
)
|
)
|
||||||
|
|
||||||
// ExampleSTM_apply shows how to use STM with a transactional
|
// ExampleSTM_apply shows how to use STM with a transactional
|
||||||
|
@ -18,9 +18,9 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/mvcc/mvccpb"
|
"go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
func waitDelete(ctx context.Context, client *v3.Client, key string, rev int64) error {
|
func waitDelete(ctx context.Context, client *v3.Client, key string, rev int64) error {
|
||||||
|
@ -20,8 +20,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
var endpoints []string
|
var endpoints []string
|
||||||
|
@ -19,8 +19,8 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Mutex implements the sync Locker interface with etcd
|
// Mutex implements the sync Locker interface with etcd
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
const defaultSessionTTL = 60
|
const defaultSessionTTL = 60
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"math"
|
"math"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
// STM is an interface for software transactional memory.
|
// STM is an interface for software transactional memory.
|
||||||
|
@ -61,7 +61,7 @@
|
|||||||
//
|
//
|
||||||
// 1. context error: canceled or deadline exceeded.
|
// 1. context error: canceled or deadline exceeded.
|
||||||
// 2. gRPC status error: e.g. when clock drifts in server-side before client's context deadline exceeded.
|
// 2. gRPC status error: e.g. when clock drifts in server-side before client's context deadline exceeded.
|
||||||
// 3. gRPC error: see https://github.com/coreos/etcd/blob/master/etcdserver/api/v3rpc/rpctypes/error.go
|
// 3. gRPC error: see https://go.etcd.io/etcd/blob/master/etcdserver/api/v3rpc/rpctypes/error.go
|
||||||
//
|
//
|
||||||
// Here is the example code to handle client errors:
|
// Here is the example code to handle client errors:
|
||||||
//
|
//
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleAuth() {
|
func ExampleAuth() {
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleCluster_memberList() {
|
func ExampleCluster_memberList() {
|
||||||
|
@ -19,8 +19,8 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleKV_put() {
|
func ExampleKV_put() {
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleLease_grant() {
|
func ExampleLease_grant() {
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleMaintenance_status() {
|
func ExampleMaintenance_status() {
|
||||||
|
@ -23,7 +23,7 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
|
|
||||||
grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
|
grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
|
||||||
"github.com/prometheus/client_golang/prometheus/promhttp"
|
"github.com/prometheus/client_golang/prometheus/promhttp"
|
||||||
|
@ -20,8 +20,8 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/pkg/transport"
|
"go.etcd.io/etcd/pkg/transport"
|
||||||
|
|
||||||
"google.golang.org/grpc/grpclog"
|
"google.golang.org/grpc/grpclog"
|
||||||
)
|
)
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
func ExampleWatcher_watch() {
|
func ExampleWatcher_watch() {
|
||||||
|
@ -21,10 +21,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -19,9 +19,9 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"github.com/coreos/etcd/pkg/types"
|
"go.etcd.io/etcd/pkg/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestMemberList(t *testing.T) {
|
func TestMemberList(t *testing.T) {
|
||||||
|
@ -21,11 +21,11 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"github.com/coreos/etcd/pkg/transport"
|
"go.etcd.io/etcd/pkg/transport"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -23,11 +23,11 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/mvcc/mvccpb"
|
"go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
"google.golang.org/grpc/codes"
|
"google.golang.org/grpc/codes"
|
||||||
|
@ -22,11 +22,11 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/concurrency"
|
"go.etcd.io/etcd/clientv3/concurrency"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
@ -23,11 +23,11 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/concurrency"
|
"go.etcd.io/etcd/clientv3/concurrency"
|
||||||
"github.com/coreos/etcd/clientv3/leasing"
|
"go.etcd.io/etcd/clientv3/leasing"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestLeasingPutGet(t *testing.T) {
|
func TestLeasingPutGet(t *testing.T) {
|
||||||
|
@ -17,7 +17,7 @@ package integration
|
|||||||
import (
|
import (
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
|
|
||||||
"google.golang.org/grpc/grpclog"
|
"google.golang.org/grpc/grpclog"
|
||||||
)
|
)
|
||||||
|
@ -8,7 +8,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestMain(m *testing.M) {
|
func TestMain(m *testing.M) {
|
||||||
|
@ -27,13 +27,13 @@ import (
|
|||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/lease"
|
"go.etcd.io/etcd/lease"
|
||||||
"github.com/coreos/etcd/mvcc"
|
"go.etcd.io/etcd/mvcc"
|
||||||
"github.com/coreos/etcd/mvcc/backend"
|
"go.etcd.io/etcd/mvcc/backend"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestMaintenanceHashKV(t *testing.T) {
|
func TestMaintenanceHashKV(t *testing.T) {
|
||||||
|
@ -25,10 +25,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"github.com/coreos/etcd/pkg/transport"
|
"go.etcd.io/etcd/pkg/transport"
|
||||||
|
|
||||||
grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
|
grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
|
||||||
"github.com/prometheus/client_golang/prometheus/promhttp"
|
"github.com/prometheus/client_golang/prometheus/promhttp"
|
||||||
|
@ -22,10 +22,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3/mirror"
|
"go.etcd.io/etcd/clientv3/mirror"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/mvcc/mvccpb"
|
"go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestMirrorSync(t *testing.T) {
|
func TestMirrorSync(t *testing.T) {
|
||||||
|
@ -19,11 +19,11 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/namespace"
|
"go.etcd.io/etcd/clientv3/namespace"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/mvcc/mvccpb"
|
"go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestNamespacePutGet(t *testing.T) {
|
func TestNamespacePutGet(t *testing.T) {
|
||||||
|
@ -22,10 +22,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -18,9 +18,9 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestRoleError(t *testing.T) {
|
func TestRoleError(t *testing.T) {
|
||||||
|
@ -21,10 +21,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
|
|
||||||
"google.golang.org/grpc/codes"
|
"google.golang.org/grpc/codes"
|
||||||
"google.golang.org/grpc/status"
|
"google.golang.org/grpc/status"
|
||||||
|
@ -20,11 +20,11 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/embed"
|
"go.etcd.io/etcd/embed"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestTxnError(t *testing.T) {
|
func TestTxnError(t *testing.T) {
|
||||||
|
@ -19,10 +19,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
// mustWaitPinReady waits up to 3-second until connection is up (pin endpoint).
|
// mustWaitPinReady waits up to 3-second until connection is up (pin endpoint).
|
||||||
|
@ -23,9 +23,9 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TestWatchFragmentDisable ensures that large watch
|
// TestWatchFragmentDisable ensures that large watch
|
||||||
|
@ -23,12 +23,12 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
mvccpb "github.com/coreos/etcd/mvcc/mvccpb"
|
mvccpb "go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
|
|
||||||
"google.golang.org/grpc/metadata"
|
"google.golang.org/grpc/metadata"
|
||||||
)
|
)
|
||||||
|
@ -17,7 +17,7 @@ package clientv3
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
@ -19,8 +19,8 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
@ -133,7 +133,7 @@ type Lease interface {
|
|||||||
// is returned. Otherwise, it retries.
|
// is returned. Otherwise, it retries.
|
||||||
//
|
//
|
||||||
// TODO(v4.0): post errors to last keep alive message before closing
|
// TODO(v4.0): post errors to last keep alive message before closing
|
||||||
// (see https://github.com/coreos/etcd/pull/7866)
|
// (see https://go.etcd.io/etcd/pull/7866)
|
||||||
KeepAlive(ctx context.Context, id LeaseID) (<-chan *LeaseKeepAliveResponse, error)
|
KeepAlive(ctx context.Context, id LeaseID) (<-chan *LeaseKeepAliveResponse, error)
|
||||||
|
|
||||||
// KeepAliveOnce renews the lease once. The response corresponds to the
|
// KeepAliveOnce renews the lease once. The response corresponds to the
|
||||||
|
@ -20,9 +20,9 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
v3pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
v3pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/mvcc/mvccpb"
|
"go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
const revokeBackoff = 2 * time.Second
|
const revokeBackoff = 2 * time.Second
|
||||||
|
@ -20,11 +20,11 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/clientv3/concurrency"
|
"go.etcd.io/etcd/clientv3/concurrency"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/mvcc/mvccpb"
|
"go.etcd.io/etcd/mvcc/mvccpb"
|
||||||
|
|
||||||
"google.golang.org/grpc/codes"
|
"google.golang.org/grpc/codes"
|
||||||
"google.golang.org/grpc/status"
|
"google.golang.org/grpc/status"
|
||||||
|
@ -18,8 +18,8 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
v3pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
v3pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
type txnLeasing struct {
|
type txnLeasing struct {
|
||||||
|
@ -17,8 +17,8 @@ package leasing
|
|||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
|
|
||||||
v3 "github.com/coreos/etcd/clientv3"
|
v3 "go.etcd.io/etcd/clientv3"
|
||||||
v3pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
v3pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
func compareInt64(a, b int64) int {
|
func compareInt64(a, b int64) int {
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
"github.com/coreos/etcd/pkg/logutil"
|
"go.etcd.io/etcd/pkg/logutil"
|
||||||
|
|
||||||
"google.golang.org/grpc/grpclog"
|
"google.golang.org/grpc/grpclog"
|
||||||
)
|
)
|
||||||
|
@ -22,8 +22,8 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TestMain sets up an etcd cluster if running the examples.
|
// TestMain sets up an etcd cluster if running the examples.
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
|
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
)
|
)
|
||||||
|
@ -18,7 +18,7 @@ package mirror
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
@ -17,9 +17,9 @@ package namespace
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
type kvPrefix struct {
|
type kvPrefix struct {
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"bytes"
|
"bytes"
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
type leasePrefix struct {
|
type leasePrefix struct {
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
type watcherPrefix struct {
|
type watcherPrefix struct {
|
||||||
|
@ -17,8 +17,8 @@
|
|||||||
// To use, first import the packages:
|
// To use, first import the packages:
|
||||||
//
|
//
|
||||||
// import (
|
// import (
|
||||||
// "github.com/coreos/etcd/clientv3"
|
// "go.etcd.io/etcd/clientv3"
|
||||||
// etcdnaming "github.com/coreos/etcd/clientv3/naming"
|
// etcdnaming "go.etcd.io/etcd/clientv3/naming"
|
||||||
//
|
//
|
||||||
// "google.golang.org/grpc"
|
// "google.golang.org/grpc"
|
||||||
// "google.golang.org/grpc/naming"
|
// "google.golang.org/grpc/naming"
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
etcd "github.com/coreos/etcd/clientv3"
|
etcd "go.etcd.io/etcd/clientv3"
|
||||||
|
|
||||||
"google.golang.org/grpc/codes"
|
"google.golang.org/grpc/codes"
|
||||||
"google.golang.org/grpc/naming"
|
"google.golang.org/grpc/naming"
|
||||||
|
@ -20,9 +20,9 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
etcd "github.com/coreos/etcd/clientv3"
|
etcd "go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
|
|
||||||
"google.golang.org/grpc/naming"
|
"google.golang.org/grpc/naming"
|
||||||
)
|
)
|
||||||
|
@ -14,7 +14,7 @@
|
|||||||
|
|
||||||
package clientv3
|
package clientv3
|
||||||
|
|
||||||
import pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
import pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
|
|
||||||
type opType int
|
type opType int
|
||||||
|
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TestOpWithSort tests if WithSort(ASCEND, KEY) and WithLimit are specified,
|
// TestOpWithSort tests if WithSort(ASCEND, KEY) and WithLimit are specified,
|
||||||
|
@ -18,7 +18,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
// kvOrdering ensures that serialized requests do not return
|
// kvOrdering ensures that serialized requests do not return
|
||||||
|
@ -22,10 +22,10 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestDetectKvOrderViolation(t *testing.T) {
|
func TestDetectKvOrderViolation(t *testing.T) {
|
||||||
|
@ -17,7 +17,7 @@ package ordering
|
|||||||
import (
|
import (
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
|
|
||||||
"google.golang.org/grpc/grpclog"
|
"google.golang.org/grpc/grpclog"
|
||||||
)
|
)
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
)
|
)
|
||||||
|
|
||||||
type OrderViolationFunc func(op clientv3.Op, resp clientv3.OpResponse, prevRev int64) error
|
type OrderViolationFunc func(op clientv3.Op, resp clientv3.OpResponse, prevRev int64) error
|
||||||
|
@ -19,9 +19,9 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/coreos/etcd/clientv3"
|
"go.etcd.io/etcd/clientv3"
|
||||||
"github.com/coreos/etcd/integration"
|
"go.etcd.io/etcd/integration"
|
||||||
"github.com/coreos/etcd/pkg/testutil"
|
"go.etcd.io/etcd/pkg/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestEndpointSwitchResolvesViolation(t *testing.T) {
|
func TestEndpointSwitchResolvesViolation(t *testing.T) {
|
||||||
|
@ -17,8 +17,8 @@ package clientv3
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
|
||||||
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
|
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
|
||||||
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
"google.golang.org/grpc/codes"
|
"google.golang.org/grpc/codes"
|
||||||
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
x
Reference in New Issue
Block a user