raftexample: update etcdserver to use the new raft module go.etcd.io/raft/v3

Just replaced all go.etcd.io/etcd/raft/v3 with go.etcd.io/raft/v3
under directory contrib/raftexample.

Signed-off-by: Benjamin Wang <wachao@vmware.com>
dependabot/go_modules/go.uber.org/atomic-1.10.0
Benjamin Wang 2022-12-02 14:25:50 +08:00
parent 8651478ce2
commit 0775d36e53
6 changed files with 7 additions and 7 deletions

View File

@ -20,7 +20,7 @@ import (
"net/http" "net/http"
"strconv" "strconv"
"go.etcd.io/etcd/raft/v3/raftpb" "go.etcd.io/raft/v3/raftpb"
) )
// Handler for a http based key-value store backed by raft // Handler for a http based key-value store backed by raft

View File

@ -21,8 +21,8 @@ import (
"log" "log"
"sync" "sync"
"go.etcd.io/etcd/raft/v3/raftpb"
"go.etcd.io/etcd/server/v3/etcdserver/api/snap" "go.etcd.io/etcd/server/v3/etcdserver/api/snap"
"go.etcd.io/raft/v3/raftpb"
) )
// a key-value store backed by raft // a key-value store backed by raft

View File

@ -18,7 +18,7 @@ import (
"flag" "flag"
"strings" "strings"
"go.etcd.io/etcd/raft/v3/raftpb" "go.etcd.io/raft/v3/raftpb"
) )
func main() { func main() {

View File

@ -26,13 +26,13 @@ import (
"go.etcd.io/etcd/client/pkg/v3/fileutil" "go.etcd.io/etcd/client/pkg/v3/fileutil"
"go.etcd.io/etcd/client/pkg/v3/types" "go.etcd.io/etcd/client/pkg/v3/types"
"go.etcd.io/etcd/raft/v3"
"go.etcd.io/etcd/raft/v3/raftpb"
"go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp" "go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp"
"go.etcd.io/etcd/server/v3/etcdserver/api/snap" "go.etcd.io/etcd/server/v3/etcdserver/api/snap"
stats "go.etcd.io/etcd/server/v3/etcdserver/api/v2stats" stats "go.etcd.io/etcd/server/v3/etcdserver/api/v2stats"
"go.etcd.io/etcd/server/v3/storage/wal" "go.etcd.io/etcd/server/v3/storage/wal"
"go.etcd.io/etcd/server/v3/storage/wal/walpb" "go.etcd.io/etcd/server/v3/storage/wal/walpb"
"go.etcd.io/raft/v3"
"go.etcd.io/raft/v3/raftpb"
"go.uber.org/zap" "go.uber.org/zap"
) )

View File

@ -18,7 +18,7 @@ import (
"reflect" "reflect"
"testing" "testing"
"go.etcd.io/etcd/raft/v3/raftpb" "go.etcd.io/raft/v3/raftpb"
) )
func TestProcessMessages(t *testing.T) { func TestProcessMessages(t *testing.T) {

View File

@ -25,7 +25,7 @@ import (
"testing" "testing"
"time" "time"
"go.etcd.io/etcd/raft/v3/raftpb" "go.etcd.io/raft/v3/raftpb"
) )
func getSnapshotFn() (func() ([]byte, error), <-chan struct{}) { func getSnapshotFn() (func() ([]byte, error), <-chan struct{}) {