Browse Source

*: revert "internal/lease" change

Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
Gyuho Lee 7 years ago
parent
commit
dd2f3b0de8

+ 1 - 1
clientv3/integration/maintenance_test.go

@@ -26,9 +26,9 @@ import (
 
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	"github.com/coreos/etcd/integration"
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/testutil"
 )
 

+ 1 - 1
etcdserver/api/etcdhttp/peer.go

@@ -20,7 +20,7 @@ import (
 
 	"github.com/coreos/etcd/etcdserver"
 	"github.com/coreos/etcd/etcdserver/api"
-	"github.com/coreos/etcd/internal/lease/leasehttp"
+	"github.com/coreos/etcd/lease/leasehttp"
 	"github.com/coreos/etcd/rafthttp"
 )
 

+ 1 - 1
etcdserver/api/v3rpc/lease.go

@@ -21,7 +21,7 @@ import (
 	"github.com/coreos/etcd/etcdserver"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/internal/lease"
+	"github.com/coreos/etcd/lease"
 )
 
 type LeaseServer struct {

+ 1 - 1
etcdserver/api/v3rpc/util.go

@@ -22,8 +22,8 @@ import (
 	"github.com/coreos/etcd/etcdserver"
 	"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
 	"github.com/coreos/etcd/etcdserver/membership"
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/lease"
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"

+ 1 - 1
etcdserver/apply.go

@@ -22,9 +22,9 @@ import (
 
 	"github.com/coreos/etcd/auth"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/types"
 
 	"github.com/gogo/protobuf/proto"

+ 1 - 1
etcdserver/apply_auth.go

@@ -19,8 +19,8 @@ import (
 
 	"github.com/coreos/etcd/auth"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/lease"
 )
 
 type authApplierV3 struct {

+ 1 - 1
etcdserver/backend.go

@@ -19,10 +19,10 @@ import (
 	"os"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/raft/raftpb"
 )
 

+ 2 - 2
etcdserver/server.go

@@ -38,12 +38,12 @@ import (
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/etcdserver/membership"
 	"github.com/coreos/etcd/etcdserver/stats"
-	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/internal/lease/leasehttp"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
 	"github.com/coreos/etcd/internal/store"
+	"github.com/coreos/etcd/lease"
+	"github.com/coreos/etcd/lease/leasehttp"
 	"github.com/coreos/etcd/pkg/fileutil"
 	"github.com/coreos/etcd/pkg/idutil"
 	"github.com/coreos/etcd/pkg/pbutil"

+ 1 - 1
etcdserver/server_test.go

@@ -28,11 +28,11 @@ import (
 
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/etcdserver/membership"
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
 	"github.com/coreos/etcd/internal/store"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/fileutil"
 	"github.com/coreos/etcd/pkg/idutil"
 	"github.com/coreos/etcd/pkg/mock/mockstorage"

+ 2 - 2
etcdserver/v3_server.go

@@ -23,9 +23,9 @@ import (
 	"github.com/coreos/etcd/auth"
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/etcdserver/membership"
-	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/internal/lease/leasehttp"
 	"github.com/coreos/etcd/internal/mvcc"
+	"github.com/coreos/etcd/lease"
+	"github.com/coreos/etcd/lease/leasehttp"
 	"github.com/coreos/etcd/raft"
 
 	"github.com/gogo/protobuf/proto"

+ 1 - 1
internal/mvcc/kv.go

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

+ 1 - 1
internal/mvcc/kv_test.go

@@ -21,9 +21,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/testutil"
 
 	"github.com/prometheus/client_golang/prometheus"

+ 1 - 1
internal/mvcc/kv_view.go

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

+ 2 - 1
internal/mvcc/kvstore.go

@@ -24,10 +24,11 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/schedule"
+
 	"github.com/coreos/pkg/capnslog"
 )
 

+ 1 - 1
internal/mvcc/kvstore_bench_test.go

@@ -18,8 +18,8 @@ import (
 	"sync/atomic"
 	"testing"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease"
 )
 
 type fakeConsistentIndex uint64

+ 1 - 1
internal/mvcc/kvstore_compaction_test.go

@@ -20,8 +20,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease"
 )
 
 func TestScheduleCompaction(t *testing.T) {

+ 1 - 1
internal/mvcc/kvstore_test.go

@@ -26,9 +26,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/schedule"
 	"github.com/coreos/etcd/pkg/testutil"
 )

+ 1 - 1
internal/mvcc/kvstore_txn.go

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

+ 1 - 3
internal/mvcc/metrics_txn.go

@@ -14,9 +14,7 @@
 
 package mvcc
 
-import (
-	"github.com/coreos/etcd/internal/lease"
-)
+import "github.com/coreos/etcd/lease"
 
 type metricsTxnWrite struct {
 	TxnWrite

+ 1 - 1
internal/mvcc/watchable_store.go

@@ -18,9 +18,9 @@ import (
 	"sync"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease"
 )
 
 // non-const so modifiable by tests

+ 1 - 1
internal/mvcc/watchable_store_bench_test.go

@@ -19,8 +19,8 @@ import (
 	"os"
 	"testing"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease"
 )
 
 func BenchmarkWatchableStorePut(b *testing.B) {

+ 1 - 1
internal/mvcc/watchable_store_test.go

@@ -23,9 +23,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease"
 )
 
 func TestWatch(t *testing.T) {

+ 1 - 1
internal/mvcc/watcher_bench_test.go

@@ -18,8 +18,8 @@ import (
 	"fmt"
 	"testing"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease"
 )
 
 func BenchmarkKVWatcherMemoryUsage(b *testing.B) {

+ 1 - 1
internal/mvcc/watcher_test.go

@@ -22,9 +22,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease"
 )
 
 // TestWatcherWatchID tests that each watcher provides unique watchID,

+ 0 - 0
internal/lease/doc.go → lease/doc.go


+ 0 - 0
internal/lease/leasehttp/doc.go → lease/leasehttp/doc.go


+ 2 - 2
internal/lease/leasehttp/http.go → lease/leasehttp/http.go

@@ -24,8 +24,8 @@ import (
 	"time"
 
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
-	"github.com/coreos/etcd/internal/lease"
-	"github.com/coreos/etcd/internal/lease/leasepb"
+	"github.com/coreos/etcd/lease"
+	"github.com/coreos/etcd/lease/leasepb"
 	"github.com/coreos/etcd/pkg/httputil"
 )
 

+ 1 - 1
internal/lease/leasehttp/http_test.go → lease/leasehttp/http_test.go

@@ -23,8 +23,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease"
 )
 
 func TestRenewHTTP(t *testing.T) {

+ 0 - 0
internal/lease/leasepb/lease.pb.go → lease/leasepb/lease.pb.go


+ 0 - 0
internal/lease/leasepb/lease.proto → lease/leasepb/lease.proto


+ 1 - 1
internal/lease/lessor.go → lease/lessor.go

@@ -22,8 +22,8 @@ import (
 	"sync"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease/leasepb"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease/leasepb"
 )
 
 // NoLease is a special LeaseID representing the absence of a lease.

+ 0 - 0
internal/lease/lessor_test.go → lease/lessor_test.go


+ 1 - 1
snapshot/v3_snapshot.go

@@ -30,11 +30,11 @@ import (
 	"github.com/coreos/etcd/etcdserver"
 	"github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/etcdserver/membership"
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/raftsnap"
 	"github.com/coreos/etcd/internal/store"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/fileutil"
 	"github.com/coreos/etcd/pkg/logger"
 	"github.com/coreos/etcd/pkg/types"

+ 1 - 1
tools/benchmark/cmd/mvcc-put.go

@@ -21,7 +21,7 @@ import (
 	"runtime/pprof"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
+	"github.com/coreos/etcd/lease"
 	"github.com/coreos/etcd/pkg/report"
 
 	"github.com/spf13/cobra"

+ 2 - 1
tools/benchmark/cmd/mvcc.go

@@ -18,9 +18,10 @@ import (
 	"os"
 	"time"
 
-	"github.com/coreos/etcd/internal/lease"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/backend"
+	"github.com/coreos/etcd/lease"
+
 	"github.com/spf13/cobra"
 )
 

+ 3 - 2
tools/etcd-dump-db/backend.go

@@ -19,11 +19,12 @@ import (
 	"fmt"
 	"path/filepath"
 
-	bolt "github.com/coreos/bbolt"
-	"github.com/coreos/etcd/internal/lease/leasepb"
 	"github.com/coreos/etcd/internal/mvcc"
 	"github.com/coreos/etcd/internal/mvcc/backend"
 	"github.com/coreos/etcd/internal/mvcc/mvccpb"
+	"github.com/coreos/etcd/lease/leasepb"
+
+	bolt "github.com/coreos/bbolt"
 )
 
 func snapDir(dataDir string) string {