Goimports: Apply automated fixing to test files as well.

Signed-off-by: Piotr Tabor <ptab@google.com>
dependabot/go_modules/go.uber.org/atomic-1.10.0
Piotr Tabor 2022-12-29 12:58:55 +01:00
parent 6f899a7b40
commit 9abc895122
109 changed files with 201 additions and 98 deletions

View File

@ -26,11 +26,12 @@ import (
"github.com/stretchr/testify/assert"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
"google.golang.org/grpc"
)

View File

@ -19,6 +19,7 @@ import (
"testing"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
)

View File

@ -19,9 +19,10 @@ import (
"reflect"
"testing"
"google.golang.org/grpc/metadata"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
"go.etcd.io/etcd/api/v3/version"
"google.golang.org/grpc/metadata"
)
func TestMetadataWithRequireLeader(t *testing.T) {

View File

@ -31,10 +31,10 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/client/pkg/v3/transport"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
"go.uber.org/zap"
"go.etcd.io/etcd/client/pkg/v3/transport"
)
func TestServer_Unix_Insecure(t *testing.T) { testServer(t, "unix", false, false) }

View File

@ -33,8 +33,9 @@ function bash_ws_fix {
function go_imports_fix {
GOFILES=$(run ${GO_CMD} list --f "{{with \$d:=.}}{{range .GoFiles}}{{\$d.Dir}}/{{.}}{{\"\n\"}}{{end}}{{end}}" ./...)
TESTGOFILES=$(run ${GO_CMD} list --f "{{with \$d:=.}}{{range .TestGoFiles}}{{\$d.Dir}}/{{.}}{{\"\n\"}}{{end}}{{end}}" ./...)
cd "${ROOTDIR}/tools/mod"
echo "${GOFILES}" | grep -v '.gw.go' | grep -v '.pb.go' | xargs -n 100 go run golang.org/x/tools/cmd/goimports -w -local go.etcd.io
echo "${GOFILES}" "${TESTGOFILES}" | grep -v '.gw.go' | grep -v '.pb.go' | xargs -n 100 go run golang.org/x/tools/cmd/goimports -w -local go.etcd.io
}
log_callout -e "\\nFixing etcd code for you...\n"

View File

@ -17,9 +17,10 @@ package auth
import (
"testing"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/authpb"
"go.etcd.io/etcd/pkg/v3/adt"
"go.uber.org/zap/zaptest"
)
func TestRangePermission(t *testing.T) {

View File

@ -26,12 +26,13 @@ import (
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"golang.org/x/crypto/bcrypt"
"google.golang.org/grpc/metadata"
"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/pkg/v3/adt"
"golang.org/x/crypto/bcrypt"
"google.golang.org/grpc/metadata"
)
func dummyIndexWaiter(index uint64) <-chan struct{} {

View File

@ -18,8 +18,9 @@ import (
"net/url"
"testing"
"go.etcd.io/etcd/client/pkg/v3/types"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/types"
)
func mustNewURLs(t *testing.T, urls []string) []url.URL {

View File

@ -24,6 +24,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/client/pkg/v3/srv"
"go.etcd.io/etcd/client/pkg/v3/transport"
"go.etcd.io/etcd/client/pkg/v3/types"

View File

@ -22,8 +22,9 @@ import (
"strings"
"testing"
"go.etcd.io/etcd/server/v3/embed"
"sigs.k8s.io/yaml"
"go.etcd.io/etcd/server/v3/embed"
)
func TestConfigParsingMemberFlags(t *testing.T) {

View File

@ -23,6 +23,8 @@ import (
"net/http/httptest"
"testing"
"go.uber.org/zap/zaptest"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/client/pkg/v3/types"
@ -30,7 +32,6 @@ import (
"go.etcd.io/etcd/server/v3/config"
"go.etcd.io/etcd/server/v3/etcdserver"
"go.etcd.io/raft/v3"
"go.uber.org/zap/zaptest"
)
type fakeStats struct{}

View File

@ -29,6 +29,7 @@ import (
"go.uber.org/zap/zaptest"
"github.com/coreos/go-semver/semver"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/client/pkg/v3/types"

View File

@ -19,6 +19,7 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/client/pkg/v3/types"
"go.etcd.io/etcd/server/v3/etcdserver/version"

View File

@ -19,8 +19,9 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/server/v3/etcdserver/api/v2store"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/server/v3/etcdserver/api/v2store"
)
func TestIsMetaStoreOnly(t *testing.T) {

View File

@ -21,11 +21,12 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/types"
stats "go.etcd.io/etcd/server/v3/etcdserver/api/v2stats"
"go.etcd.io/raft/v3"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
func TestSendMessage(t *testing.T) {

View File

@ -26,12 +26,13 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/types"
"go.etcd.io/etcd/pkg/v3/pbutil"
"go.etcd.io/etcd/server/v3/etcdserver/api/snap"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
func TestServeRaftPrefix(t *testing.T) {

View File

@ -23,12 +23,13 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/client/pkg/v3/types"
stats "go.etcd.io/etcd/server/v3/etcdserver/api/v2stats"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
// TestPipelineSend tests that pipeline could send data using roundtripper

View File

@ -24,10 +24,11 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/types"
"go.etcd.io/etcd/server/v3/etcdserver/api/snap"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
type strReaderCloser struct{ *strings.Reader }

View File

@ -25,12 +25,13 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/client/pkg/v3/types"
stats "go.etcd.io/etcd/server/v3/etcdserver/api/v2stats"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
"github.com/coreos/go-semver/semver"
"golang.org/x/time/rate"

View File

@ -21,11 +21,12 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/types"
stats "go.etcd.io/etcd/server/v3/etcdserver/api/v2stats"
"go.etcd.io/raft/v3"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
func BenchmarkSendingMsgApp(b *testing.B) {

View File

@ -20,11 +20,12 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/client/pkg/v3/types"
stats "go.etcd.io/etcd/server/v3/etcdserver/api/v2stats"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
"github.com/xiang90/probing"
)

View File

@ -22,10 +22,11 @@ import (
"reflect"
"testing"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/fileutil"
"go.etcd.io/etcd/server/v3/storage/wal/walpb"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
var testSnap = &raftpb.Snapshot{

View File

@ -27,9 +27,10 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/types"
"go.etcd.io/etcd/client/v2"
"go.uber.org/zap/zaptest"
"github.com/jonboulle/clockwork"
)

View File

@ -19,6 +19,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/server/v3/etcdserver/api/v2error"

View File

@ -20,11 +20,11 @@ import (
"testing"
"time"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"github.com/jonboulle/clockwork"
"go.uber.org/zap/zaptest"
"github.com/jonboulle/clockwork"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
)
func TestPeriodicHourly(t *testing.T) {

View File

@ -19,9 +19,10 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.uber.org/zap/zaptest"
"github.com/jonboulle/clockwork"
)

View File

@ -20,13 +20,13 @@ import (
"fmt"
"testing"
"github.com/jonboulle/clockwork"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/mvccpb"
"go.etcd.io/etcd/client/pkg/v3/types"
clientv3 "go.etcd.io/etcd/client/v3"
"go.uber.org/zap/zaptest"
"github.com/jonboulle/clockwork"
)
// fakeKVForClusterSize is used to test getClusterSize.

View File

@ -18,12 +18,13 @@ import (
"context"
"testing"
"go.uber.org/zap/zaptest"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
txn "go.etcd.io/etcd/server/v3/etcdserver/txn"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/etcd/server/v3/storage/mvcc"
"go.uber.org/zap/zaptest"
)
func FuzzTxnRangeRequest(f *testing.F) {

View File

@ -27,12 +27,13 @@ import (
"strings"
"testing"
"go.uber.org/zap/zaptest"
bolt "go.etcd.io/bbolt"
"go.etcd.io/etcd/server/v3/storage/datadir"
"go.etcd.io/etcd/server/v3/storage/schema"
"go.etcd.io/etcd/server/v3/storage/wal"
"go.etcd.io/etcd/server/v3/storage/wal/walpb"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/version"

View File

@ -20,11 +20,12 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/server/v3/storage/backend"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/etcd/server/v3/storage/schema"
"go.uber.org/zap/zaptest"
)
// TestConsistentIndex ensures that LoadConsistentIndex/Save/ConsistentIndex and backend.BatchTx can work well together.

View File

@ -17,11 +17,11 @@ package etcdserver
import (
"testing"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/types"
"github.com/coreos/go-semver/semver"
"go.uber.org/zap/zaptest"
"github.com/coreos/go-semver/semver"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/types"
)
func TestIsCompatibleWithVers(t *testing.T) {

View File

@ -21,11 +21,12 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
"go.etcd.io/etcd/client/pkg/v3/types"
"go.etcd.io/etcd/server/v3/storage/mvcc"
"go.uber.org/zap/zaptest"
)
func TestInitialCheck(t *testing.T) {

View File

@ -22,6 +22,8 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/types"
"go.etcd.io/etcd/pkg/v3/pbutil"
"go.etcd.io/etcd/server/v3/etcdserver/api/membership"
@ -29,7 +31,6 @@ import (
serverstorage "go.etcd.io/etcd/server/v3/storage"
"go.etcd.io/raft/v3"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
func TestGetIDs(t *testing.T) {

View File

@ -29,6 +29,9 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/membershippb"
"go.etcd.io/etcd/client/pkg/v3/fileutil"
@ -57,8 +60,6 @@ import (
"go.etcd.io/etcd/server/v3/storage/schema"
"go.etcd.io/raft/v3"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
)
// TestDoLocalAction tests requests which do not need to go through raft to be applied,

View File

@ -19,11 +19,12 @@ import (
"strings"
"testing"
"go.uber.org/zap/zaptest"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/etcd/server/v3/storage/mvcc"
"go.uber.org/zap/zaptest"
"github.com/stretchr/testify/assert"
)

View File

@ -19,8 +19,9 @@ import (
"testing"
"time"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
"go.etcd.io/raft/v3/raftpb"
)
func BenchmarkWarnOfExpensiveRequestNoLog(b *testing.B) {

View File

@ -19,9 +19,10 @@ import (
"testing"
"github.com/coreos/go-semver/semver"
"go.etcd.io/etcd/api/v3/version"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/version"
)
func TestMustDetectDowngrade(t *testing.T) {

View File

@ -23,9 +23,10 @@ import (
"testing"
"time"
"go.etcd.io/etcd/client/pkg/v3/logutil"
"go.uber.org/zap"
"go.uber.org/zap/zapcore"
"go.etcd.io/etcd/client/pkg/v3/logutil"
)
func TestNewRaftLogger(t *testing.T) {

View File

@ -21,9 +21,10 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
func TestRenewHTTP(t *testing.T) {

View File

@ -19,8 +19,9 @@ import (
"testing"
"time"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
)
func BenchmarkLessorGrant1000(b *testing.B) { benchmarkLessorGrant(1000, b) }

View File

@ -26,12 +26,13 @@ import (
"time"
"github.com/coreos/go-semver/semver"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/server/v3/storage/backend"
"go.etcd.io/etcd/server/v3/storage/schema"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
)
const (

View File

@ -20,11 +20,12 @@ import (
"testing"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/pkg/v3/traceutil"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/etcd/server/v3/storage/mvcc/testutil"
"go.uber.org/zap/zaptest"
)
// TestHashByRevValue test HashByRevValue values to ensure we don't change the

View File

@ -22,13 +22,14 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/mvccpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/pkg/v3/traceutil"
"go.etcd.io/etcd/server/v3/lease"
"go.etcd.io/etcd/server/v3/storage/backend"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
"github.com/prometheus/client_golang/prometheus"
dto "github.com/prometheus/client_model/go"

View File

@ -19,12 +19,13 @@ import (
"testing"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/pkg/v3/traceutil"
"go.etcd.io/etcd/server/v3/etcdserver/cindex"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/etcd/server/v3/storage/schema"
"go.uber.org/zap/zaptest"
)
func BenchmarkStorePut(b *testing.B) {

View File

@ -21,11 +21,12 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/pkg/v3/traceutil"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/etcd/server/v3/storage/schema"
"go.uber.org/zap/zaptest"
)
func TestScheduleCompaction(t *testing.T) {

View File

@ -30,6 +30,8 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/mvccpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/pkg/v3/schedule"
@ -38,7 +40,6 @@ import (
"go.etcd.io/etcd/server/v3/storage/backend"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/etcd/server/v3/storage/schema"
"go.uber.org/zap/zaptest"
"go.uber.org/zap"
)

View File

@ -19,10 +19,11 @@ import (
"os"
"testing"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/pkg/v3/traceutil"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
func BenchmarkWatchableStorePut(b *testing.B) {

View File

@ -23,11 +23,12 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/mvccpb"
"go.etcd.io/etcd/pkg/v3/traceutil"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
func TestWatch(t *testing.T) {

View File

@ -18,9 +18,10 @@ import (
"fmt"
"testing"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
func BenchmarkKVWatcherMemoryUsage(b *testing.B) {

View File

@ -22,10 +22,11 @@ import (
"testing"
"time"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/mvccpb"
"go.etcd.io/etcd/server/v3/lease"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
// TestWatcherWatchID tests that each watcher provides unique watchID,

View File

@ -20,9 +20,10 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/server/v3/storage/backend"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
func TestActionIsReversible(t *testing.T) {

View File

@ -18,9 +18,10 @@ import (
"testing"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
func TestConfStateFromBackendInOneTx(t *testing.T) {

View File

@ -20,10 +20,11 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/server/v3/lease/leasepb"
"go.etcd.io/etcd/server/v3/storage/backend"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
func TestLeaseBackend(t *testing.T) {

View File

@ -21,10 +21,11 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/server/v3/storage/backend"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
"go.uber.org/zap/zaptest"
)
func TestNewPlan(t *testing.T) {

View File

@ -20,6 +20,8 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/stretchr/testify/assert"
"go.uber.org/zap"
"go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/membershippb"
"go.etcd.io/etcd/api/v3/version"
@ -28,7 +30,6 @@ import (
"go.etcd.io/etcd/server/v3/storage/wal"
waltesting "go.etcd.io/etcd/server/v3/storage/wal/testing"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap"
)
func TestValidate(t *testing.T) {

View File

@ -20,9 +20,10 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/stretchr/testify/assert"
"go.etcd.io/bbolt"
"go.uber.org/zap/zaptest"
"go.etcd.io/bbolt"
"go.etcd.io/etcd/server/v3/storage/backend"
betesting "go.etcd.io/etcd/server/v3/storage/backend/testing"
)

View File

@ -20,9 +20,10 @@ import (
"os"
"testing"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/server/v3/storage/wal/walpb"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
type corruptFunc func(string, int64) error

View File

@ -21,12 +21,13 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/golang/protobuf/proto"
"github.com/stretchr/testify/assert"
"google.golang.org/protobuf/reflect/protoreflect"
"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/pkg/v3/pbutil"
"go.etcd.io/raft/v3/raftpb"
"google.golang.org/protobuf/reflect/protoreflect"
)
func TestEtcdVersionFromEntry(t *testing.T) {

View File

@ -17,8 +17,9 @@ package wal
import (
"testing"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
"go.etcd.io/raft/v3/raftpb"
)
func BenchmarkWrite100EntryWithoutBatch(b *testing.B) { benchmarkWriteEntry(b, 100, 0) }

View File

@ -30,11 +30,12 @@ import (
"testing"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/fileutil"
"go.etcd.io/etcd/pkg/v3/pbutil"
"go.etcd.io/etcd/server/v3/storage/wal/walpb"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap/zaptest"
)
var (

View File

@ -18,6 +18,7 @@ import (
"testing"
"github.com/golang/protobuf/descriptor"
"go.etcd.io/raft/v3/raftpb"
)

View File

@ -20,6 +20,7 @@ import (
"time"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/testutils"
)

View File

@ -21,6 +21,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/testutils"
)

View File

@ -21,6 +21,7 @@ import (
"time"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/testutils"
)

View File

@ -20,6 +20,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/testutils"

View File

@ -20,6 +20,7 @@ import (
"time"
"github.com/stretchr/testify/require"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/testutils"

View File

@ -20,6 +20,7 @@ import (
"time"
"github.com/stretchr/testify/require"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/server/v3/etcdserver"
"go.etcd.io/etcd/tests/v3/framework/config"

View File

@ -21,6 +21,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/tests/v3/framework/config"

View File

@ -20,6 +20,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/testutils"
)

View File

@ -20,6 +20,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/testutils"
)

View File

@ -25,12 +25,13 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.uber.org/zap"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/fileutil"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/tests/v3/framework/e2e"
"go.etcd.io/etcd/tests/v3/framework/testutils"
"go.uber.org/zap"
)
func TestDowngradeUpgradeClusterOf1(t *testing.T) {

View File

@ -21,6 +21,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/api/v3/etcdserverpb"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/server/v3/storage/datadir"

View File

@ -22,6 +22,7 @@ import (
"time"
"github.com/stretchr/testify/require"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/tests/v3/framework/e2e"
)

View File

@ -24,6 +24,7 @@ import (
"testing"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/tests/v3/framework/e2e"
)

View File

@ -22,6 +22,7 @@ import (
"time"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/pkg/v3/expect"
"go.etcd.io/etcd/tests/v3/framework/e2e"
)

View File

@ -24,6 +24,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/e2e"
"go.etcd.io/etcd/tests/v3/framework/testutils"

View File

@ -21,6 +21,7 @@ import (
"time"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/tests/v3/framework/e2e"
)

View File

@ -23,6 +23,7 @@ import (
"time"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/pkg/v3/expect"
"go.etcd.io/etcd/tests/v3/framework/e2e"
)

View File

@ -22,6 +22,7 @@ import (
"time"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/client/pkg/v3/transport"
"go.etcd.io/etcd/client/pkg/v3/types"
clientv3 "go.etcd.io/etcd/client/v3"

View File

@ -26,6 +26,7 @@ import (
"time"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/etcdutl/v3/snapshot"
"go.etcd.io/etcd/pkg/v3/expect"
"go.etcd.io/etcd/tests/v3/framework/e2e"

View File

@ -23,6 +23,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/pkg/v3/flags"

View File

@ -22,6 +22,7 @@ import (
"testing"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/pkg/v3/expect"
"go.etcd.io/etcd/tests/v3/framework/e2e"
)

View File

@ -22,6 +22,7 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/pkg/v3/expect"

View File

@ -25,12 +25,13 @@ import (
"github.com/coreos/go-semver/semver"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/client/pkg/v3/fileutil"
"go.etcd.io/etcd/server/v3/storage/backend"
"go.etcd.io/etcd/server/v3/storage/schema"
"go.etcd.io/etcd/tests/v3/framework/e2e"
"go.uber.org/zap/zaptest"
)
func TestEtctlutlMigrate(t *testing.T) {

View File

@ -23,13 +23,14 @@ import (
"testing"
"github.com/stretchr/testify/assert"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/fileutil"
"go.etcd.io/etcd/server/v3/etcdserver"
"go.etcd.io/etcd/server/v3/etcdserver/api/snap"
"go.etcd.io/etcd/server/v3/etcdserver/api/v2store"
"go.etcd.io/etcd/tests/v3/framework/config"
"go.etcd.io/etcd/tests/v3/framework/e2e"
"go.uber.org/zap/zaptest"
)
func createV2store(t testing.TB, dataDirPath string) string {

View File

@ -21,6 +21,7 @@ import (
"testing"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/api/v3/version"
"go.etcd.io/etcd/tests/v3/framework/e2e"
)

View File

@ -26,6 +26,7 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/tests/v3/framework/e2e"

View File

@ -25,6 +25,7 @@ import (
"testing"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/api/v3/authpb"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"

View File

@ -19,11 +19,12 @@ import (
"flag"
"testing"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/tests/v3/functional/tester"
"go.uber.org/zap"
"go.uber.org/zap/zapcore"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/client/pkg/v3/testutil"
"go.etcd.io/etcd/tests/v3/functional/tester"
)
var config = flag.String("config", "../../functional.yaml", "path to tester configuration")

View File

@ -19,8 +19,9 @@ import (
"sort"
"testing"
"go.etcd.io/etcd/tests/v3/functional/rpcpb"
"go.uber.org/zap/zaptest"
"go.etcd.io/etcd/tests/v3/functional/rpcpb"
)
func Test_read(t *testing.T) {

View File

@ -25,14 +25,15 @@ import (
"testing"
"time"
"google.golang.org/grpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
"go.etcd.io/etcd/api/v3/mvccpb"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
"go.etcd.io/etcd/api/v3/version"
clientv3 "go.etcd.io/etcd/client/v3"
integration2 "go.etcd.io/etcd/tests/v3/framework/integration"
"google.golang.org/grpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
)
func TestKVPutError(t *testing.T) {

View File

@ -27,10 +27,11 @@ import (
grpcprom "github.com/grpc-ecosystem/go-grpc-prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp"
"google.golang.org/grpc"
"go.etcd.io/etcd/client/pkg/v3/transport"
clientv3 "go.etcd.io/etcd/client/v3"
integration2 "go.etcd.io/etcd/tests/v3/framework/integration"
"google.golang.org/grpc"
)
func TestV3ClientMetrics(t *testing.T) {

View File

@ -22,11 +22,12 @@ import (
"testing"
"time"
"google.golang.org/grpc"
"go.etcd.io/etcd/api/v3/mvccpb"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/client/v3/mirror"
integration2 "go.etcd.io/etcd/tests/v3/framework/integration"
"google.golang.org/grpc"
)
func TestMirrorSync_Authenticated(t *testing.T) {

View File

@ -21,6 +21,7 @@ import (
"time"
"github.com/stretchr/testify/assert"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/client/v3/ordering"
integration2 "go.etcd.io/etcd/tests/v3/framework/integration"

View File

@ -19,10 +19,11 @@ import (
"testing"
"time"
"google.golang.org/grpc"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
clientv3 "go.etcd.io/etcd/client/v3"
integration2 "go.etcd.io/etcd/tests/v3/framework/integration"
"google.golang.org/grpc"
)
func TestUserError(t *testing.T) {

View File

@ -24,13 +24,14 @@ import (
"testing"
"time"
"google.golang.org/grpc/metadata"
mvccpb "go.etcd.io/etcd/api/v3/mvccpb"
"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
"go.etcd.io/etcd/api/v3/version"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/server/v3/etcdserver/api/v3rpc"
integration2 "go.etcd.io/etcd/tests/v3/framework/integration"
"google.golang.org/grpc/metadata"
)
type watcherTest func(*testing.T, *watchctx)

View File

@ -22,6 +22,7 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.etcd.io/etcd/api/v3/etcdserverpb"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/server/v3/storage/mvcc/testutil"

View File

@ -22,9 +22,10 @@ import (
"testing"
"time"
"google.golang.org/grpc"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/tests/v3/framework/integration"
"google.golang.org/grpc"
)
func TestAuthority(t *testing.T) {

View File

@ -20,6 +20,7 @@ import (
"testing"
"github.com/stretchr/testify/assert"
"go.etcd.io/etcd/tests/v3/framework/integration"
)

View File

@ -20,14 +20,14 @@ import (
"testing"
"time"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
"google.golang.org/grpc"
pb "go.etcd.io/etcd/api/v3/etcdserverpb"
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/server/v3/proxy/grpcproxy"
integration2 "go.etcd.io/etcd/tests/v3/framework/integration"
"go.uber.org/zap/zaptest"
"go.uber.org/zap"
"google.golang.org/grpc"
)
func TestClusterProxyMemberList(t *testing.T) {

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