Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

etcdserver: update import paths to "go.etcd.io/etcd"

Browse Source 
Signed-off-by: Gyuho Lee <leegyuho@amazon.com>
This commit is contained in:
Gyuho Lee 2018-08-28 17:11:43 -07:00
parent bb60f8ab1d
commit 1399bc69ce
126 changed files with 458 additions and 458 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
etcdserver/api/capability.go
View File

@ -17,7 +17,7 @@ package api
import (
"sync"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/version"
"go.uber.org/zap"
"github.com/coreos/go-semver/semver"
@ -32,7 +32,7 @@ const (
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/api")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/api")
// capabilityMaps is a static map of version to capability map.
capabilityMaps = map[string]map[Capability]bool{

4
etcdserver/api/cluster.go
View File

@ -15,8 +15,8 @@
package api
import (
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/go-semver/semver"
)

14
etcdserver/api/etcdhttp/base.go
View File

@ -21,19 +21,19 @@ import (
"net/http"
"strings"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2http/httptypes"
"github.com/coreos/etcd/pkg/logutil"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2http/httptypes"
"go.etcd.io/etcd/pkg/logutil"
"go.etcd.io/etcd/version"
"github.com/coreos/pkg/capnslog"
"go.uber.org/zap"
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/api/etcdhttp")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/api/etcdhttp")
mlog = logutil.NewMergeLogger(plog)
)

6
etcdserver/api/etcdhttp/metrics.go
View File

@ -20,9 +20,9 @@ import (
"net/http"
"time"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/raft"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/raft"
"github.com/prometheus/client_golang/prometheus/promhttp"
)

8
etcdserver/api/etcdhttp/peer.go
View File

@ -18,10 +18,10 @@ import (
"encoding/json"
"net/http"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/rafthttp"
"github.com/coreos/etcd/lease/leasehttp"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/rafthttp"
"go.etcd.io/etcd/lease/leasehttp"
"go.uber.org/zap"
)

8
etcdserver/api/etcdhttp/peer_test.go
View File

@ -25,10 +25,10 @@ import (
"go.uber.org/zap"
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/etcdserver/api/rafthttp"
"github.com/coreos/etcd/pkg/testutil"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/etcdserver/api/rafthttp"
"go.etcd.io/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/go-semver/semver"
)

2
etcdserver/api/etcdhttp/version_test.go
View File

@ -20,7 +20,7 @@ import (
"net/http/httptest"
"testing"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/version"
)
func TestServeVersion(t *testing.T) {

16
etcdserver/api/membership/cluster.go
View File

@ -27,13 +27,13 @@ import (
"sync"
"time"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/mvcc/backend"
"github.com/coreos/etcd/pkg/netutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/raft/raftpb"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/mvcc/backend"
"go.etcd.io/etcd/pkg/netutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/raft/raftpb"
"go.etcd.io/etcd/version"
"github.com/coreos/go-semver/semver"
"go.uber.org/zap"
@ -516,7 +516,7 @@ func (c *RaftCluster) IsReadyToAddNewMember() bool {
if nstarted == 1 && nmembers == 2 {
// a case of adding a new node to 1-member cluster for restoring cluster data
// https://github.com/coreos/etcd/blob/master/Documentation/v2/admin_guide.md#restoring-the-cluster
// https://go.etcd.io/etcd/blob/master/Documentation/v2/admin_guide.md#restoring-the-cluster
if c.lg != nil {
c.lg.Debug("number of started member is 1; can accept add member request")
} else {

10
etcdserver/api/membership/cluster_test.go
View File

@ -21,11 +21,11 @@ import (
"reflect"
"testing"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/pkg/mock/mockstore"
"github.com/coreos/etcd/pkg/testutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/pkg/mock/mockstore"
"go.etcd.io/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.uber.org/zap"
)

2
etcdserver/api/membership/errors.go
View File

@ -17,7 +17,7 @@ package membership
import (
"errors"
"github.com/coreos/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2error"
)
var (

4
etcdserver/api/membership/member.go
View File

@ -22,12 +22,12 @@ import (
"sort"
"time"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/pkg/capnslog"
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/membership")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/membership")
)
// RaftAttributes represents the raft related attributes of an etcd member.

2
etcdserver/api/membership/member_test.go
View File

@ -20,7 +20,7 @@ import (
"testing"
"time"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/pkg/types"
)
func timeParse(value string) *time.Time {

6
etcdserver/api/membership/store.go
View File

@ -19,9 +19,9 @@ import (
"fmt"
"path"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/mvcc/backend"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/mvcc/backend"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/go-semver/semver"
)

2
etcdserver/api/rafthttp/coder.go
View File

@ -14,7 +14,7 @@
package rafthttp
import "github.com/coreos/etcd/raft/raftpb"
import "go.etcd.io/etcd/raft/raftpb"
type encoder interface {
// encode encodes the given message to an output stream.

8
etcdserver/api/rafthttp/functional_test.go
View File

@ -21,10 +21,10 @@ import (
"testing"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/raft/raftpb"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/raft/raftpb"
)
func TestSendMessage(t *testing.T) {

10
etcdserver/api/rafthttp/http.go
View File

@ -24,11 +24,11 @@ import (
"strings"
"time"
"github.com/coreos/etcd/etcdserver/api/snap"
pioutil "github.com/coreos/etcd/pkg/ioutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/etcdserver/api/snap"
pioutil "go.etcd.io/etcd/pkg/ioutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.etcd.io/etcd/version"
humanize "github.com/dustin/go-humanize"
"go.uber.org/zap"

10
etcdserver/api/rafthttp/http_test.go
View File

@ -26,11 +26,11 @@ import (
"testing"
"time"
"github.com/coreos/etcd/etcdserver/api/snap"
"github.com/coreos/etcd/pkg/pbutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/etcdserver/api/snap"
"go.etcd.io/etcd/pkg/pbutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.etcd.io/etcd/version"
"go.uber.org/zap"
)

4
etcdserver/api/rafthttp/msg_codec.go
View File

@ -19,8 +19,8 @@ import (
"errors"
"io"
"github.com/coreos/etcd/pkg/pbutil"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/pkg/pbutil"
"go.etcd.io/etcd/raft/raftpb"
)
// messageEncoder is a encoder that can encode all kinds of messages.

2
etcdserver/api/rafthttp/msg_codec_test.go
View File

@ -19,7 +19,7 @@ import (
"reflect"
"testing"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/raft/raftpb"
)
func TestMessage(t *testing.T) {

8
etcdserver/api/rafthttp/msgappv2_codec.go
View File

@ -20,10 +20,10 @@ import (
"io"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/pbutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/pbutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
)
const (

6
etcdserver/api/rafthttp/msgappv2_codec_test.go
View File

@ -19,9 +19,9 @@ import (
"reflect"
"testing"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
)
func TestMsgAppV2(t *testing.T) {

10
etcdserver/api/rafthttp/peer.go
View File

@ -19,11 +19,11 @@ import (
"sync"
"time"
"github.com/coreos/etcd/etcdserver/api/snap"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/etcdserver/api/snap"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/raft/raftpb"
"go.uber.org/zap"
"golang.org/x/time/rate"

2
etcdserver/api/rafthttp/peer_status.go
View File

@ -20,7 +20,7 @@ import (
"sync"
"time"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/pkg/types"
"go.uber.org/zap"
)

2
etcdserver/api/rafthttp/peer_test.go
View File

@ -17,7 +17,7 @@ package rafthttp
import (
"testing"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/raft/raftpb"
)
func TestPeerPick(t *testing.T) {

10
etcdserver/api/rafthttp/pipeline.go
View File

@ -22,11 +22,11 @@ import (
"sync"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/pbutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/raft/raftpb"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/pbutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/raft/raftpb"
"go.uber.org/zap"
)

10
etcdserver/api/rafthttp/pipeline_test.go
View File

@ -24,11 +24,11 @@ import (
"testing"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/testutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"github.com/coreos/etcd/version"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.etcd.io/etcd/version"
"go.uber.org/zap"
)

4
etcdserver/api/rafthttp/remote.go
View File

@ -15,8 +15,8 @@
package rafthttp
import (
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.uber.org/zap"
)

10
etcdserver/api/rafthttp/snapshot_sender.go
View File

@ -22,11 +22,11 @@ import (
"net/http"
"time"
"github.com/coreos/etcd/etcdserver/api/snap"
"github.com/coreos/etcd/pkg/httputil"
pioutil "github.com/coreos/etcd/pkg/ioutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"go.etcd.io/etcd/etcdserver/api/snap"
"go.etcd.io/etcd/pkg/httputil"
pioutil "go.etcd.io/etcd/pkg/ioutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
"github.com/dustin/go-humanize"
"go.uber.org/zap"

6
etcdserver/api/rafthttp/snapshot_test.go
View File

@ -25,9 +25,9 @@ import (
"testing"
"time"
"github.com/coreos/etcd/etcdserver/api/snap"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/etcdserver/api/snap"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.uber.org/zap"
)

12
etcdserver/api/rafthttp/stream.go
View File

@ -25,12 +25,12 @@ import (
"sync"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/httputil"
"github.com/coreos/etcd/pkg/transport"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"github.com/coreos/etcd/version"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/httputil"
"go.etcd.io/etcd/pkg/transport"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.etcd.io/etcd/version"
"github.com/coreos/go-semver/semver"
"go.uber.org/zap"

10
etcdserver/api/rafthttp/stream_test.go
View File

@ -26,11 +26,11 @@ import (
"testing"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/testutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"github.com/coreos/etcd/version"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"go.etcd.io/etcd/version"
"github.com/coreos/go-semver/semver"
"go.uber.org/zap"

16
etcdserver/api/rafthttp/transport.go
View File

@ -20,13 +20,13 @@ import (
"sync"
"time"
"github.com/coreos/etcd/etcdserver/api/snap"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/logutil"
"github.com/coreos/etcd/pkg/transport"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/etcdserver/api/snap"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/logutil"
"go.etcd.io/etcd/pkg/transport"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/raft/raftpb"
"github.com/coreos/pkg/capnslog"
"github.com/xiang90/probing"
@ -34,7 +34,7 @@ import (
"golang.org/x/time/rate"
)
var plog = logutil.NewMergeLogger(capnslog.NewPackageLogger("github.com/coreos/etcd", "rafthttp"))
var plog = logutil.NewMergeLogger(capnslog.NewPackageLogger("go.etcd.io/etcd", "rafthttp"))
type Raft interface {
Process(ctx context.Context, m raftpb.Message) error

8
etcdserver/api/rafthttp/transport_bench_test.go
View File

@ -21,10 +21,10 @@ import (
"testing"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/raft/raftpb"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/raft/raftpb"
)
func BenchmarkSendingMsgApp(b *testing.B) {

8
etcdserver/api/rafthttp/transport_test.go
View File

@ -20,10 +20,10 @@ import (
"testing"
"time"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/pkg/testutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"github.com/xiang90/probing"
)

2
etcdserver/api/rafthttp/urlpick.go
View File

@ -18,7 +18,7 @@ import (
"net/url"
"sync"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/pkg/types"
)
type urlPicker struct {

2
etcdserver/api/rafthttp/urlpick_test.go
View File

@ -18,7 +18,7 @@ import (
"net/url"
"testing"
"github.com/coreos/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/testutil"
)
// TestURLPickerPickTwice tests that pick returns a possible url,

6
etcdserver/api/rafthttp/util.go
View File

@ -23,9 +23,9 @@ import (
"strings"
"time"
"github.com/coreos/etcd/pkg/transport"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/pkg/transport"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/version"
"github.com/coreos/go-semver/semver"
)

4
etcdserver/api/rafthttp/util_test.go
View File

@ -22,8 +22,8 @@ import (
"reflect"
"testing"
"github.com/coreos/etcd/raft/raftpb"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/raft/raftpb"
"go.etcd.io/etcd/version"
"github.com/coreos/go-semver/semver"
)

2
etcdserver/api/snap/db.go
View File

@ -23,7 +23,7 @@ import (
"path/filepath"
"time"
"github.com/coreos/etcd/pkg/fileutil"
"go.etcd.io/etcd/pkg/fileutil"
humanize "github.com/dustin/go-humanize"
"go.uber.org/zap"

4
etcdserver/api/snap/message.go
View File

@ -17,8 +17,8 @@ package snap
import (
"io"
"github.com/coreos/etcd/pkg/ioutil"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/pkg/ioutil"
"go.etcd.io/etcd/raft/raftpb"
)
// Message is a struct that contains a raft Message and a ReadCloser. The type

12
etcdserver/api/snap/snapshotter.go
View File

@ -25,11 +25,11 @@ import (
"strings"
"time"
"github.com/coreos/etcd/etcdserver/api/snap/snappb"
pioutil "github.com/coreos/etcd/pkg/ioutil"
"github.com/coreos/etcd/pkg/pbutil"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/etcdserver/api/snap/snappb"
pioutil "go.etcd.io/etcd/pkg/ioutil"
"go.etcd.io/etcd/pkg/pbutil"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/raft/raftpb"
"github.com/coreos/pkg/capnslog"
"go.uber.org/zap"
@ -38,7 +38,7 @@ import (
const snapSuffix = ".snap"
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "snap")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "snap")
ErrNoSnapshot = errors.New("snap: no available snapshot")
ErrEmptySnapshot = errors.New("snap: empty snapshot")

2
etcdserver/api/snap/snapshotter_test.go
View File

@ -23,7 +23,7 @@ import (
"reflect"
"testing"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/raft/raftpb"
"go.uber.org/zap"
)

10
etcdserver/api/v2auth/auth.go
View File

@ -26,10 +26,10 @@ import (
"strings"
"time"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/pkg/capnslog"
"go.uber.org/zap"
@ -48,7 +48,7 @@ const (
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/auth")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/auth")
)
var rootRole = Role{

6
etcdserver/api/v2auth/auth_requests.go
View File

@ -19,9 +19,9 @@ import (
"encoding/json"
"path"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.uber.org/zap"
)

8
etcdserver/api/v2auth/auth_test.go
View File

@ -20,10 +20,10 @@ import (
"testing"
"time"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.uber.org/zap"
)

8
etcdserver/api/v2discovery/discovery.go
View File

@ -29,9 +29,9 @@ import (
"strings"
"time"
"github.com/coreos/etcd/client"
"github.com/coreos/etcd/pkg/transport"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/client"
"go.etcd.io/etcd/pkg/transport"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/pkg/capnslog"
"github.com/jonboulle/clockwork"
@ -39,7 +39,7 @@ import (
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "discovery")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "discovery")
ErrInvalidURL = errors.New("discovery: invalid URL")
ErrBadSizeKey = errors.New("discovery: size key is bad")

2
etcdserver/api/v2discovery/discovery_test.go
View File

@ -28,7 +28,7 @@ import (
"go.uber.org/zap"
"github.com/coreos/etcd/client"
"go.etcd.io/etcd/client"
"github.com/jonboulle/clockwork"
)

4
etcdserver/api/v2http/capability.go
View File

@ -18,8 +18,8 @@ import (
"fmt"
"net/http"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/v2http/httptypes"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/v2http/httptypes"
)
func authCapabilityHandler(fn func(http.ResponseWriter, *http.Request)) http.HandlerFunc {

22
etcdserver/api/v2http/client.go
View File

@ -27,17 +27,17 @@ import (
"strings"
"time"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/etcdhttp"
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/etcdserver/api/v2auth"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2http/httptypes"
stats "github.com/coreos/etcd/etcdserver/api/v2stats"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/etcdhttp"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/etcdserver/api/v2auth"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2http/httptypes"
stats "go.etcd.io/etcd/etcdserver/api/v2stats"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/types"
"github.com/jonboulle/clockwork"
"go.uber.org/zap"

6
etcdserver/api/v2http/client_auth.go
View File

@ -20,9 +20,9 @@ import (
"path"
"strings"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/v2auth"
"github.com/coreos/etcd/etcdserver/api/v2http/httptypes"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/v2auth"
"go.etcd.io/etcd/etcdserver/api/v2http/httptypes"
"go.uber.org/zap"
)

4
etcdserver/api/v2http/client_auth_test.go
View File

@ -30,8 +30,8 @@ import (
"strings"
"testing"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/v2auth"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/v2auth"
"go.uber.org/zap"
)

20
etcdserver/api/v2http/client_test.go
View File

@ -29,16 +29,16 @@ import (
"testing"
"time"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2http/httptypes"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/testutil"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2http/httptypes"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"github.com/coreos/go-semver/semver"
"github.com/jonboulle/clockwork"

10
etcdserver/api/v2http/http.go
View File

@ -20,10 +20,10 @@ import (
"strings"
"time"
"github.com/coreos/etcd/etcdserver/api/etcdhttp"
"github.com/coreos/etcd/etcdserver/api/v2auth"
"github.com/coreos/etcd/etcdserver/api/v2http/httptypes"
"github.com/coreos/etcd/pkg/logutil"
"go.etcd.io/etcd/etcdserver/api/etcdhttp"
"go.etcd.io/etcd/etcdserver/api/v2auth"
"go.etcd.io/etcd/etcdserver/api/v2http/httptypes"
"go.etcd.io/etcd/pkg/logutil"
"github.com/coreos/pkg/capnslog"
"go.uber.org/zap"
@ -35,7 +35,7 @@ const (
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/api/v2http")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/api/v2http")
mlog = logutil.NewMergeLogger(plog)
)

12
etcdserver/api/v2http/http_test.go
View File

@ -22,12 +22,12 @@ import (
"sort"
"testing"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft/raftpb"
"github.com/coreos/go-semver/semver"
"go.uber.org/zap"

2
etcdserver/api/v2http/httptypes/errors.go
View File

@ -22,7 +22,7 @@ import (
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/api/v2http/httptypes")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/api/v2http/httptypes")
)
type HTTPError struct {

2
etcdserver/api/v2http/httptypes/member.go
View File

@ -19,7 +19,7 @@ package httptypes
import (
"encoding/json"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/pkg/types"
)
type Member struct {

2
etcdserver/api/v2http/httptypes/member_test.go
View File

@ -20,7 +20,7 @@ import (
"reflect"
"testing"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/pkg/types"
)
func TestMemberUnmarshal(t *testing.T) {

6
etcdserver/api/v2http/metrics.go
View File

@ -20,9 +20,9 @@ import (
"net/http"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2http/httptypes"
"github.com/coreos/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2http/httptypes"
"go.etcd.io/etcd/etcdserver/etcdserverpb"
"github.com/prometheus/client_golang/prometheus"
)

2
etcdserver/api/v2stats/server.go
View File

@ -20,7 +20,7 @@ import (
"sync"
"time"
"github.com/coreos/etcd/raft"
"go.etcd.io/etcd/raft"
)
// ServerStats encapsulates various statistics about an EtcdServer and its

2
etcdserver/api/v2stats/stats.go
View File

@ -17,7 +17,7 @@ package v2stats
import "github.com/coreos/pkg/capnslog"
var plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/stats")
var plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/stats")
type Stats interface {
// SelfStats returns the struct representing statistics of this server

2
etcdserver/api/v2store/event_history.go
View File

@ -20,7 +20,7 @@ import (
"strings"
"sync"
"github.com/coreos/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2error"
)
type EventHistory struct {

2
etcdserver/api/v2store/event_test.go
View File

@ -17,7 +17,7 @@ package v2store
import (
"testing"
"github.com/coreos/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2error"
)
// TestEventQueue tests a queue with capacity = 100

2
etcdserver/api/v2store/node.go
View File

@ -19,7 +19,7 @@ import (
"sort"
"time"
"github.com/coreos/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2error"
"github.com/jonboulle/clockwork"
)

2
etcdserver/api/v2store/node_extern_test.go
View File

@ -20,7 +20,7 @@ import (
"time"
"unsafe"
"github.com/coreos/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/testutil"
)
func TestNodeExternClone(t *testing.T) {

2
etcdserver/api/v2store/stats_test.go
View File

@ -18,7 +18,7 @@ import (
"testing"
"time"
"github.com/coreos/etcd/pkg/testutil"
"go.etcd.io/etcd/pkg/testutil"
)
// Ensure that a successful Get is recorded in the stats.

4
etcdserver/api/v2store/store.go
View File

@ -23,8 +23,8 @@ import (
"sync"
"time"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/pkg/types"
"github.com/jonboulle/clockwork"
)

6
etcdserver/api/v2store/store_test.go
View File

@ -18,9 +18,9 @@ import (
"testing"
"time"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/pkg/testutil"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/pkg/testutil"
)
type StoreCloser interface {

4
etcdserver/api/v2store/store_ttl_test.go
View File

@ -18,8 +18,8 @@ import (
"testing"
"time"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/pkg/testutil"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/pkg/testutil"
"github.com/jonboulle/clockwork"
)

4
etcdserver/api/v2store/store_v2_test.go
View File

@ -19,8 +19,8 @@ package v2store_test
import (
"testing"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/pkg/testutil"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/pkg/testutil"
)
type v2TestStore struct {

8
etcdserver/api/v2store/store_v2v3_test.go
View File

@ -20,10 +20,10 @@ import (
"io/ioutil"
"testing"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/etcdserver/api/v2v3"
"github.com/coreos/etcd/integration"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/etcdserver/api/v2v3"
"go.etcd.io/etcd/integration"
"google.golang.org/grpc/grpclog"
)

2
etcdserver/api/v2store/watcher_hub.go
View File

@ -21,7 +21,7 @@ import (
"sync"
"sync/atomic"
"github.com/coreos/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2error"
)
// A watcherHub contains all subscribed watchers

4
etcdserver/api/v2v3/cluster.go
View File

@ -15,8 +15,8 @@
package v2v3
import (
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/go-semver/semver"
)

12
etcdserver/api/v2v3/server.go
View File

@ -19,12 +19,12 @@ import (
"net/http"
"time"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/membership"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/membership"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/go-semver/semver"
"go.uber.org/zap"

10
etcdserver/api/v2v3/store.go
View File

@ -22,11 +22,11 @@ import (
"strings"
"time"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/clientv3/concurrency"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2store"
"github.com/coreos/etcd/mvcc/mvccpb"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/clientv3/concurrency"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/mvcc/mvccpb"
)
// store implements the Store interface for V2 using

6
etcdserver/api/v2v3/watcher.go
View File

@ -18,9 +18,9 @@ import (
"context"
"strings"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/etcdserver/api/v2error"
"github.com/coreos/etcd/etcdserver/api/v2store"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/etcdserver/api/v2error"
"go.etcd.io/etcd/etcdserver/api/v2store"
)
func (s *v2v3Store) Watch(prefix string, recursive, stream bool, sinceIndex uint64) (v2store.Watcher, error) {

8
etcdserver/api/v3alarm/alarms.go
View File

@ -18,16 +18,16 @@ package v3alarm
import (
"sync"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/mvcc/backend"
"github.com/coreos/etcd/pkg/types"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/mvcc/backend"
"go.etcd.io/etcd/pkg/types"
"github.com/coreos/pkg/capnslog"
)
var (
alarmBucketName = []byte("alarm")
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "alarm")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "alarm")
)
type BackendGetter interface {

4
etcdserver/api/v3client/doc.go
View File

@ -19,8 +19,8 @@
// import (
// "context"
//
// "github.com/coreos/etcd/embed"
// "github.com/coreos/etcd/etcdserver/api/v3client"
// "go.etcd.io/etcd/embed"
// "go.etcd.io/etcd/etcdserver/api/v3client"
// )
//
// ...

8
etcdserver/api/v3client/v3client.go
View File

@ -18,10 +18,10 @@ import (
"context"
"time"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v3rpc"
"github.com/coreos/etcd/proxy/grpcproxy/adapter"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v3rpc"
"go.etcd.io/etcd/proxy/grpcproxy/adapter"
)
// New creates a clientv3 client that wraps an in-process EtcdServer. Instead

4
etcdserver/api/v3compactor/compactor.go
View File

@ -19,7 +19,7 @@ import (
"fmt"
"time"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"github.com/coreos/pkg/capnslog"
"github.com/jonboulle/clockwork"
@ -27,7 +27,7 @@ import (
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "compactor")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "compactor")
)
const (

4
etcdserver/api/v3compactor/compactor_test.go
View File

@ -18,8 +18,8 @@ import (
"context"
"sync/atomic"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/testutil"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/testutil"
)
type fakeCompactable struct {

4
etcdserver/api/v3compactor/periodic.go
View File

@ -19,8 +19,8 @@ import (
"sync"
"time"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/mvcc"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/mvcc"
"github.com/jonboulle/clockwork"
"go.uber.org/zap"

4
etcdserver/api/v3compactor/periodic_test.go
View File

@ -19,8 +19,8 @@ import (
"testing"
"time"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/testutil"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/testutil"
"github.com/jonboulle/clockwork"
"go.uber.org/zap"

4
etcdserver/api/v3compactor/revision.go
View File

@ -19,8 +19,8 @@ import (
"sync"
"time"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/mvcc"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/mvcc"
"github.com/jonboulle/clockwork"
"go.uber.org/zap"

4
etcdserver/api/v3compactor/revision_test.go
View File

@ -19,8 +19,8 @@ import (
"testing"
"time"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/testutil"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/testutil"
"github.com/jonboulle/clockwork"
"go.uber.org/zap"

6
etcdserver/api/v3election/election.go
View File

@ -18,9 +18,9 @@ import (
"context"
"errors"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/clientv3/concurrency"
epb "github.com/coreos/etcd/etcdserver/api/v3election/v3electionpb"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/clientv3/concurrency"
epb "go.etcd.io/etcd/etcdserver/api/v3election/v3electionpb"
)
// ErrMissingLeaderKey is returned when election API request

2
etcdserver/api/v3election/v3electionpb/gw/v3election.pb.gw.go
View File

@ -9,7 +9,7 @@ It translates gRPC into RESTful JSON APIs.
package gw
import (
"github.com/coreos/etcd/etcdserver/api/v3election/v3electionpb"
"go.etcd.io/etcd/etcdserver/api/v3election/v3electionpb"
"io"
"net/http"

4
etcdserver/api/v3election/v3electionpb/v3election.pb.go
View File

@ -29,9 +29,9 @@ import (
_ "github.com/gogo/protobuf/gogoproto"
etcdserverpb "github.com/coreos/etcd/etcdserver/etcdserverpb"
etcdserverpb "go.etcd.io/etcd/etcdserver/etcdserverpb"
mvccpb "github.com/coreos/etcd/mvcc/mvccpb"
mvccpb "go.etcd.io/etcd/mvcc/mvccpb"
context "golang.org/x/net/context"

6
etcdserver/api/v3lock/lock.go
View File

@ -17,9 +17,9 @@ package v3lock
import (
"context"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/clientv3/concurrency"
"github.com/coreos/etcd/etcdserver/api/v3lock/v3lockpb"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/clientv3/concurrency"
"go.etcd.io/etcd/etcdserver/api/v3lock/v3lockpb"
)
type lockServer struct {

2
etcdserver/api/v3lock/v3lockpb/gw/v3lock.pb.gw.go
View File

@ -9,7 +9,7 @@ It translates gRPC into RESTful JSON APIs.
package gw
import (
"github.com/coreos/etcd/etcdserver/api/v3lock/v3lockpb"
"go.etcd.io/etcd/etcdserver/api/v3lock/v3lockpb"
"io"
"net/http"

2
etcdserver/api/v3lock/v3lockpb/v3lock.pb.go
View File

@ -24,7 +24,7 @@ import (
_ "github.com/gogo/protobuf/gogoproto"
etcdserverpb "github.com/coreos/etcd/etcdserver/etcdserverpb"
etcdserverpb "go.etcd.io/etcd/etcdserver/etcdserverpb"
context "golang.org/x/net/context"

4
etcdserver/api/v3rpc/auth.go
View File

@ -17,8 +17,8 @@ package v3rpc
import (
"context"
"github.com/coreos/etcd/etcdserver"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/etcdserver"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
)
type AuthServer struct {

4
etcdserver/api/v3rpc/grpc.go
View File

@ -18,8 +18,8 @@ import (
"crypto/tls"
"math"
"github.com/coreos/etcd/etcdserver"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/etcdserver"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"github.com/grpc-ecosystem/go-grpc-middleware"
"github.com/grpc-ecosystem/go-grpc-prometheus"

4
etcdserver/api/v3rpc/header.go
View File

@ -15,8 +15,8 @@
package v3rpc
import (
"github.com/coreos/etcd/etcdserver"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/etcdserver"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
)
type header struct {

12
etcdserver/api/v3rpc/interceptor.go
View File

@ -19,13 +19,13 @@ import (
"sync"
"time"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
"go.etcd.io/etcd/pkg/types"
"go.etcd.io/etcd/raft"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"github.com/coreos/pkg/capnslog"
"go.uber.org/zap"
"google.golang.org/grpc"

10
etcdserver/api/v3rpc/key.go
View File

@ -18,16 +18,16 @@ package v3rpc
import (
"context"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/adt"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/adt"
"github.com/coreos/pkg/capnslog"
)
var (
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "etcdserver/api/v3rpc")
plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "etcdserver/api/v3rpc")
)
type kvServer struct {

8
etcdserver/api/v3rpc/lease.go
View File

@ -18,10 +18,10 @@ import (
"context"
"io"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/lease"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/lease"
"go.uber.org/zap"
)

16
etcdserver/api/v3rpc/maintenance.go
View File

@ -19,14 +19,14 @@ import (
"crypto/sha256"
"io"
"github.com/coreos/etcd/auth"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/mvcc"
"github.com/coreos/etcd/mvcc/backend"
"github.com/coreos/etcd/raft"
"github.com/coreos/etcd/version"
"go.etcd.io/etcd/auth"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/mvcc"
"go.etcd.io/etcd/mvcc/backend"
"go.etcd.io/etcd/raft"
"go.etcd.io/etcd/version"
"go.uber.org/zap"
)

12
etcdserver/api/v3rpc/member.go
View File

@ -18,12 +18,12 @@ import (
"context"
"time"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api"
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/types"
)
type ClusterServer struct {

8
etcdserver/api/v3rpc/quota.go
View File

@ -17,10 +17,10 @@ package v3rpc
import (
"context"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
"github.com/coreos/etcd/pkg/types"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
pb "go.etcd.io/etcd/etcdserver/etcdserverpb"
"go.etcd.io/etcd/pkg/types"
)
type quotaKVServer struct {

12
etcdserver/api/v3rpc/util.go
View File

@ -18,12 +18,12 @@ import (
"context"
"strings"
"github.com/coreos/etcd/auth"
"github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/membership"
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
"github.com/coreos/etcd/lease"
"github.com/coreos/etcd/mvcc"
"go.etcd.io/etcd/auth"
"go.etcd.io/etcd/etcdserver"
"go.etcd.io/etcd/etcdserver/api/membership"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
"go.etcd.io/etcd/lease"
"go.etcd.io/etcd/mvcc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"

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