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

mvcc: update import paths "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:12:03 -07:00
parent 1399bc69ce
commit d537b328cb
19 changed files with 46 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mvcc/backend/backend.go
View File

@ -42,7 +42,7 @@ var (
// This only works for linux. // This only works for linux.
initialMmapSize = uint64(10 * 1024 * 1024 * 1024) initialMmapSize = uint64(10 * 1024 * 1024 * 1024)
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "mvcc/backend") plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "mvcc/backend")
// minSnapshotWarningTimeout is the minimum threshold to trigger a long running snapshot warning. // minSnapshotWarningTimeout is the minimum threshold to trigger a long running snapshot warning.
minSnapshotWarningTimeout = 30 * time.Second minSnapshotWarningTimeout = 30 * time.Second

6
mvcc/kv.go
View File

@ -15,9 +15,9 @@
package mvcc package mvcc
import ( import (
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
) )
type RangeOptions struct { type RangeOptions struct {

8
mvcc/kv_test.go
View File

@ -21,10 +21,10 @@ import (
"testing" "testing"
"time" "time"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"github.com/coreos/etcd/pkg/testutil" "go.etcd.io/etcd/pkg/testutil"
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
dto "github.com/prometheus/client_model/go" dto "github.com/prometheus/client_model/go"

2
mvcc/kv_view.go
View File

@ -14,7 +14,7 @@
package mvcc package mvcc
import "github.com/coreos/etcd/lease" import "go.etcd.io/etcd/lease"
type readView struct{ kv KV } type readView struct{ kv KV }

10
mvcc/kvstore.go
View File

@ -25,10 +25,10 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"github.com/coreos/etcd/pkg/schedule" "go.etcd.io/etcd/pkg/schedule"
"github.com/coreos/pkg/capnslog" "github.com/coreos/pkg/capnslog"
"go.uber.org/zap" "go.uber.org/zap"
@ -47,7 +47,7 @@ var (
ErrCanceled = errors.New("mvcc: watcher is canceled") ErrCanceled = errors.New("mvcc: watcher is canceled")
ErrClosed = errors.New("mvcc: closed") ErrClosed = errors.New("mvcc: closed")
plog = capnslog.NewPackageLogger("github.com/coreos/etcd", "mvcc") plog = capnslog.NewPackageLogger("go.etcd.io/etcd", "mvcc")
) )
const ( const (

4
mvcc/kvstore_bench_test.go
View File

@ -18,8 +18,8 @@ import (
"sync/atomic" "sync/atomic"
"testing" "testing"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"go.uber.org/zap" "go.uber.org/zap"
) )

4
mvcc/kvstore_compaction_test.go
View File

@ -20,8 +20,8 @@ import (
"testing" "testing"
"time" "time"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"go.uber.org/zap" "go.uber.org/zap"
) )

10
mvcc/kvstore_test.go
View File

@ -26,11 +26,11 @@ import (
"testing" "testing"
"time" "time"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"github.com/coreos/etcd/pkg/schedule" "go.etcd.io/etcd/pkg/schedule"
"github.com/coreos/etcd/pkg/testutil" "go.etcd.io/etcd/pkg/testutil"
"go.uber.org/zap" "go.uber.org/zap"
) )

6
mvcc/kvstore_txn.go
View File

@ -15,9 +15,9 @@
package mvcc package mvcc
import ( import (
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"go.uber.org/zap" "go.uber.org/zap"
) )

2
mvcc/metrics_txn.go
View File

@ -14,7 +14,7 @@
package mvcc package mvcc
import "github.com/coreos/etcd/lease" import "go.etcd.io/etcd/lease"
type metricsTxnWrite struct { type metricsTxnWrite struct {
TxnWrite TxnWrite

4
mvcc/util.go
View File

@ -18,8 +18,8 @@ import (
"encoding/binary" "encoding/binary"
"fmt" "fmt"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
) )
func UpdateConsistentIndex(be backend.Backend, index uint64) { func UpdateConsistentIndex(be backend.Backend, index uint64) {

6
mvcc/watchable_store.go
View File

@ -18,9 +18,9 @@ import (
"sync" "sync"
"time" "time"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"go.uber.org/zap" "go.uber.org/zap"
) )

4
mvcc/watchable_store_bench_test.go
View File

@ -19,8 +19,8 @@ import (
"os" "os"
"testing" "testing"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"go.uber.org/zap" "go.uber.org/zap"
) )

6
mvcc/watchable_store_test.go
View File

@ -23,9 +23,9 @@ import (
"testing" "testing"
"time" "time"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"go.uber.org/zap" "go.uber.org/zap"
) )

2
mvcc/watchable_store_txn.go
View File

@ -14,7 +14,7 @@
package mvcc package mvcc
import "github.com/coreos/etcd/mvcc/mvccpb" import "go.etcd.io/etcd/mvcc/mvccpb"
func (tw *watchableStoreTxnWrite) End() { func (tw *watchableStoreTxnWrite) End() {
changes := tw.Changes() changes := tw.Changes()

2
mvcc/watcher.go
View File

@ -19,7 +19,7 @@ import (
"errors" "errors"
"sync" "sync"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
) )
// AutoWatchID is the watcher ID passed in WatchStream.Watch when no // AutoWatchID is the watcher ID passed in WatchStream.Watch when no

4
mvcc/watcher_bench_test.go
View File

@ -18,8 +18,8 @@ import (
"fmt" "fmt"
"testing" "testing"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"go.uber.org/zap" "go.uber.org/zap"
) )

4
mvcc/watcher_group.go
View File

@ -18,8 +18,8 @@ import (
"fmt" "fmt"
"math" "math"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"github.com/coreos/etcd/pkg/adt" "go.etcd.io/etcd/pkg/adt"
) )
var ( var (

6
mvcc/watcher_test.go
View File

@ -22,9 +22,9 @@ import (
"testing" "testing"
"time" "time"
"github.com/coreos/etcd/lease" "go.etcd.io/etcd/lease"
"github.com/coreos/etcd/mvcc/backend" "go.etcd.io/etcd/mvcc/backend"
"github.com/coreos/etcd/mvcc/mvccpb" "go.etcd.io/etcd/mvcc/mvccpb"
"go.uber.org/zap" "go.uber.org/zap"
) )